X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardTransaction.java;h=3b3462884f85b6987b8a1777e797503e58255976;hb=844efe1d20cb61e5983532038e5135793fde5863;hp=44393a14f1c1ff1daae4a14d808a36225133d689;hpb=ab1ade6589dfeb820dedb0ef415103bb8270d616;p=controller.git 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 44393a14f1..3b3462884f 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 @@ -29,6 +29,7 @@ import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; /** * The ShardTransaction Actor represents a remote transaction that delegates all actions to DOMDataReadWriteTransaction. */ +@Deprecated(since = "9.0.0", forRemoval = true) public abstract class ShardTransaction extends AbstractUntypedActorWithMetering { private final ActorRef shardActor; private final ShardStats shardStats; @@ -119,7 +120,7 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering @SuppressFBWarnings(value = "SE_BAD_FIELD", justification = "Some fields are not Serializable but we don't " + "create remote instances of this actor and thus don't need it to be Serializable.") private static class ShardTransactionCreator implements Creator { - + @java.io.Serial private static final long serialVersionUID = 1L; final AbstractShardDataTreeTransaction transaction; @@ -139,23 +140,14 @@ public abstract class ShardTransaction extends AbstractUntypedActorWithMetering @Override public ShardTransaction create() { - final ShardTransaction tx; - switch (type) { - case READ_ONLY: - tx = new ShardReadTransaction(transaction, shardActor, shardStats); - break; - case READ_WRITE: - tx = new ShardReadWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, shardActor, - shardStats); - break; - case WRITE_ONLY: - tx = new ShardWriteTransaction((ReadWriteShardDataTreeTransaction)transaction, shardActor, - shardStats); - break; - default: - throw new IllegalArgumentException("Unhandled transaction type " + type); - } - + final var tx = switch (type) { + case READ_ONLY -> new ShardReadTransaction(transaction, shardActor, shardStats); + case READ_WRITE -> new ShardReadWriteTransaction((ReadWriteShardDataTreeTransaction) transaction, + shardActor, shardStats); + case WRITE_ONLY -> new ShardWriteTransaction((ReadWriteShardDataTreeTransaction) transaction, + shardActor, shardStats); + default -> throw new IllegalArgumentException("Unhandled transaction type " + type); + }; tx.getContext().setReceiveTimeout(datastoreContext.getShardTransactionIdleTimeout()); return tx; }