import akka.actor.ActorSelection;
import akka.dispatch.OnComplete;
import com.google.common.base.Preconditions;
-import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.cluster.datastore.compat.PreLithiumTransactionContextImpl;
import org.opendaylight.controller.cluster.datastore.exceptions.NoShardLeaderException;
return parent.getActorContext();
}
- private Semaphore getOperationLimiter() {
+ private OperationLimiter getOperationLimiter() {
return parent.getLimiter();
}
if (remoteTransactionVersion < DataStoreVersions.LITHIUM_VERSION) {
ret = new PreLithiumTransactionContextImpl(transactionPath, transactionActor, getIdentifier(),
- getActorContext(), isTxActorLocal, remoteTransactionVersion, parent.getCompleter());
+ getActorContext(), isTxActorLocal, remoteTransactionVersion, parent.getLimiter());
} else {
ret = new RemoteTransactionContext(transactionActor, getIdentifier(), getActorContext(),
- isTxActorLocal, remoteTransactionVersion, parent.getCompleter());
+ isTxActorLocal, remoteTransactionVersion, parent.getLimiter());
}
if(parent.getType() == TransactionType.READ_ONLY) {