/** * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.openflowplugin.impl.services; import com.google.common.base.Function; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.SettableFuture; import java.math.BigInteger; import java.util.concurrent.Future; import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter; import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext; import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext; import org.opendaylight.openflowplugin.api.openflow.device.RequestContext; import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack; import org.opendaylight.openflowplugin.api.openflow.statistics.ofpspecific.MessageSpy; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FeaturesReply; import org.opendaylight.yangtools.yang.common.RpcError.ErrorType; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import org.slf4j.Logger; public abstract class CommonService { private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(CommonService.class); private static final long WAIT_TIME = 2000; protected final static Future> ERROR_RPC_RESULT = Futures.immediateFuture(RpcResultBuilder .failed().withError(ErrorType.APPLICATION, "", "Request quota exceeded.").build()); protected static final BigInteger PRIMARY_CONNECTION = new BigInteger("0"); // protected OFRpcTaskContext rpcTaskContext; public short version; public BigInteger datapathId; protected RequestContextStack requestContextStack; protected DeviceContext deviceContext; public ConnectionAdapter primaryConnectionAdapter; public MessageSpy messageSpy; /** * @deprecated use {@link #CommonService(RequestContextStack, DeviceContext)} */ @Deprecated public CommonService() { } public CommonService(final RequestContextStack requestContextStack, DeviceContext deviceContext) { this.requestContextStack = requestContextStack; this.deviceContext = deviceContext; final FeaturesReply features = this.deviceContext.getPrimaryConnectionContext().getFeatures(); this.datapathId = features.getDatapathId(); this.version = features.getVersion(); this.primaryConnectionAdapter = deviceContext.getPrimaryConnectionContext().getConnectionAdapter(); this.messageSpy = deviceContext.getMessageSpy(); } protected long provideWaitTime() { return WAIT_TIME; } protected ConnectionAdapter provideConnectionAdapter(final BigInteger connectionID) { if (connectionID == null) { return primaryConnectionAdapter; } if (connectionID.equals(PRIMARY_CONNECTION)) { return primaryConnectionAdapter; } final ConnectionContext auxiliaryConnectionContext = deviceContext.getAuxiliaryConnectiobContexts(connectionID); if (auxiliaryConnectionContext != null) { return auxiliaryConnectionContext.getConnectionAdapter(); } return primaryConnectionAdapter; } /** * @param connectionID connection identifier * @param function data sender * @param rpc result backend type * @param final rpc backend type * @return */ public ListenableFuture> handleServiceCall(final BigInteger connectionID, final Function, ListenableFuture>> function) { DataCrateBuilder dataCrateBuilder = DataCrateBuilder.builder(); return handleServiceCall(connectionID, function, dataCrateBuilder); } /** * @param * @param * @param connectionID * @param function * @param dataCrateBuilder predefined data * @return */ public final ListenableFuture> handleServiceCall(final BigInteger connectionID, final Function, ListenableFuture>> function, final DataCrateBuilder dataCrateBuilder) { synchronized (deviceContext) { LOG.debug("Handling general service call"); final RequestContext requestContext = requestContextStack.createRequestContext(); final SettableFuture> result = requestContextStack.storeOrFail(requestContext); if (!result.isDone()) { DataCrate dataCrate = dataCrateBuilder.setiDConnection(connectionID).setRequestContext(requestContext) .build(); requestContext.setXid(deviceContext.getNextXid()); LOG.trace("Hooking xid {} to device context - precaution.", requestContext.getXid().getValue()); deviceContext.hookRequestCtx(requestContext.getXid(), requestContext); final ListenableFuture> resultFromOFLib = function.apply(dataCrate); final OFJResult2RequestCtxFuture OFJResult2RequestCtxFuture = new OFJResult2RequestCtxFuture<>(requestContext, deviceContext); OFJResult2RequestCtxFuture.processResultFromOfJava(resultFromOFLib); } else { messageSpy.spyMessage(requestContext, MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMITTED_FAILURE); } return result; } } }