X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FCompositeDataTreeCohort.java;h=d833962277d9a1c3ee1785c2147737740649b6f5;hp=07ff936b2f8e87f331e53fb71212a57040b3f9e8;hb=4d1709660b7af992d4c382a2a38debb5c7d64fb9;hpb=21186d16ca8b233674ebdf3aa1ea190a2c0b3959 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/CompositeDataTreeCohort.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/CompositeDataTreeCohort.java index 07ff936b2f..d833962277 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/CompositeDataTreeCohort.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/CompositeDataTreeCohort.java @@ -23,6 +23,7 @@ import java.util.Collection; import java.util.Iterator; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeoutException; +import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.controller.cluster.datastore.DataTreeCohortActor.CanCommit; import org.opendaylight.controller.cluster.datastore.DataTreeCohortActor.Success; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidateTip; @@ -91,15 +92,16 @@ class CompositeDataTreeCohort { private final DataTreeCohortActorRegistry registry; - private final String txId; + private final TransactionIdentifier txId; private final SchemaContext schema; private final Timeout timeout; private Iterable successfulFromPrevious; private State state = State.IDLE; - CompositeDataTreeCohort(DataTreeCohortActorRegistry registry, String txId, SchemaContext schema, Timeout timeout) { + CompositeDataTreeCohort(DataTreeCohortActorRegistry registry, TransactionIdentifier transactionID, + SchemaContext schema, Timeout timeout) { this.registry = Preconditions.checkNotNull(registry); - this.txId = Preconditions.checkNotNull(txId); + this.txId = Preconditions.checkNotNull(transactionID); this.schema = Preconditions.checkNotNull(schema); this.timeout = Preconditions.checkNotNull(timeout); }