2 * Copyright (c) 2017 Pantheon Technologies s.r.o. 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
9 package org.opendaylight.openflowplugin.impl.services.singlelayer;
11 import com.google.common.util.concurrent.FutureCallback;
12 import com.google.common.util.concurrent.Futures;
13 import com.google.common.util.concurrent.SettableFuture;
14 import java.util.List;
15 import java.util.concurrent.Future;
16 import java.util.stream.Collectors;
17 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
18 import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
19 import org.opendaylight.openflowplugin.extension.api.core.extension.ExtensionConverterProvider;
20 import org.opendaylight.openflowplugin.impl.services.AbstractExperimenterMultipartService;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequestInput;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequestOutput;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequestOutputBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.send.experimenter.mp.request.output.ExperimenterCoreMessageItemBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.multipart.types.rev170112.MultipartReply;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.experimenter.types.rev151020.multipart.reply.multipart.reply.body.MultipartReplyExperimenter;
27 import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
28 import org.opendaylight.yangtools.yang.common.RpcResult;
29 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
30 import org.slf4j.Logger;
32 public class SingleLayerExperimenterMultipartService extends AbstractExperimenterMultipartService<MultipartReply> {
34 private static final Logger LOG = org.slf4j.LoggerFactory.getLogger(SingleLayerExperimenterMultipartService.class);
36 public SingleLayerExperimenterMultipartService(RequestContextStack requestContextStack, DeviceContext deviceContext,
37 ExtensionConverterProvider extensionConverterProvider) {
38 super(requestContextStack, deviceContext, extensionConverterProvider);
42 public Future<RpcResult<SendExperimenterMpRequestOutput>> handleAndReply(SendExperimenterMpRequestInput input) {
43 final SettableFuture<RpcResult<SendExperimenterMpRequestOutput>> future = SettableFuture.create();
45 Futures.addCallback(handleServiceCall(input), new FutureCallback<RpcResult<List<MultipartReply>>>() {
47 public void onSuccess(final RpcResult<List<MultipartReply>> result) {
48 if (result.isSuccessful()) {
49 future.set(RpcResultBuilder
50 .success(new SendExperimenterMpRequestOutputBuilder()
51 .setExperimenterCoreMessageItem(result
54 .map(MultipartReply::getMultipartReplyBody)
55 .filter(MultipartReplyExperimenter.class::isInstance)
56 .map(experimenter -> new ExperimenterCoreMessageItemBuilder()
57 .setExperimenterMessageOfChoice(MultipartReplyExperimenter.class
59 .getExperimenterMessageOfChoice())
61 .collect(Collectors.toList()))
65 LOG.warn("OnSuccess, rpc result unsuccessful, multipart response for rpc sendExperimenterMpRequest was unsuccessful.");
66 future.set(RpcResultBuilder.<SendExperimenterMpRequestOutput>failed().withRpcErrors(result.getErrors()).build());
71 public void onFailure(final Throwable t) {
72 LOG.warn("Failure multipart response for Experimenter-Mp request. Exception: {}", t);
73 future.set(RpcResultBuilder.<SendExperimenterMpRequestOutput>failed().withError(ErrorType.RPC, "Future error", t).build());