2 * Copyright (c) 2013 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
8 package org.opendaylight.openflowplugin.openflow.md.core.sal;
10 import java.util.Collection;
12 import org.opendaylight.controller.sal.common.util.Rpcs;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.AddFlowOutput;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.AddFlowOutputBuilder;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.UpdateFlowOutput;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.AddGroupOutput;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.AddGroupOutputBuilder;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.UpdateGroupOutput;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.AddMeterOutput;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.AddMeterOutputBuilder;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.UpdateMeterOutput;
22 import org.opendaylight.yangtools.yang.common.RpcError;
23 import org.opendaylight.yangtools.yang.common.RpcResult;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 import com.google.common.base.Function;
30 * collection of transformation functions dedicated to rpc future results
32 public abstract class OFRpcFutureResultTransformFactory {
34 protected static Logger LOG = LoggerFactory
35 .getLogger(OFRpcFutureResultTransformFactory.class);
42 protected static <E> RpcResult<E> assembleRpcResult(RpcResult<?> input, E result) {
43 Collection<RpcError> errors = input.getErrors();
44 RpcResult<E> rpcResult = Rpcs.getRpcResult(input.isSuccessful(), result, errors);
49 * @return translator from {@link UpdateFlowOutput} to {@link AddFlowOutput}
51 public static Function<RpcResult<UpdateFlowOutput>,RpcResult<AddFlowOutput>> createForAddFlowOutput() {
52 return new Function<RpcResult<UpdateFlowOutput>,RpcResult<AddFlowOutput>>() {
55 public RpcResult<AddFlowOutput> apply(RpcResult<UpdateFlowOutput> input) {
57 UpdateFlowOutput updateFlowOutput = input.getResult();
59 AddFlowOutputBuilder addFlowOutput = new AddFlowOutputBuilder();
60 addFlowOutput.setTransactionId(updateFlowOutput.getTransactionId());
61 AddFlowOutput result = addFlowOutput.build();
63 RpcResult<AddFlowOutput> rpcResult = assembleRpcResult(input, result);
64 LOG.debug("Returning the Add Flow RPC result to MD-SAL");
72 * @return translator from {@link UpdateGroupOutput} to {@link AddGroupOutput}
74 public static Function<RpcResult<UpdateGroupOutput>, RpcResult<AddGroupOutput>> createForAddGroupOutput() {
75 return new Function<RpcResult<UpdateGroupOutput>,RpcResult<AddGroupOutput>>() {
78 public RpcResult<AddGroupOutput> apply(RpcResult<UpdateGroupOutput> input) {
79 UpdateGroupOutput updateGroupOutput = input.getResult();
81 AddGroupOutputBuilder addGroupOutput = new AddGroupOutputBuilder();
82 addGroupOutput.setTransactionId(updateGroupOutput.getTransactionId());
83 AddGroupOutput result = addGroupOutput.build();
85 RpcResult<AddGroupOutput> rpcResult = assembleRpcResult(input, result);
86 LOG.debug("Returning the Add Group RPC result to MD-SAL");
93 * @return translator from {@link UpdateGroupOutput} to {@link AddGroupOutput}
95 public static Function<RpcResult<UpdateMeterOutput>, RpcResult<AddMeterOutput>> createForAddMeterOutput() {
96 return new Function<RpcResult<UpdateMeterOutput>,RpcResult<AddMeterOutput>>() {
99 public RpcResult<AddMeterOutput> apply(final RpcResult<UpdateMeterOutput> input) {
100 UpdateMeterOutput updateMeterOutput = input.getResult();
102 AddMeterOutputBuilder addMeterOutput = new AddMeterOutputBuilder();
103 addMeterOutput.setTransactionId(updateMeterOutput.getTransactionId());
104 AddMeterOutput result = addMeterOutput.build();
106 RpcResult<AddMeterOutput> rpcResult = assembleRpcResult(input, result);
107 LOG.debug("Returning the Add Meter RPC result to MD-SAL");