unregister request ctx from rpc stack when transmitPacket operation fails

Change-Id: If38c097ba19a2c2062f7ebac110f29a2a8e1a538
Signed-off-by: Martin Bobak <mbobak@cisco.com>

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/PacketProcessingServiceImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/PacketProcessingServiceImpl.java
index db78b0036456374a2a64e4bdc2376b4a1a8cde04..7c8c6df8c72c36423e2c591f3cd8433adf7e21e3 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/PacketProcessingServiceImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/PacketProcessingServiceImpl.java
@@ -51,6 +51,7 @@ public class PacketProcessingServiceImpl extends CommonService implements Packet
                 outboundQueue.commitEntry(xid.getValue(), message, new FutureCallback<OfHeader>() {
                     @Override
                     public void onSuccess(final OfHeader ofHeader) {
+                        RequestContextUtil.closeRequstContext(requestContext);
                         getMessageSpy().spyMessage(message.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS);
                         final RpcResultBuilder<Void> rpcResultBuilder = RpcResultBuilder.<Void>success();
                         settableFuture.set(rpcResultBuilder.build());
@@ -58,6 +59,7 @@ public class PacketProcessingServiceImpl extends CommonService implements Packet
 
                     @Override
                     public void onFailure(final Throwable throwable) {
+                        RequestContextUtil.closeRequstContext(requestContext);
                         getMessageSpy().spyMessage(message.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_FAILURE);
                         final RpcResultBuilder<Void> rpcResultBuilder = RpcResultBuilder.<Void>failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable);
                         settableFuture.set(rpcResultBuilder.build());