*/
package org.opendaylight.openflowplugin.impl.services;
-import com.google.common.util.concurrent.JdkFutureAdapters;
-import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.SettableFuture;
+import java.util.concurrent.Future;
+import org.opendaylight.openflowjava.protocol.api.connection.OutboundQueue;
+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.api.openflow.statistics.ofpspecific.MessageSpy;
import org.opendaylight.yang.gen.v1.urn.opendaylight.module.config.rev141015.NodeConfigService;
import org.opendaylight.yang.gen.v1.urn.opendaylight.module.config.rev141015.SetConfigInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.module.config.rev141015.SetConfigOutput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.SwitchConfigFlag;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInputBuilder;
+import org.opendaylight.yangtools.yang.common.RpcError;
import org.opendaylight.yangtools.yang.common.RpcResult;
-import java.util.concurrent.Future;
+import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
-/**
- * @author joe
- */
public class NodeConfigServiceImpl extends CommonService implements NodeConfigService {
+ public NodeConfigServiceImpl(final RequestContextStack requestContextStack, final DeviceContext deviceContext) {
+ super(requestContextStack, deviceContext);
+ }
+
@Override
public Future<RpcResult<SetConfigOutput>> setConfig(final SetConfigInput input) {
- final RequestContext requestContext = rpcContext.createRequestContext();
- final SettableFuture<RpcResult<SetConfigOutput>> result = rpcContext.storeOrFail(requestContext);
- if (!result.isDone()) {
- SetConfigInputBuilder builder = new SetConfigInputBuilder();
- SwitchConfigFlag flag = SwitchConfigFlag.valueOf(input.getFlag());
- final Xid xid = deviceContext.getNextXid();
- builder.setXid(xid.getValue());
- builder.setFlags(flag);
- builder.setMissSendLen(input.getMissSearchLength());
- builder.setVersion(version);
- ListenableFuture<RpcResult<Void>> futureResultFromOfLib = JdkFutureAdapters.listenInPoolThread(deviceContext.getPrimaryConnectionContext().getConnectionAdapter().setConfig(builder.build()));
- RpcResultConvertor<SetConfigOutput> rpcResultConvertor = new RpcResultConvertor<>(requestContext, deviceContext);
- rpcResultConvertor.processResultFromOfJava(futureResultFromOfLib);
- } else {
- RequestContextUtil.closeRequstContext(requestContext);
+ final RequestContext<SetConfigOutput> requestContext = createRequestContext();
+ if (requestContext == null) {
+ return failedFuture();
}
- return result;
+
+ SetConfigInputBuilder builder = new SetConfigInputBuilder();
+ SwitchConfigFlag flag = SwitchConfigFlag.valueOf(input.getFlag());
+
+ final Xid xid = requestContext.getXid();
+ builder.setXid(xid.getValue());
+ builder.setFlags(flag);
+ builder.setMissSendLen(input.getMissSearchLength());
+ builder.setVersion(getVersion());
+ final OutboundQueue outboundQueue = getDeviceContext().getPrimaryConnectionContext().getOutboundQueueProvider();
+
+ final SettableFuture<RpcResult<SetConfigOutput>> settableFuture = SettableFuture.create();
+ final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput setConfigInput = builder.build();
+ outboundQueue.commitEntry(xid.getValue(), setConfigInput, new FutureCallback<OfHeader>() {
+
+ RpcResultBuilder<SetConfigOutput> rpcResultBuilder;
+ @Override
+ public void onSuccess(final OfHeader ofHeader) {
+ rpcResultBuilder = RpcResultBuilder.<SetConfigOutput>success();
+ requestContext.setResult(rpcResultBuilder.build());
+ RequestContextUtil.closeRequstContext(requestContext);
+
+ getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS);
+ }
+
+ @Override
+ public void onFailure(final Throwable throwable) {
+ rpcResultBuilder = RpcResultBuilder.<SetConfigOutput>failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable);
+ requestContext.setResult(rpcResultBuilder.build());
+ RequestContextUtil.closeRequstContext(requestContext);
+
+ getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_FAILURE);
+ }
+ });
+ return requestContext.getFuture();
+
}
}