/** * 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.statistics.services; import com.google.common.base.Function; import com.google.common.util.concurrent.JdkFutureAdapters; import com.google.common.util.concurrent.ListenableFuture; import org.opendaylight.openflowplugin.api.OFConstants; 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.device.Xid; import org.opendaylight.openflowplugin.impl.services.CommonService; import org.opendaylight.openflowplugin.impl.services.DataCrate; import org.opendaylight.openflowplugin.impl.services.RequestInputUtils; import org.opendaylight.openflowplugin.impl.services.RpcResultConvertor; import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.match.MatchReactor; import org.opendaylight.openflowplugin.openflow.md.util.FlowCreatorUtil; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAggregateFlowStatisticsFromFlowTableForAllFlowsInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAggregateFlowStatisticsFromFlowTableForAllFlowsOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAggregateFlowStatisticsFromFlowTableForGivenMatchInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAggregateFlowStatisticsFromFlowTableForGivenMatchOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAllFlowStatisticsFromFlowTableInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAllFlowStatisticsFromFlowTableOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAllFlowsStatisticsFromAllFlowTablesInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetAllFlowsStatisticsFromAllFlowTablesOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetFlowStatisticsFromFlowTableInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.GetFlowStatisticsFromFlowTableOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCaseBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlowCaseBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.aggregate._case.MultipartRequestAggregateBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.flow._case.MultipartRequestFlowBuilder; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.Future; /** * @author joe */ public class OpendaylightFlowStatisticsServiceImpl extends CommonService implements OpendaylightFlowStatisticsService { private static final Logger LOG = LoggerFactory.getLogger(OpendaylightFlowStatisticsServiceImpl.class); public OpendaylightFlowStatisticsServiceImpl(final RequestContextStack requestContextStack, DeviceContext deviceContext) { super(requestContextStack, deviceContext); } @Override public Future> getAggregateFlowStatisticsFromFlowTableForAllFlows( final GetAggregateFlowStatisticsFromFlowTableForAllFlowsInput input) { return this.handleServiceCall( PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { // Create multipart request body for fetch all the group stats final MultipartRequestAggregateCaseBuilder multipartRequestAggregateCaseBuilder = new MultipartRequestAggregateCaseBuilder(); final MultipartRequestAggregateBuilder mprAggregateRequestBuilder = new MultipartRequestAggregateBuilder(); mprAggregateRequestBuilder.setTableId(input.getTableId().getValue()); mprAggregateRequestBuilder.setOutPort(OFConstants.OFPP_ANY); mprAggregateRequestBuilder.setOutGroup(OFConstants.OFPG_ANY); mprAggregateRequestBuilder.setCookie(OFConstants.DEFAULT_COOKIE); mprAggregateRequestBuilder.setCookieMask(OFConstants.DEFAULT_COOKIE_MASK); FlowCreatorUtil.setWildcardedFlowMatch(version, mprAggregateRequestBuilder); // Set request body to main multipart request multipartRequestAggregateCaseBuilder.setMultipartRequestAggregate(mprAggregateRequestBuilder .build()); final Xid xid = deviceContext.getNextXid(); data.getRequestContext().setXid(xid); final MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader( MultipartType.OFPMPAGGREGATE, xid.getValue(), version); mprInput.setMultipartRequestBody(multipartRequestAggregateCaseBuilder.build()); final Future> resultFromOFLib = deviceContext.getPrimaryConnectionContext() .getConnectionAdapter().multipartRequest(mprInput.build()); return JdkFutureAdapters.listenInPoolThread(resultFromOFLib); } }); } @Override public Future> getAggregateFlowStatisticsFromFlowTableForGivenMatch( final GetAggregateFlowStatisticsFromFlowTableForGivenMatchInput input) { return this.handleServiceCall( PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { final MultipartRequestAggregateCaseBuilder multipartRequestAggregateCaseBuilder = new MultipartRequestAggregateCaseBuilder(); final MultipartRequestAggregateBuilder mprAggregateRequestBuilder = new MultipartRequestAggregateBuilder(); mprAggregateRequestBuilder.setTableId(input.getTableId()); mprAggregateRequestBuilder.setOutPort(input.getOutPort().longValue()); // TODO: repeating code if (version == OFConstants.OFP_VERSION_1_3) { mprAggregateRequestBuilder.setCookie(input.getCookie().getValue()); mprAggregateRequestBuilder.setCookieMask(input.getCookieMask().getValue()); mprAggregateRequestBuilder.setOutGroup(input.getOutGroup()); } else { mprAggregateRequestBuilder.setOutGroup(OFConstants.OFPG_ANY); mprAggregateRequestBuilder.setCookie(OFConstants.DEFAULT_COOKIE); mprAggregateRequestBuilder.setCookieMask(OFConstants.DEFAULT_COOKIE_MASK); } MatchReactor.getInstance().convert(input.getMatch(), version, mprAggregateRequestBuilder, deviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId()); FlowCreatorUtil.setWildcardedFlowMatch(version, mprAggregateRequestBuilder); // Set request body to main multipart request multipartRequestAggregateCaseBuilder.setMultipartRequestAggregate(mprAggregateRequestBuilder .build()); final Xid xid = deviceContext.getNextXid(); data.getRequestContext().setXid(xid); final MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader( MultipartType.OFPMPAGGREGATE, xid.getValue(), version); mprInput.setMultipartRequestBody(multipartRequestAggregateCaseBuilder.build()); final Future> resultFromOFLib = deviceContext.getPrimaryConnectionContext() .getConnectionAdapter().multipartRequest(mprInput.build()); return JdkFutureAdapters.listenInPoolThread(resultFromOFLib); } }); } @Override public Future> getAllFlowStatisticsFromFlowTable( final GetAllFlowStatisticsFromFlowTableInput input) { return this.handleServiceCall(PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { final MultipartRequestFlowBuilder mprFlowRequestBuilder = new MultipartRequestFlowBuilder(); mprFlowRequestBuilder.setTableId(input.getTableId().getValue()); mprFlowRequestBuilder.setOutPort(OFConstants.OFPP_ANY); mprFlowRequestBuilder.setOutGroup(OFConstants.OFPG_ANY); mprFlowRequestBuilder.setCookie(OFConstants.DEFAULT_COOKIE); mprFlowRequestBuilder.setCookieMask(OFConstants.DEFAULT_COOKIE_MASK); FlowCreatorUtil.setWildcardedFlowMatch(version, mprFlowRequestBuilder); final MultipartRequestFlowCaseBuilder multipartRequestFlowCaseBuilder = new MultipartRequestFlowCaseBuilder(); multipartRequestFlowCaseBuilder.setMultipartRequestFlow(mprFlowRequestBuilder.build()); final Xid xid = deviceContext.getNextXid(); data.getRequestContext().setXid(xid); final MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader( MultipartType.OFPMPFLOW, xid.getValue(), version); mprInput.setMultipartRequestBody(multipartRequestFlowCaseBuilder.build()); final Future> resultFromOFLib = deviceContext.getPrimaryConnectionContext() .getConnectionAdapter().multipartRequest(mprInput.build()); return JdkFutureAdapters.listenInPoolThread(resultFromOFLib); } }); } @Override public Future> getAllFlowsStatisticsFromAllFlowTables( final GetAllFlowsStatisticsFromAllFlowTablesInput input) { return this.handleServiceCall(PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { final MultipartRequestFlowCaseBuilder multipartRequestFlowCaseBuilder = new MultipartRequestFlowCaseBuilder(); final MultipartRequestFlowBuilder mprFlowRequestBuilder = new MultipartRequestFlowBuilder(); mprFlowRequestBuilder.setTableId(OFConstants.OFPTT_ALL); mprFlowRequestBuilder.setOutPort(OFConstants.OFPP_ANY); mprFlowRequestBuilder.setOutGroup(OFConstants.OFPG_ANY); mprFlowRequestBuilder.setCookie(OFConstants.DEFAULT_COOKIE); mprFlowRequestBuilder.setCookieMask(OFConstants.DEFAULT_COOKIE_MASK); FlowCreatorUtil.setWildcardedFlowMatch(version, mprFlowRequestBuilder); final Xid xid = deviceContext.getNextXid(); data.getRequestContext().setXid(xid); final MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader( MultipartType.OFPMPFLOW, xid.getValue(), version); multipartRequestFlowCaseBuilder.setMultipartRequestFlow(mprFlowRequestBuilder.build()); mprInput.setMultipartRequestBody(multipartRequestFlowCaseBuilder.build()); final Future> resultFromOFLib = deviceContext.getPrimaryConnectionContext() .getConnectionAdapter().multipartRequest(mprInput.build()); return JdkFutureAdapters.listenInPoolThread(resultFromOFLib); } }); } @Override public Future> getFlowStatisticsFromFlowTable( final GetFlowStatisticsFromFlowTableInput input) { return this.handleServiceCall(PRIMARY_CONNECTION, new Function, Future>>() { @Override public Future> apply(final DataCrate data) { final MultipartRequestFlowCaseBuilder multipartRequestFlowCaseBuilder = new MultipartRequestFlowCaseBuilder(); final MultipartRequestFlowBuilder mprFlowRequestBuilder = new MultipartRequestFlowBuilder(); mprFlowRequestBuilder.setTableId(input.getTableId()); if (input.getOutPort() != null) { mprFlowRequestBuilder.setOutPort(input.getOutPort().longValue()); } else { mprFlowRequestBuilder.setOutPort(OFConstants.OFPP_ANY); } if (input.getOutGroup() != null) { mprFlowRequestBuilder.setOutGroup(input.getOutGroup()); } else { mprFlowRequestBuilder.setOutGroup(OFConstants.OFPG_ANY); } if (input.getCookie() != null) { mprFlowRequestBuilder.setCookie(input.getCookie().getValue()); } else { mprFlowRequestBuilder.setCookie(OFConstants.DEFAULT_COOKIE); } if (input.getCookieMask() != null) { mprFlowRequestBuilder.setCookieMask(input.getCookieMask().getValue()); } else { mprFlowRequestBuilder.setCookieMask(OFConstants.DEFAULT_COOKIE_MASK); } // convert and inject match MatchReactor.getInstance().convert(input.getMatch(), version, mprFlowRequestBuilder, deviceContext.getPrimaryConnectionContext().getFeatures().getDatapathId()); // Set request body to main multipart request multipartRequestFlowCaseBuilder.setMultipartRequestFlow(mprFlowRequestBuilder.build()); final Xid xid = deviceContext.getNextXid(); data.getRequestContext().setXid(xid); final MultipartRequestInputBuilder mprInput = RequestInputUtils.createMultipartHeader( MultipartType.OFPMPFLOW, xid.getValue(), version); mprInput.setMultipartRequestBody(multipartRequestFlowCaseBuilder.build()); final Future> resultFromOFLib = deviceContext.getPrimaryConnectionContext() .getConnectionAdapter().multipartRequest(mprInput.build()); return JdkFutureAdapters.listenInPoolThread(resultFromOFLib); } }); } private void convertRpcResultToRequestFuture(final RequestContext requestContext, final ListenableFuture> futureResultFromOfLib) { final RpcResultConvertor rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext); rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib); } }