[VOL-4246] Feature parity with the previous implementation
Change-Id: I3741edb3c1b88b1cf8b5e6d4ff0900132e2e5e6a
diff --git a/impl/src/main/java/org/opencord/olt/driver/OltPipeline.java b/impl/src/main/java/org/opencord/olt/driver/OltPipeline.java
index 459526c..29d234b 100644
--- a/impl/src/main/java/org/opencord/olt/driver/OltPipeline.java
+++ b/impl/src/main/java/org/opencord/olt/driver/OltPipeline.java
@@ -1152,7 +1152,9 @@
// Builds the batch using the accumulated flow rules
private void sendFilters(List<Pair<FilteringObjective, FlowRule>> pairs) {
FlowRuleOperations.Builder flowOpsBuilder = FlowRuleOperations.builder();
- log.debug("Sending batch of {} filter-objs", pairs.size());
+ if (log.isDebugEnabled()) {
+ log.debug("Sending batch of {} filter-objs", pairs.size());
+ }
List<Objective> filterObjs = Lists.newArrayList();
// Iterates over all accumulated flow rules and then build an unique batch
pairs.forEach(pair -> {
@@ -1161,12 +1163,16 @@
switch (filter.type()) {
case PERMIT:
flowOpsBuilder.add(rule);
- log.debug("Applying add filter-obj {} to device: {}", filter.id(), deviceId);
+ if (log.isTraceEnabled()) {
+ log.trace("Applying add filter-obj {} to device: {}", filter.id(), deviceId);
+ }
filterObjs.add(filter);
break;
case DENY:
flowOpsBuilder.remove(rule);
- log.debug("Deleting flow rule {} to device: {}", rule, deviceId);
+ if (log.isTraceEnabled()) {
+ log.trace("Deleting flow rule {} from device: {}", rule, deviceId);
+ }
filterObjs.add(filter);
break;
default: