2 * Copyright (c) 2017, 2018 Ericsson India Global Services Pvt Ltd. 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.genius.interfacemanager.servicebindings.flowbased.listeners;
10 import com.google.common.util.concurrent.ListenableFuture;
11 import java.util.ArrayList;
12 import java.util.List;
13 import java.util.concurrent.Callable;
14 import javax.inject.Inject;
15 import javax.inject.Singleton;
16 import org.apache.aries.blueprint.annotation.service.Reference;
17 import org.eclipse.jdt.annotation.NonNull;
18 import org.opendaylight.genius.interfacemanager.servicebindings.flowbased.state.factory.FlowBasedServicesStateAddable;
19 import org.opendaylight.genius.interfacemanager.servicebindings.flowbased.state.factory.FlowBasedServicesStateRendererFactoryResolver;
20 import org.opendaylight.genius.interfacemanager.servicebindings.flowbased.utilities.FlowBasedServicesUtils;
21 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
22 import org.opendaylight.mdsal.binding.api.DataBroker;
23 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
24 import org.opendaylight.serviceutils.tools.listener.AbstractSyncDataTreeChangeListener;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceModeBase;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
29 import org.opendaylight.yangtools.yang.common.Uint64;
30 import org.slf4j.Logger;
31 import org.slf4j.LoggerFactory;
34 public class FlowBasedServicesNodeStateListener extends AbstractSyncDataTreeChangeListener<Node> {
36 private static final Logger LOG = LoggerFactory.getLogger(FlowBasedServicesNodeStateListener.class);
38 private final JobCoordinator jobCoordinator;
39 private final FlowBasedServicesStateRendererFactoryResolver flowBasedServicesStateRendererFactoryResolver;
42 public FlowBasedServicesNodeStateListener(@Reference final DataBroker dataBroker,
43 @Reference final JobCoordinator jobCoordinator,
44 final FlowBasedServicesStateRendererFactoryResolver
45 flowBasedServicesStateRendererFactoryResolver) {
46 super(dataBroker, LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(Nodes.class).child(Node.class));
47 this.jobCoordinator = jobCoordinator;
48 this.flowBasedServicesStateRendererFactoryResolver = flowBasedServicesStateRendererFactoryResolver;
52 public void remove(@NonNull InstanceIdentifier<Node> instanceIdentifier, @NonNull Node node) {
57 public void update(@NonNull InstanceIdentifier<Node> instanceIdentifier, @NonNull Node originalNode,
58 @NonNull final Node updatedNode) {
63 public void add(@NonNull InstanceIdentifier<Node> instanceIdentifier, @NonNull Node node) {
64 final Uint64 dpId = getDpnID(node);
68 bindServicesOnTunnelType(dpId);
71 private void bindServicesOnTunnelType(final Uint64 dpId) {
72 LOG.debug("Received node add event for {}", dpId);
73 for (final Class<?extends ServiceModeBase> serviceMode : FlowBasedServicesUtils.SERVICE_MODE_MAP.values()) {
74 for (final String interfaceName : FlowBasedServicesUtils.INTERFACE_TYPE_BASED_SERVICE_BINDING_KEYWORDS) {
75 final FlowBasedServicesStateAddable flowBasedServicesStateAddable =
76 flowBasedServicesStateRendererFactoryResolver
77 .getFlowBasedServicesStateRendererFactory(serviceMode).getFlowBasedServicesStateAddRenderer();
78 jobCoordinator.enqueueJob(interfaceName,
79 new RendererStateInterfaceBindWorker(flowBasedServicesStateAddable, dpId,
85 private static class RendererStateInterfaceBindWorker implements Callable<List<? extends ListenableFuture<?>>> {
86 private final String iface;
88 final FlowBasedServicesStateAddable flowBasedServicesStateAddable;
90 RendererStateInterfaceBindWorker(final FlowBasedServicesStateAddable flowBasedServicesStateAddable,
93 this.flowBasedServicesStateAddable = flowBasedServicesStateAddable;
99 public List<ListenableFuture<Void>> call() {
100 final List<ListenableFuture<Void>> futures = new ArrayList<>();
101 flowBasedServicesStateAddable.bindServicesOnInterfaceType(futures, dpnId, iface);
106 private static Uint64 getDpnID(final Node id) {
107 final String[] node = id.getId().getValue().split(":");
108 if (node.length < 2) {
109 LOG.warn("Unexpected nodeId {}", id.getId().getValue());
112 return Uint64.valueOf(node[1]);