X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatabroker%2Factors%2Fdds%2FRemoteProxyTransaction.java;h=d14b7bda666790f7268875c4dead378d77e70b31;hp=e91bd6c8b031f935a08749272286ac565602d95c;hb=047566574ea74d1dfe24fa8075f8ba137faa698c;hpb=b8e58ad33db2a15162d548ba13f241409ffaadd9 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/RemoteProxyTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/RemoteProxyTransaction.java index e91bd6c8b0..d14b7bda66 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/RemoteProxyTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/RemoteProxyTransaction.java @@ -71,7 +71,6 @@ final class RemoteProxyTransaction extends AbstractProxyTransaction { private volatile Exception operationFailure; - RemoteProxyTransaction(final ProxyHistory parent, final TransactionIdentifier identifier, final boolean snapshotOnly, final boolean sendReadyOnSeal) { super(parent); @@ -303,7 +302,11 @@ final class RemoteProxyTransaction extends AbstractProxyTransaction { switch (maybeProto.get()) { case ABORT: - sendAbort(callback); + ensureInitializedBuilder(); + builder.setAbort(); + final ModifyTransactionRequest newReq = builder.build(); + builderBusy = false; + sendRequest(newReq, callback); break; case SIMPLE: sendRequest(commitRequest(false), callback);