commit | 67af1f4247af9b60e899a76b468b27e95e379337 | [log] [tgz] |
---|---|---|
author | Ayaka Koshibe <ayaka@onlab.us> | Mon Oct 20 15:26:37 2014 -0700 |
committer | Ayaka Koshibe <ayaka@onlab.us> | Mon Oct 20 17:31:10 2014 -0700 |
tree | dae8339ca718a1ba8d5e91cd3826c078b5277293 | |
parent | f4f23fcdf4806c350c7846420dbafee1e978e39c [diff] |
add roleInfo structure and backup_changed mastership event Change-Id: Iedee219fe250d681377d73a50a71f5fa72cd7802
diff --git a/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java b/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java index 7cf14fc..867c6cb 100644 --- a/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java +++ b/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java
@@ -228,8 +228,8 @@ return true; } //else { - //FIXME: break tie for equal-sized clusters, - // maybe by number of connected switches + //FIXME: break tie for equal-sized clusters, by number of + // connected switches, then masters, then nodeId hash // } return false; }
diff --git a/core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java b/core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java index b163f08..8ee6f55 100644 --- a/core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java +++ b/core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java
@@ -367,7 +367,7 @@ final NodeId myNodeId = clusterService.getLocalNode().id(); log.info("## got Mastershipevent for dev {}", did); - if (myNodeId.equals(event.master())) { + if (myNodeId.equals(event.node())) { MastershipTerm term = termService.getMastershipTerm(did); if (!myNodeId.equals(term.master())) {