X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fdevice%2FBarrierTaskBuilder.java;h=a2f83b974346cb361b55a3230392c581cb09b061;hb=f55fba5cc124ab2ad5990e60c492f9e92e08085f;hp=b1929d849e9f1dddb4dbf1b69668f521388a0e47;hpb=4199aaa1901223bfa12f95568263b1da0e89d660;p=openflowplugin.git

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/BarrierTaskBuilder.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/BarrierTaskBuilder.java
index b1929d849e..a2f83b9743 100644
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/BarrierTaskBuilder.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/BarrierTaskBuilder.java
@@ -56,7 +56,7 @@ public class BarrierTaskBuilder {
             @Override
             public void run(final Timeout timeout) throws Exception {
                 // check outstanding requests first
-                if (! deviceCtx.getRequests().isEmpty()) {
+                if (deviceCtx.getNumberOfOutstandingRequests() > 0) {
                     BarrierInput barrierInput = makeBarrier();
                     LOG.trace("sending out barrier [{}]", barrierInput.getXid());
                     final Future<RpcResult<BarrierOutput>> future = deviceCtx.getPrimaryConnectionContext()