2 * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.openflowplugin.impl.services;
11 import com.google.common.util.concurrent.FutureCallback;
12 import com.google.common.util.concurrent.Futures;
13 import com.google.common.util.concurrent.ListenableFuture;
14 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
15 import org.opendaylight.openflowplugin.api.openflow.device.RequestContext;
16 import org.opendaylight.openflowplugin.api.openflow.statistics.ofpspecific.MessageSpy;
17 import org.opendaylight.yangtools.yang.common.RpcError;
18 import org.opendaylight.yangtools.yang.common.RpcResult;
19 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
20 import org.slf4j.Logger;
21 import org.slf4j.LoggerFactory;
24 * Created by Martin Bobak <mbobak@cisco.com> on 26.3.2015.
26 public class OFJResult2RequestCtxFuture<T> {
28 private static final Logger LOG = LoggerFactory.getLogger(OFJResult2RequestCtxFuture.class);
29 private final RequestContext<T> requestContext;
30 private final DeviceContext deviceContext;
32 public OFJResult2RequestCtxFuture(final RequestContext<T> requestContext, final DeviceContext deviceContext) {
33 this.requestContext = requestContext;
34 this.deviceContext = deviceContext;
37 public <F> void processResultFromOfJava(final ListenableFuture<RpcResult<F>> futureResultFromOfLib) {
38 Futures.addCallback(futureResultFromOfLib, new FutureCallback<RpcResult<F>>() {
40 public void onSuccess(final RpcResult<F> fRpcResult) {
41 if (!fRpcResult.isSuccessful()) {
42 deviceContext.getMessageSpy().spyMessage(requestContext, MessageSpy.STATISTIC_GROUP.FROM_SWITCH_PUBLISHED_FAILURE);
44 // remove current request from request cache in deviceContext
45 deviceContext.unhookRequestCtx(requestContext.getXid());
46 // handle requestContext failure
47 StringBuilder rpcErrors = new StringBuilder();
48 if (null != fRpcResult.getErrors() && fRpcResult.getErrors().size() > 0) {
49 for (RpcError error : fRpcResult.getErrors()) {
50 rpcErrors.append(error.getMessage());
53 LOG.trace("OF Java result for XID {} was not successful. Errors : {}", requestContext.getXid().getValue(), rpcErrors.toString());
54 requestContext.getFuture().set(
55 RpcResultBuilder.<T>failed().withRpcErrors(fRpcResult.getErrors()).build());
56 RequestContextUtil.closeRequstContext(requestContext);
61 public void onFailure(final Throwable throwable) {
62 if (futureResultFromOfLib.isCancelled()) {
63 deviceContext.getMessageSpy().spyMessage(requestContext, MessageSpy.STATISTIC_GROUP.FROM_SWITCH_PUBLISHED_SUCCESS);
65 LOG.trace("Asymmetric message - no response from OF Java expected for XID {}. Closing as successful.", requestContext.getXid().getValue());
66 requestContext.getFuture().set(RpcResultBuilder.<T>success().build());
68 deviceContext.getMessageSpy().spyMessage(requestContext, MessageSpy.STATISTIC_GROUP.FROM_SWITCH_PUBLISHED_FAILURE);
69 LOG.trace("Exception occured while processing OF Java response for XID {}.", requestContext.getXid().getValue(), throwable);
70 requestContext.getFuture().set(
71 RpcResultBuilder.<T>failed()
72 .withError(RpcError.ErrorType.APPLICATION, "", "Flow translation to OF JAVA failed.")
76 RequestContextUtil.closeRequstContext(requestContext);