X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FOperationLimiter.java;h=3f0c98c47ff218bc105be34a8b9d2cab10ab8a88;hb=729e3f9606dae61f98bd0bca0cfb082c22e5b8d8;hp=e1fee6d62b485393f3f98f9c3f9ffcfe64f34db9;hpb=6a0fab98dc4d16a52922c6594f99a97d4050e800;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/OperationLimiter.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/OperationLimiter.java index e1fee6d62b..3f0c98c47f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/OperationLimiter.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/OperationLimiter.java @@ -7,8 +7,10 @@ */ package org.opendaylight.controller.cluster.datastore; +import static com.google.common.base.Preconditions.checkArgument; +import static java.util.Objects.requireNonNull; + import com.google.common.annotations.VisibleForTesting; -import com.google.common.base.Preconditions; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; @@ -26,12 +28,12 @@ public class OperationLimiter { private final int maxPermits; OperationLimiter(final TransactionIdentifier identifier, final int maxPermits, final long acquireTimeoutSeconds) { - this.identifier = Preconditions.checkNotNull(identifier); + this.identifier = requireNonNull(identifier); - Preconditions.checkArgument(acquireTimeoutSeconds >= 0); + checkArgument(acquireTimeoutSeconds >= 0); this.acquireTimeout = TimeUnit.SECONDS.toNanos(acquireTimeoutSeconds); - Preconditions.checkArgument(maxPermits >= 0); + checkArgument(maxPermits >= 0); this.maxPermits = maxPermits; this.semaphore = new Semaphore(maxPermits); } @@ -60,7 +62,7 @@ public class OperationLimiter { release(1); } - void release(int permits) { + void release(final int permits) { this.semaphore.release(permits); }