X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=common%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fcommon%2Fnetwork%2FRequestProcessor.java;h=d3d82f0ac8637884439bb33254d048f4c6fbf6eb;hb=refs%2Fchanges%2F24%2F83624%2F2;hp=807589fd0c9a27a894478e2502e78ab3b5a31c26;hpb=1bf7f298852d03faf47011c75978ce44bee135d7;p=transportpce.git

diff --git a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
index 807589fd0..d3d82f0ac 100644
--- a/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
+++ b/common/src/main/java/org/opendaylight/transportpce/common/network/RequestProcessor.java
@@ -8,12 +8,15 @@
 package org.opendaylight.transportpce.common.network;
 
 import com.google.common.base.Optional;
+import com.google.common.util.concurrent.FluentFuture;
 import com.google.common.util.concurrent.ListenableFuture;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
+import org.eclipse.jdt.annotation.NonNull;
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.mdsal.common.api.CommitInfo;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
@@ -101,6 +104,15 @@ public class RequestProcessor {
         return future;
     }
 
+    public FluentFuture<? extends @NonNull CommitInfo> commit() {
+        acquireLock();
+        FluentFuture<? extends @NonNull CommitInfo> future = null;
+        future = rwTx.commit();
+        releaseLock();
+        resetRwTx();
+        return future;
+    }
+
     public void close() {
         releaseLock();
     }