2 * Copyright (c) 2019 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.itm.listeners;
10 import static org.opendaylight.mdsal.binding.util.Datastore.CONFIGURATION;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import java.util.Collection;
14 import java.util.Collections;
15 import java.util.List;
16 import java.util.concurrent.Callable;
17 import javax.inject.Inject;
18 import javax.inject.Singleton;
19 import org.opendaylight.genius.itm.cache.DPNTEPsInfoCache;
20 import org.opendaylight.genius.itm.confighelpers.ItmExternalTunnelAddWorker;
21 import org.opendaylight.genius.itm.confighelpers.ItmExternalTunnelDeleteWorker;
22 import org.opendaylight.genius.itm.globals.ITMConstants;
23 import org.opendaylight.infrautils.jobcoordinator.JobCoordinator;
24 import org.opendaylight.mdsal.binding.api.DataBroker;
25 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunner;
26 import org.opendaylight.mdsal.binding.util.ManagedNewTransactionRunnerImpl;
27 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
28 import org.opendaylight.serviceutils.tools.mdsal.listener.AbstractSyncDataTreeChangeListener;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfig;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.DcGatewayIpList;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.dc.gateway.ip.list.DcGatewayIp;
35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
40 public class DcGatewayIpListener extends AbstractSyncDataTreeChangeListener<DcGatewayIp> {
41 private static final Logger LOG = LoggerFactory.getLogger(DcGatewayIpListener.class);
42 private static final Logger EVENT_LOGGER = LoggerFactory.getLogger("GeniusEventLogger");
43 private final DPNTEPsInfoCache dpnTEPsInfoCache;
44 private final ItmExternalTunnelAddWorker externalTunnelAddWorker;
45 private final DataBroker dataBroker;
46 private final JobCoordinator coordinator;
47 private final ManagedNewTransactionRunner txRunner;
50 public DcGatewayIpListener(final DPNTEPsInfoCache dpnTEPsInfoCache, final DataBroker dataBroker,
51 final ItmConfig itmConfig, final JobCoordinator coordinator) {
52 super(dataBroker, LogicalDatastoreType.CONFIGURATION, InstanceIdentifier.create(DcGatewayIpList.class)
53 .child(DcGatewayIp.class));
54 this.dpnTEPsInfoCache = dpnTEPsInfoCache;
55 this.coordinator = coordinator;
56 this.dataBroker = dataBroker;
57 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
58 this.externalTunnelAddWorker = new ItmExternalTunnelAddWorker(itmConfig, dpnTEPsInfoCache);
62 public void add(DcGatewayIp input) {
63 LOG.debug("Received ADD event for {}", input.getIpAddress());
64 coordinator.enqueueJob(input.getIpAddress().stringValue(),
65 new DcGatewayIpAddWorker(input.getIpAddress(),input.getTunnnelType()), ITMConstants.JOB_MAX_RETRIES);
69 public void update(DcGatewayIp original, DcGatewayIp update) {
74 public void remove(DcGatewayIp input) {
75 LOG.debug("Received REMOVE event for {}", input.getIpAddress());
76 coordinator.enqueueJob(input.getIpAddress().stringValue(),
77 new DcGatewayIpRemoveWorker(input.getIpAddress(),input.getTunnnelType()), ITMConstants.JOB_MAX_RETRIES);
81 private class DcGatewayIpAddWorker implements Callable<List<? extends ListenableFuture<?>>> {
82 private final IpAddress ipAddress;
83 private final Class<? extends TunnelTypeBase> tunnelType;
85 DcGatewayIpAddWorker(IpAddress ipAddress, Class<? extends TunnelTypeBase> tunnelType) {
86 this.ipAddress = ipAddress;
87 this.tunnelType = tunnelType;
91 public List<ListenableFuture<?>> call() throws Exception {
92 EVENT_LOGGER.debug("ITM-DcGatewayIp,ADD {}", ipAddress);
93 Collection<DPNTEPsInfo> meshedDpnList = dpnTEPsInfoCache.getAllPresent();
94 return Collections.singletonList(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION,
95 tx -> externalTunnelAddWorker.buildTunnelsToExternalEndPoint(meshedDpnList,
96 ipAddress, tunnelType, tx)));
100 public String toString() {
101 return "DcGatewayIpAddWorker{ dcGatewayIp =" + ipAddress + '\'' + '}';
105 private class DcGatewayIpRemoveWorker implements Callable<List<? extends ListenableFuture<?>>> {
106 private final IpAddress ipAddress;
107 private final Class<? extends TunnelTypeBase> tunnelType;
109 DcGatewayIpRemoveWorker(IpAddress ipAddress, Class<? extends TunnelTypeBase> tunnelType) {
110 this.ipAddress = ipAddress;
111 this.tunnelType = tunnelType;
115 public List<ListenableFuture<?>> call() throws Exception {
116 EVENT_LOGGER.debug("ITM-DcGatewayIp,REMOVE {}", ipAddress);
117 Collection<DPNTEPsInfo> meshedDpnList = dpnTEPsInfoCache.getAllPresent();
118 return Collections.singletonList(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION,
119 tx -> ItmExternalTunnelDeleteWorker.deleteTunnels(meshedDpnList,
120 ipAddress, tunnelType, tx)));
124 public String toString() {
125 return "DcGatewayIpRemoveWorker{ dcGatewayIp =" + ipAddress + '\'' + '}';