/** * 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.rpc.RpcContext; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.AddGroupInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.AddGroupOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.RemoveGroupInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.RemoveGroupOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.UpdateGroupInput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.UpdateGroupOutput; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import java.util.concurrent.Future; /** * @author joe */ public class SalGroupServiceImpl extends CommonService implements SalGroupService { private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(SalGroupServiceImpl.class); @Override public Future> addGroup(final AddGroupInput input) { // LOG.debug("Calling the GroupMod RPC method on MessageDispatchService"); // // // use primary connection // final SwitchConnectionDistinguisher cookie = null; // // final OFRpcTask> task = OFRpcTaskFactory.createAddGroupTask( // rpcTaskContext, input, cookie); // final ListenableFuture> result = task.submit(); // // return Futures.transform(result, OFRpcFutureResultTransformFactory.createForAddGroupOutput()); return null; } @Override public Future> updateGroup(final UpdateGroupInput input) { // LOG.debug("Calling the update Group Mod RPC method on MessageDispatchService"); // // // use primary connection // final SwitchConnectionDistinguisher cookie = null; // // final OFRpcTask> task = // OFRpcTaskFactory.createUpdateGroupTask( // rpcTaskContext, input, cookie); // final ListenableFuture> result = task.submit(); // return null;// return result; } @Override public Future> removeGroup(final RemoveGroupInput input) { // LOG.debug("Calling the Remove Group RPC method on MessageDispatchService"); // // final SwitchConnectionDistinguisher cookie = null; // final OFRpcTask> task = // OFRpcTaskFactory.createRemoveGroupTask( // rpcTaskContext, input, cookie); // final ListenableFuture> result = task.submit(); // // return Futures.transform(result, OFRpcFutureResultTransformFactory.createForRemoveGroupOutput()); return null; } }