Remove AsyncWriteTransaction.submit() impls 82/71582/5
authorTom Pantelis <tompantelis@gmail.com>
Mon, 30 Apr 2018 14:39:23 +0000 (10:39 -0400)
committerTom Pantelis <tompantelis@gmail.com>
Fri, 8 Jun 2018 21:41:46 +0000 (17:41 -0400)
The submit() method is now defaulted in the interface
so implementations don't need to implement it.

Change-Id: Ibdb988739df9ea309c2debd9c31dc1b9bf18e83d
Signed-off-by: Tom Pantelis <tompantelis@gmail.com>
netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/tx/AbstractWriteTx.java
netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/tx/ReadWriteTx.java
netconf/sal-netconf-connector/src/test/java/org/opendaylight/netconf/sal/connect/netconf/sal/tx/ReadWriteTxTest.java

index 56b3dab7d94ca1c779824fd48e38d7d1a0e5fac7..6e3b0554c64e1cd68c6bfcdd2d8fd299bda73f43 100644 (file)
@@ -11,7 +11,6 @@ package org.opendaylight.netconf.sal.connect.netconf.sal.tx;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.Lists;
-import com.google.common.util.concurrent.CheckedFuture;
 import com.google.common.util.concurrent.FluentFuture;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
@@ -28,12 +27,10 @@ import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFaile
 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult;
 import org.opendaylight.mdsal.common.api.CommitInfo;
-import org.opendaylight.mdsal.common.api.MappingCheckedFuture;
 import org.opendaylight.netconf.api.DocumentedException;
 import org.opendaylight.netconf.api.NetconfDocumentedException;
 import org.opendaylight.netconf.sal.connect.netconf.util.NetconfBaseOps;
 import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId;
-import org.opendaylight.yangtools.util.concurrent.ExceptionMapper;
 import org.opendaylight.yangtools.yang.common.RpcError;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
@@ -153,17 +150,6 @@ public abstract class AbstractWriteTx implements DOMDataWriteTransaction {
                 editStructure, Optional.of(ModifyAction.NONE), "delete");
     }
 
-    @Override
-    public CheckedFuture<Void, TransactionCommitFailedException> submit() {
-        return MappingCheckedFuture.create(commit().transform(ignored -> null, MoreExecutors.directExecutor()),
-            new ExceptionMapper<TransactionCommitFailedException>("commit", TransactionCommitFailedException.class) {
-                @Override
-                protected TransactionCommitFailedException newWithCause(String message, Throwable cause) {
-                    return new TransactionCommitFailedException(message, cause);
-                }
-            });
-    }
-
     @Override
     public @NonNull FluentFuture<? extends @NonNull CommitInfo> commit() {
         final SettableFuture<CommitInfo> resultFuture = SettableFuture.create();
index 02803c6a7ae95ea7739f93855138222b4f11c796..893b85991f96c1509a9331e850e97a600229c2bd 100644 (file)
@@ -14,7 +14,6 @@ import com.google.common.util.concurrent.FluentFuture;
 import org.eclipse.jdt.annotation.NonNull;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
-import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
@@ -54,11 +53,6 @@ public class ReadWriteTx implements DOMDataReadWriteTransaction {
         delegateWriteTx.delete(store, path);
     }
 
-    @Override
-    public CheckedFuture<Void, TransactionCommitFailedException> submit() {
-        return delegateWriteTx.submit();
-    }
-
     @Override
     public @NonNull FluentFuture<? extends @NonNull CommitInfo> commit() {
         return delegateWriteTx.commit();
index 0fe89343e264625ebf8193459eea1fffc358ea61..f9d882ea9010341097b5d066a51d447e4cb14b54 100644 (file)
@@ -51,8 +51,8 @@ public class ReadWriteTxTest {
         verify(delegateWriteTx).merge(LogicalDatastoreType.CONFIGURATION, id2, leafNode);
         tx.delete(LogicalDatastoreType.CONFIGURATION, id2);
         verify(delegateWriteTx).delete(LogicalDatastoreType.CONFIGURATION, id2);
-        tx.submit();
-        verify(delegateWriteTx).submit();
+        tx.commit();
+        verify(delegateWriteTx).commit();
     }
 
     @Test