From: Jozef Bacigal <jozef.bacigal@pantheon.tech>
Date: Mon, 26 Sep 2016 15:32:46 +0000 (+0000)
Subject: Merge "Bug 6745 Set compression semaphore to fair"
X-Git-Tag: release/carbon~150
X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=commitdiff_plain;h=f042bcf0c7dcac8e8d934d87cb723ad4d1af4a3b;hp=ee075da6265162249248390efe492ec6e9464427;p=openflowplugin.git

Merge "Bug 6745 Set compression semaphore to fair"
---

diff --git a/applications/forwardingrules-sync/src/main/java/org/opendaylight/openflowplugin/applications/frsync/impl/SyncReactorFutureZipDecorator.java b/applications/forwardingrules-sync/src/main/java/org/opendaylight/openflowplugin/applications/frsync/impl/SyncReactorFutureZipDecorator.java
index 0889216d89..4393b05d8f 100644
--- a/applications/forwardingrules-sync/src/main/java/org/opendaylight/openflowplugin/applications/frsync/impl/SyncReactorFutureZipDecorator.java
+++ b/applications/forwardingrules-sync/src/main/java/org/opendaylight/openflowplugin/applications/frsync/impl/SyncReactorFutureZipDecorator.java
@@ -29,7 +29,7 @@ public class SyncReactorFutureZipDecorator extends SyncReactorFutureDecorator {
 
     @GuardedBy("compressionGuard")
     private final Map<InstanceIdentifier<FlowCapableNode>, SyncupEntry> compressionQueue = new HashMap<>();
-    private final Semaphore compressionGuard = new Semaphore(1, false);
+    private final Semaphore compressionGuard = new Semaphore(1, true);
 
     public SyncReactorFutureZipDecorator(SyncReactor delegate, ListeningExecutorService executorService) {
         super(delegate, executorService);