X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardDataTreeTransactionChain.java;h=2554151dd73c6e4a0442169474530f21d0bcd586;hb=refs%2Fchanges%2F26%2F39426%2F73;hp=9a8e89eb422c4b4f909e6a6c3ea97366d1ab01f2;hpb=5fd8e6506248cc34da72281a1662612f6c2b2f9a;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeTransactionChain.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeTransactionChain.java index 9a8e89eb42..2554151dd7 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeTransactionChain.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeTransactionChain.java @@ -24,6 +24,7 @@ import org.slf4j.LoggerFactory; @NotThreadSafe final class ShardDataTreeTransactionChain extends ShardDataTreeTransactionParent implements Identifiable { + private static final Logger LOG = LoggerFactory.getLogger(ShardDataTreeTransactionChain.class); private final LocalHistoryIdentifier chainId; private final ShardDataTree dataTree; @@ -42,10 +43,12 @@ final class ShardDataTreeTransactionChain extends ShardDataTreeTransactionParent Preconditions.checkState(openTransaction == null, "Transaction %s is open", openTransaction); if (previousTx == null) { + LOG.debug("Opening an unchained snapshot in {}", chainId); return dataTree.takeSnapshot(); - } else { - return previousTx.getSnapshot(); } + + LOG.debug("Reusing a chained snapshot in {}", chainId); + return previousTx.getSnapshot(); } ReadOnlyShardDataTreeTransaction newReadOnlyTransaction(final TransactionIdentifier txId) { @@ -65,6 +68,7 @@ final class ShardDataTreeTransactionChain extends ShardDataTreeTransactionParent void close() { closed = true; + LOG.debug("Closing chain {}", chainId); } @Override