- Plugin sends Barrier msg every 100 async msgs (configurable thru config.ini: of...

[controller.git] / opendaylight / protocol_plugins / openflow / src / main / java / org / opendaylight / controller / protocol_plugin / openflow / core / internal / SynchronousMessage.java

diff --git a/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/SynchronousMessage.java b/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/SynchronousMessage.java
index 5e613e8642489c0dce449fdcb242700406142f20..4737d4cea9c1b95333f9c3d5ff2e5410ea392552 100644 (file)
--- a/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/SynchronousMessage.java
+++ b/opendaylight/protocol_plugins/openflow/src/main/java/org/opendaylight/controller/protocol_plugin/openflow/core/internal/SynchronousMessage.java
@@ -46,8 +46,10 @@ public class SynchronousMessage implements Callable<Object> {
     @Override
     public Object call() throws Exception {
         sw.asyncSend(syncMsg, xid);
-        OFBarrierRequest barrierMsg = new OFBarrierRequest();
-        sw.asyncSend(barrierMsg, xid);
+        if (!(syncMsg instanceof OFBarrierRequest)) {
+            OFBarrierRequest barrierMsg = new OFBarrierRequest();
+            sw.asyncSend(barrierMsg, xid);
+        }
         latch.await();
         return result;
     }