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%2FShardTransaction.java;h=ee38d1918e13442dc6983a40cabc6ac64e77b65e;hp=c2a05a6d6130a3d3b28dd9879eebef70dcaf9e65;hb=4062f5241a2a6f58ffb83dd1e9939ee66122d217;hpb=d0621d28e507d9f6c0b9445d197f90253d34725d diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java index c2a05a6d61..ee38d1918e 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardTransaction.java @@ -52,9 +52,8 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering } public static Props props(TransactionType type, AbstractShardDataTreeTransaction transaction, ActorRef shardActor, - DatastoreContext datastoreContext, ShardStats shardStats, String transactionID) { - return Props.create(new ShardTransactionCreator(type, transaction, shardActor, - datastoreContext, shardStats, transactionID)); + DatastoreContext datastoreContext, ShardStats shardStats) { + return Props.create(new ShardTransactionCreator(type, transaction, shardActor, datastoreContext, shardStats)); } protected abstract AbstractShardDataTreeTransaction getDOMStoreTransaction(); @@ -131,16 +130,14 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering final ActorRef shardActor; final DatastoreContext datastoreContext; final ShardStats shardStats; - final String transactionID; final TransactionType type; ShardTransactionCreator(TransactionType type, AbstractShardDataTreeTransaction transaction, ActorRef shardActor, - DatastoreContext datastoreContext, ShardStats shardStats, String transactionID) { + DatastoreContext datastoreContext, ShardStats shardStats) { this.transaction = Preconditions.checkNotNull(transaction); this.shardActor = shardActor; this.shardStats = shardStats; this.datastoreContext = datastoreContext; - this.transactionID = Preconditions.checkNotNull(transactionID); this.type = type; } @@ -149,16 +146,13 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering final ShardTransaction tx; switch (type) { case READ_ONLY: - tx = new ShardReadTransaction(transaction, shardActor, - shardStats, transactionID); + tx = new ShardReadTransaction(transaction, shardActor, shardStats); break; case READ_WRITE: - tx = new ShardReadWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, - shardActor, shardStats, transactionID); + tx = new ShardReadWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, shardActor, shardStats); break; case WRITE_ONLY: - tx = new ShardWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, - shardActor, shardStats, transactionID); + tx = new ShardWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, shardActor, shardStats); break; default: throw new IllegalArgumentException("Unhandled transaction type " + type);