import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
+import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.datastore.ShardCommitCoordinator.CohortDecorator;
import org.opendaylight.controller.cluster.datastore.modification.Modification;
import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate;
private final Stopwatch lastAccessTimer = Stopwatch.createStarted();
private final ReadWriteShardDataTreeTransaction transaction;
- private final String transactionID;
+ private final TransactionIdentifier transactionID;
private final CompositeDataTreeCohort userCohorts;
private final short clientVersion;
private ActorRef replySender;
private Shard shard;
- CohortEntry(String transactionID, ReadWriteShardDataTreeTransaction transaction,
+ CohortEntry(TransactionIdentifier transactionID, ReadWriteShardDataTreeTransaction transaction,
DataTreeCohortActorRegistry cohortRegistry, SchemaContext schema, short clientVersion) {
this.transaction = Preconditions.checkNotNull(transaction);
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.clientVersion = clientVersion;
this.userCohorts = new CompositeDataTreeCohort(cohortRegistry, transactionID, schema, COMMIT_STEP_TIMEOUT);
}
- CohortEntry(String transactionID, ShardDataTreeCohort cohort, DataTreeCohortActorRegistry cohortRegistry,
+ CohortEntry(TransactionIdentifier transactionID, ShardDataTreeCohort cohort, DataTreeCohortActorRegistry cohortRegistry,
SchemaContext schema, short clientVersion) {
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.cohort = cohort;
this.transaction = null;
this.clientVersion = clientVersion;
lastAccessTimer.start();
}
- String getTransactionID() {
+ TransactionIdentifier getTransactionID() {
return transactionID;
}