From 59dacb771f250867f0d85368bd8530749756dc70 Mon Sep 17 00:00:00 2001 From: Jozef Gloncak Date: Wed, 20 May 2015 15:28:02 +0200 Subject: [PATCH] Returning of future from request context - NodeConfigService. Change-Id: I8f9fd184428378e3039ac6d3ab5345f2456ccc9f Signed-off-by: Jozef Gloncak --- .../impl/services/NodeConfigServiceImpl.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/NodeConfigServiceImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/NodeConfigServiceImpl.java index 028f51d616..b04f5ed854 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/NodeConfigServiceImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/NodeConfigServiceImpl.java @@ -53,23 +53,27 @@ public class NodeConfigServiceImpl extends CommonService implements NodeConfigSe final SettableFuture> settableFuture = SettableFuture.create(); final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput setConfigInput = builder.build(); outboundQueue.commitEntry(xid.getValue(), setConfigInput, new FutureCallback() { + + RpcResultBuilder rpcResultBuilder; @Override public void onSuccess(final OfHeader ofHeader) { + rpcResultBuilder = RpcResultBuilder.success(); + requestContext.setResult(rpcResultBuilder.build()); RequestContextUtil.closeRequstContext(requestContext); - getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS); - settableFuture.set(RpcResultBuilder.success().build()); + getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS); } @Override public void onFailure(final Throwable throwable) { - RpcResultBuilder rpcResultBuilder = RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable); + rpcResultBuilder = RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable); + requestContext.setResult(rpcResultBuilder.build()); RequestContextUtil.closeRequstContext(requestContext); + getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_FAILURE); - settableFuture.set(rpcResultBuilder.build()); } }); - return settableFuture; + return requestContext.getFuture(); } } -- 2.36.6