import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
-
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ItmInternalTunnelAddWorker {
+public final class ItmInternalTunnelAddWorker {
private static final Logger LOG = LoggerFactory.getLogger(ItmInternalTunnelAddWorker.class) ;
private static Boolean monitorEnabled;
private static Integer monitorInterval;
private static ItmConfig itmCfg;
private static Class<? extends TunnelMonitoringTypeBase> monitorProtocol;
+
private static final FutureCallback<Void> DEFAULT_CALLBACK = new FutureCallback<Void>() {
@Override
public void onSuccess(Void result) {
}
};
- public static List<ListenableFuture<Void>> build_all_tunnels(DataBroker dataBroker,
+ private ItmInternalTunnelAddWorker() {
+ }
+
+ public static List<ListenableFuture<Void>> buildAllTunnels(DataBroker dataBroker,
IdManagerService idManagerService,
IMdsalApiManager mdsalManager,
List<DPNTEPsInfo> cfgdDpnList,
for (DPNTEPsInfo dpn : cfgdDpnList) {
//#####if dpn is not in meshedDpnList
- build_tunnel_from(dpn, meshedDpnList, dataBroker, idManagerService, mdsalManager, transaction, futures);
+ buildTunnelFrom(dpn, meshedDpnList, dataBroker, idManagerService, mdsalManager, transaction, futures);
if (null == meshedDpnList) {
meshedDpnList = new ArrayList<>();
}
ITMBatchingUtils.update(dep, tnlBuilder, ITMBatchingUtils.EntityType.DEFAULT_CONFIG);
}
- private static void build_tunnel_from(DPNTEPsInfo srcDpn,List<DPNTEPsInfo> meshedDpnList, DataBroker dataBroker,
+ private static void buildTunnelFrom(DPNTEPsInfo srcDpn,List<DPNTEPsInfo> meshedDpnList, DataBroker dataBroker,
IdManagerService idManagerService, IMdsalApiManager mdsalManager,
WriteTransaction transaction, List<ListenableFuture<Void>> futures) {
LOG.trace("Building tunnels from DPN {} " , srcDpn);
- if (null == meshedDpnList || 0 == meshedDpnList.size()) {
+ if (null == meshedDpnList || meshedDpnList.isEmpty()) {
LOG.debug("No DPN in the mesh ");
return ;
}
this.meshedDpnList = ItmUtils.getTunnelMeshInfo(dataBroker) ;
LOG.debug("Invoking Internal Tunnel build method with Configured DpnList {} ; Meshed DpnList {} ",
cfgdDpnList, meshedDpnList);
- futures.addAll(ItmInternalTunnelAddWorker.build_all_tunnels(dataBroker, idManagerService, mdsalManager,
+ futures.addAll(ItmInternalTunnelAddWorker.buildAllTunnels(dataBroker, idManagerService, mdsalManager,
cfgdDpnList, meshedDpnList, itmConfig)) ;
// IF EXTERNAL TUNNELS NEEDS TO BE BUILT, DO IT HERE. IT COULD BE TO DC GATEWAY OR TOR SWITCH
List<DcGatewayIp> dcGatewayIpList = ItmUtils.getDcGatewayIpList(dataBroker);
/*
- * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
+ * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. 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,
@Mock ITMBatchingUtils batchingUtils;
@Mock ItmConfig itmConfig;
- ItmInternalTunnelAddWorker addWorker = new ItmInternalTunnelAddWorker();
-
Optional<TunnelMonitorParams> tunnelMonitorParamsOptional;
Optional<TunnelMonitorInterval> tunnelMonitorIntervalOptional;
-
@Before
public void setUp() {
PowerMockito.mockStatic(ITMBatchingUtils.class);
internalTunnel1 = ItmUtils.buildInternalTunnel(dpId1,dpId2,tunnelType1,trunkInterfaceName1);
internalTunnel2 = ItmUtils.buildInternalTunnel(dpId2,dpId1,tunnelType1,trunkInterfaceName2);
- addWorker.build_all_tunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListVxlan, meshDpnListVxlan,
- itmConfig);
+ ItmInternalTunnelAddWorker.buildAllTunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListVxlan,
+ meshDpnListVxlan, itmConfig);
//Add some verifications
verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION, internalTunnelIdentifierVxlan1,
internalTunnel1 = ItmUtils.buildInternalTunnel(dpId1,dpId2,tunnelType2,trunkInterfaceName1);
internalTunnel2 = ItmUtils.buildInternalTunnel(dpId2,dpId1,tunnelType2,trunkInterfaceName2);
- addWorker.build_all_tunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListGre, meshDpnListGre,
- itmConfig);
+ ItmInternalTunnelAddWorker.buildAllTunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListGre,
+ meshDpnListGre, itmConfig);
verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION, internalTunnelIdentifierGre1,
internalTunnel1,true);
internalTunnel1 = ItmUtils.buildInternalTunnel(dpId1,dpId2,tunnelType1,trunkInterfaceName1);
internalTunnel2 = ItmUtils.buildInternalTunnel(dpId2,dpId1,tunnelType2,trunkInterfaceName2);
- addWorker.build_all_tunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListVxlan, meshDpnListGre,
- itmConfig);
+ ItmInternalTunnelAddWorker.buildAllTunnels(dataBroker, idManagerService, mdsalApiManager, cfgdDpnListVxlan,
+ meshDpnListGre, itmConfig);
verify(mockWriteTx).merge(LogicalDatastoreType.CONFIGURATION, internalTunnelIdentifierVxlan1,
internalTunnel1,true);