import com.google.common.base.Preconditions;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
-import org.opendaylight.controller.cluster.datastore.identifiers.TransactionIdentifier;
+import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.datastore.messages.BatchedModificationsReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private final Semaphore semaphore;
private final int maxPermits;
- OperationLimiter(final TransactionIdentifier identifier, final int maxPermits, final int acquireTimeoutSeconds) {
+ OperationLimiter(final TransactionIdentifier identifier, final int maxPermits, final long acquireTimeoutSeconds) {
this.identifier = Preconditions.checkNotNull(identifier);
Preconditions.checkArgument(acquireTimeoutSeconds >= 0);
}
@VisibleForTesting
- int availablePermits(){
+ int availablePermits() {
return semaphore.availablePermits();
}
/**
- * Release all the permits
+ * Release all the permits.
*/
public void releaseAll() {
- this.semaphore.release(maxPermits-availablePermits());
+ this.semaphore.release(maxPermits - availablePermits());
}
}