From 86c087af1404867f322cc2ed37a8212f372a7fc7 Mon Sep 17 00:00:00 2001 From: Jakub Morvay Date: Wed, 1 Mar 2017 13:29:50 +0100 Subject: [PATCH] BUG-5280: handle TransactionPurgeRequest replay Handle TransactionPurgeRequest in RemoteProxyTransaction Change-Id: Icf467361b949e02ba5c02d8e8630dbff7519d330 Signed-off-by: Jakub Morvay --- .../cluster/databroker/actors/dds/RemoteProxyTransaction.java | 3 +++ 1 file changed, 3 insertions(+) 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 e777156b3e..b8afb0e90d 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 @@ -29,6 +29,7 @@ import org.opendaylight.controller.cluster.access.commands.TransactionDoCommitRe import org.opendaylight.controller.cluster.access.commands.TransactionMerge; import org.opendaylight.controller.cluster.access.commands.TransactionModification; import org.opendaylight.controller.cluster.access.commands.TransactionPreCommitRequest; +import org.opendaylight.controller.cluster.access.commands.TransactionPurgeRequest; import org.opendaylight.controller.cluster.access.commands.TransactionRequest; import org.opendaylight.controller.cluster.access.commands.TransactionSuccess; import org.opendaylight.controller.cluster.access.commands.TransactionWrite; @@ -331,6 +332,8 @@ final class RemoteProxyTransaction extends AbstractProxyTransaction { } else if (request instanceof TransactionAbortRequest) { ensureFlushedBuider(); sendAbort(callback); + } else if (request instanceof TransactionPurgeRequest) { + purge(); } else { throw new IllegalArgumentException("Unhandled request {}" + request); } -- 2.36.6