Madan Jampani

Removed fixed TODO. Cleaned up logging

...@@ -95,8 +95,6 @@ public class DistributedFlowRuleStore ...@@ -95,8 +95,6 @@ public class DistributedFlowRuleStore
95 storeFlowEntryInternal(rule); 95 storeFlowEntryInternal(rule);
96 // FIXME what to respond. 96 // FIXME what to respond.
97 try { 97 try {
98 - // FIXME: #respond() not working. responded message is
99 - // handled by this sender node and never goes back.
100 message.respond(SERIALIZER.encode("ACK")); 98 message.respond(SERIALIZER.encode("ACK"));
101 } catch (IOException e) { 99 } catch (IOException e) {
102 log.error("Failed to respond back", e); 100 log.error("Failed to respond back", e);
...@@ -173,7 +171,8 @@ public class DistributedFlowRuleStore ...@@ -173,7 +171,8 @@ public class DistributedFlowRuleStore
173 return storeFlowEntryInternal(rule); 171 return storeFlowEntryInternal(rule);
174 } 172 }
175 173
176 - log.warn("Not my flow forwarding to {}", replicaInfo.master().orNull()); 174 + log.info("Forwarding storeFlowRule to {}, which is the primary (master) for device {}",
175 + replicaInfo.master().orNull(), rule.deviceId());
177 176
178 ClusterMessage message = new ClusterMessage( 177 ClusterMessage message = new ClusterMessage(
179 clusterService.getLocalNode().id(), 178 clusterService.getLocalNode().id(),
......
...@@ -347,6 +347,11 @@ ...@@ -347,6 +347,11 @@
347 <pluginManagement> 347 <pluginManagement>
348 <plugins> 348 <plugins>
349 <plugin> 349 <plugin>
350 + <groupId>kr.motd.maven</groupId>
351 + <artifactId>os-maven-plugin</artifactId>
352 + <version>1.2.3.Final</version>
353 + </plugin>
354 + <plugin>
350 <groupId>org.apache.maven.plugins</groupId> 355 <groupId>org.apache.maven.plugins</groupId>
351 <artifactId>maven-compiler-plugin</artifactId> 356 <artifactId>maven-compiler-plugin</artifactId>
352 <!-- TODO: update once following issue is fixed. --> 357 <!-- TODO: update once following issue is fixed. -->
......