X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=dom%2Fmdsal-dom-inmemory-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fdom%2Fstore%2Finmemory%2FShardSubmitCoordinationTask.java;h=6034e0b6b0f3b41c065071c3b03340ae70873513;hb=dca009bba2d4ceb2e13537f3ac6f9a5f1b05302f;hp=c7b0ee6adc01ae91c3222d6a25f708615f220242;hpb=395348596fcc6296e1a9ed0d9899b5aa16f08625;p=mdsal.git

diff --git a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ShardSubmitCoordinationTask.java b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ShardSubmitCoordinationTask.java
index c7b0ee6adc..6034e0b6b0 100644
--- a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ShardSubmitCoordinationTask.java
+++ b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/ShardSubmitCoordinationTask.java
@@ -31,29 +31,34 @@ public class ShardSubmitCoordinationTask implements Callable<Void> {
     private final ShardCanCommitCoordinationTask canCommitCoordinationTask;
     private final ShardPreCommitCoordinationTask preCommitCoordinationTask;
     private final ShardCommitCoordinationTask commitCoordinationTask;
+    private final InmemoryDOMDataTreeShardWriteTransaction transaction;
 
 
     public ShardSubmitCoordinationTask(final DOMDataTreeIdentifier rootShardPrefix,
-                                       final Collection<DOMStoreThreePhaseCommitCohort> cohorts) {
+                                       final Collection<DOMStoreThreePhaseCommitCohort> cohorts,
+                                       final InmemoryDOMDataTreeShardWriteTransaction transaction) {
         this.rootShardPrefix = Preconditions.checkNotNull(rootShardPrefix);
+        this.transaction = transaction;
 
         canCommitCoordinationTask = new ShardCanCommitCoordinationTask(rootShardPrefix, cohorts);
         preCommitCoordinationTask = new ShardPreCommitCoordinationTask(rootShardPrefix, cohorts);
-        commitCoordinationTask = new ShardCommitCoordinationTask(rootShardPrefix, cohorts);
+        commitCoordinationTask = new ShardCommitCoordinationTask(rootShardPrefix, cohorts, transaction);
     }
 
     @Override
     public Void call() throws TransactionCommitFailedException {
 
-        LOG.debug("Shard {}, CanCommit started", rootShardPrefix);
+        LOG.debug("Shard {}, tx{} CanCommit started", transaction.getIdentifier(), rootShardPrefix);
         canCommitCoordinationTask.canCommitBlocking();
 
-        LOG.debug("Shard {}, PreCommit started", rootShardPrefix);
+        LOG.debug("Shard {}, tx{} PreCommit started", transaction.getIdentifier(), rootShardPrefix);
         preCommitCoordinationTask.preCommitBlocking();
 
-        LOG.debug("Shard {}, commit started", rootShardPrefix);
+        LOG.debug("Shard {}, tx{} commit started", transaction.getIdentifier(), rootShardPrefix);
         commitCoordinationTask.commitBlocking();
 
+        transaction.transactionCommited(transaction);
+
         return null;
     }
 }