/** * 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 org.opendaylight.openflowplugin.api.openflow.device.DeviceContext; import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack; import org.opendaylight.openflowplugin.api.openflow.device.Xid; import org.opendaylight.yangtools.yang.common.RpcError.ErrorType; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.SettableFuture; import org.opendaylight.openflowplugin.api.openflow.device.RequestContext; import com.google.common.base.Function; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.JdkFutureAdapters; import com.google.common.util.concurrent.ListenableFuture; import java.math.BigInteger; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Future; import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.FlowConvertor; import org.opendaylight.openflowplugin.openflow.md.util.FlowCreatorUtil; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.AddFlowInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.AddFlowInputBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.AddFlowOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.RemoveFlowInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.RemoveFlowInputBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.RemoveFlowOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.UpdateFlowInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.UpdateFlowOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.flow.update.OriginalFlow; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.flow.update.UpdatedFlow; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInputBuilder; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; public class SalFlowServiceImpl extends CommonService implements SalFlowService { private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(SalFlowServiceImpl.class); public SalFlowServiceImpl(final RequestContextStack requestContextStack, final DeviceContext deviceContext) { super(requestContextStack, deviceContext); } ListenableFuture> handleServiceCall(final BigInteger connectionID, final FlowModInputBuilder flowModInputBuilder, final Function, Future>> function) { LOG.debug("Calling the FlowMod RPC method on MessageDispatchService"); final RequestContext requestContext = requestContextStack.createRequestContext(); final SettableFuture> result = requestContextStack.storeOrFail(requestContext); final DataCrate dataCrate = DataCrateBuilder. builder().setiDConnection(connectionID) .setRequestContext(requestContext).setFlowModInputBuilder(flowModInputBuilder).build(); if (!result.isDone()) { final Future> resultFromOFLib = function.apply(dataCrate); final RpcResultConvertor rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext); rpcResultConvertor.processResultFromOfJava(resultFromOFLib); } else { RequestContextUtil.closeRequstContext(requestContext); } return result; } @Override public Future> addFlow(final AddFlowInput input) { final List ofFlowModInputs = FlowConvertor.toFlowModInputs(input, version, datapathId); return processFlowModInputBuilders(ofFlowModInputs); } @Override public Future> removeFlow(final RemoveFlowInput input) { return this. handleServiceCall(PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { final FlowModInputBuilder ofFlowModInput = FlowConvertor.toFlowModInput(input, version, datapathId); return createResultForFlowMod(data, ofFlowModInput); } }); } @Override public Future> updateFlow(final UpdateFlowInput input) { final UpdateFlowInput in = input; final UpdatedFlow updated = in.getUpdatedFlow(); final OriginalFlow original = in.getOriginalFlow(); final List allFlowMods = new ArrayList<>(); List ofFlowModInputs; if (!FlowCreatorUtil.canModifyFlow(original, updated, version)) { // We would need to remove original and add updated. // remove flow final RemoveFlowInputBuilder removeflow = new RemoveFlowInputBuilder(original); final List ofFlowRemoveInput = FlowConvertor.toFlowModInputs(removeflow.build(), version, datapathId); // remove flow should be the first allFlowMods.addAll(ofFlowRemoveInput); final AddFlowInputBuilder addFlowInputBuilder = new AddFlowInputBuilder(updated); ofFlowModInputs = FlowConvertor.toFlowModInputs(addFlowInputBuilder.build(), version, datapathId); } else { ofFlowModInputs = FlowConvertor.toFlowModInputs(updated, version, datapathId); } allFlowMods.addAll(ofFlowModInputs); return processFlowModInputBuilders(allFlowMods); } private Future> processFlowModInputBuilders( final List ofFlowModInputs) { final List>> partialFutures = new ArrayList<>(); for (FlowModInputBuilder flowModInputBuilder : ofFlowModInputs) { ListenableFuture> partialFuture = handleServiceCall(PRIMARY_CONNECTION, flowModInputBuilder, new Function, Future>>() { @Override public ListenableFuture> apply(final DataCrate data) { return createResultForFlowMod(data); } }); partialFutures.add(partialFuture); } ListenableFuture>> allFutures = Futures.allAsList(partialFutures); final SettableFuture> finalFuture = SettableFuture.create(); Futures.addCallback(allFutures, new FutureCallback>>() { @Override public void onSuccess(List> result) { for (RpcResult rpcResult : result) { if (rpcResult.isSuccessful()) { // TODO: AddFlowOutput has getTransactionId() - shouldn't it have some value? finalFuture.set(RpcResultBuilder. success().build()); } } } @Override public void onFailure(Throwable t) { finalFuture.set(RpcResultBuilder. failed().withError(ErrorType.APPLICATION, "", t.getMessage()) .build()); } }); return finalFuture; } protected ListenableFuture> createResultForFlowMod(final DataCrate data) { return createResultForFlowMod(data, data.getFlowModInputBuilder()) ; } protected ListenableFuture> createResultForFlowMod(final DataCrate data, final FlowModInputBuilder flowModInput) { final Xid xId = deviceContext.getNextXid(); flowModInput.setXid(xId.getValue()); data.getRequestContext().setXid(xId); Future> flowModResult = provideConnectionAdapter(data.getiDConnection()).flowMod( flowModInput.build()); return JdkFutureAdapters.listenInPoolThread(flowModResult); } }