Fix for ticket no. ONOS-4754. Adding break statement to FLOW_REMOVED also
Change-Id: Icfcd52ad098e51911b7b5d3e97ad24c011a139ef
Showing
1 changed file
with
3 additions
and
1 deletions
| ... | @@ -303,8 +303,10 @@ public class OpenFlowControllerImpl implements OpenFlowController { | ... | @@ -303,8 +303,10 @@ public class OpenFlowControllerImpl implements OpenFlowController { |
| 303 | case FLOW_REMOVED: | 303 | case FLOW_REMOVED: |
| 304 | if (monitorAllEvents) { | 304 | if (monitorAllEvents) { |
| 305 | executorFlowRemoved.execute(new OFMessageHandler(dpid, msg)); | 305 | executorFlowRemoved.execute(new OFMessageHandler(dpid, msg)); |
| 306 | - break; | 306 | + } else { |
| 307 | + executorMsgs.execute(new OFMessageHandler(dpid, msg)); | ||
| 307 | } | 308 | } |
| 309 | + break; | ||
| 308 | case ERROR: | 310 | case ERROR: |
| 309 | log.debug("Received error message from {}: {}", dpid, msg); | 311 | log.debug("Received error message from {}: {}", dpid, msg); |
| 310 | errorMsgs.putIfAbsent(msg.getXid(), true); | 312 | errorMsgs.putIfAbsent(msg.getXid(), true); | ... | ... |
-
Please register or login to post a comment