for (VpnToDpnList dpnInVpn : vpnToDpnList ) {
dpns.add(dpnInVpn.getDpnId());
}
- if ( !dpns.contains(dpnId) ) {
+ if (!dpns.contains(BigInteger.valueOf(dpnId))) {
LOG.debug("Dpn {} is not included in the current VPN Footprint", dpnId);
dpns.add(BigInteger.valueOf(dpnId));
}
// Verifying installed flows
ArgumentCaptor<Flow> argumentCaptor = ArgumentCaptor.forClass(Flow.class);
- verify(mdsalMgr, times(2)).installFlow((BigInteger)anyObject(), argumentCaptor.capture());
+ verify(mdsalMgr, times(1)).installFlow((BigInteger)anyObject(), argumentCaptor.capture());
List<Flow> installedFlowsCaptured = argumentCaptor.getAllValues();
- assert (installedFlowsCaptured.size() == 2);
+ assert (installedFlowsCaptured.size() == 1);
Flow expectedLportDispatcherFlowEntity =
VpnServiceChainUtils.buildLPortDispFromScfToL3VpnFlow(VPN_ID, DPN_ID, LPORT_TAG, NwConstants.ADD_FLOW);
assert (new FlowMatcher(expectedLportDispatcherFlowEntity).matches(installedFlowsCaptured.get(0)));
designatedSwitchForTunnelOptional.get().getDesignatedSwitchForTunnel();
for (DesignatedSwitchForTunnel designatedSwitchForTunnel : list) {
Set<Pair<IpAddress, String>> setOfTunnelIpElanNamePair =
- designatedDpnsToTunnelIpElanNameCache.get(designatedSwitchForTunnel.getDpId());
+ designatedDpnsToTunnelIpElanNameCache
+ .get(BigInteger.valueOf(designatedSwitchForTunnel.getDpId()));
if (setOfTunnelIpElanNamePair == null) {
setOfTunnelIpElanNamePair = new CopyOnWriteArraySet<>();
}