commit f5d263b41f32d1cef9d6fe7f6d52708e9a9b2f71
author Madan Jampani <madan@onlab.us> Thu Nov 13 10:04:40 2014 -0800
committer Madan Jampani <madan@onlab.us> Thu Nov 13 12:45:50 2014 -0800
tree 22546f14c2d897cf71025022918d51f75c58bb7c
parent f8e5b4e0b9bc796b629cea9ae027b357072d36a3

Bugfixes for DistributedLockManager functionality
Added a method called broadcastIncludeSelf to ClusterCommunicationService.
Cosmetic improvements: added toString methods

Change-Id: I1d58720c29e6f8642f950670c3a6d95a7019a491

core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java

diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
index 6de94b4..0be310e 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
@@ -116,6 +116,15 @@
     }
 
     @Override
+    public boolean broadcastIncludeSelf(ClusterMessage message) throws IOException {
+        boolean ok = true;
+        for (ControllerNode node : clusterService.getNodes()) {
+            ok = unicast(message, node.id()) && ok;
+        }
+        return ok;
+    }
+
+    @Override
     public boolean multicast(ClusterMessage message, Set<NodeId> nodes) throws IOException {
         boolean ok = true;
         final ControllerNode localNode = clusterService.getLocalNode();
@@ -209,4 +218,4 @@
             rawMessage.respond(response);
         }
     }
-}
\ No newline at end of file
+}