Move OperationLimiter.acquire() warnings to callers

[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / RemoteTransactionContext.java

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java
index 7c45c542bd1422887c5c96cd9f53ce3ce81e9268..941c86116cb7926ebd13a6b55b79b32484bdd54e 100644 (file)
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/RemoteTransactionContext.java
@@ -245,7 +245,16 @@ public class RemoteTransactionContext extends AbstractTransactionContext {
      * @return True if a permit was successfully acquired, false otherwise
      */
     private boolean acquireOperation() {
-        return isOperationHandOffComplete() && limiter.acquire();
+        if (isOperationHandOffComplete()) {
+            if (limiter.acquire()) {
+                return true;
+            }
+
+            LOG.warn("Failed to acquire execute operation permit for transaction {} on actor {}", getIdentifier(),
+                actor);
+        }
+
+        return false;
     }
 
     @Override