commit | e8708e3c8db69b42be912f8dc903a5d7f7cff40c | [log] [tgz] |
---|---|---|
author | Ayaka Koshibe <ayaka@onlab.us> | Wed Oct 22 13:40:18 2014 -0700 |
committer | Ayaka Koshibe <ayaka@onlab.us> | Wed Oct 22 13:40:18 2014 -0700 |
tree | eafd3b1dc705e8d02095a597e1dabe25b36e6ebd | |
parent | 3ab76a84f0ecc52e18e1116891dd025403f2704f [diff] |
trigger device query after mastership reelection Change-Id: Ibf8b32ed1de2a904289731596a28bd5524d6ea25 Conflicts: core/net/src/main/java/org/onlab/onos/net/device/impl/DeviceManager.java
diff --git a/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OFChannelHandler.java b/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OFChannelHandler.java index 009cd3f..d15d9f1 100644 --- a/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OFChannelHandler.java +++ b/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OFChannelHandler.java
@@ -608,6 +608,12 @@ h.dispatchMessage(m); } + @Override + void processOFFeaturesReply(OFChannelHandler h, OFFeaturesReply m) { + // TODO verify this leads to right behavior. + h.dispatchMessage(m); + } + }; private final boolean handshakeComplete;
diff --git a/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OpenFlowControllerImpl.java b/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OpenFlowControllerImpl.java index 565ccb9..46b8be6 100644 --- a/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OpenFlowControllerImpl.java +++ b/openflow/ctl/src/main/java/org/onlab/onos/openflow/controller/impl/OpenFlowControllerImpl.java
@@ -142,6 +142,7 @@ public void processPacket(Dpid dpid, OFMessage msg) { switch (msg.getType()) { case PORT_STATUS: + case FEATURES_REPLY: for (OpenFlowSwitchListener l : ofSwitchListener) { l.portChanged(dpid, (OFPortStatus) msg); }