private AtomicInteger sequenceNumber = new AtomicInteger(0);
- private ConcurrentMap<String, List<String>> raiseAlarmObjectMap = new ConcurrentHashMap<String, List<String>>();
+ private ConcurrentMap<String, List<String>> raiseAlarmObjectMap = new ConcurrentHashMap<>();
@Override
public void raiseAlarm(String alarmName, String additionalText, String source, String detailsInfo) {
public class DhcpPortCache {
private static final Logger LOG = LoggerFactory.getLogger(DhcpPortCache.class);
- private final ConcurrentHashMap<String, Port> portMap = new ConcurrentHashMap<String, Port>();
+ private final ConcurrentHashMap<String, Port> portMap = new ConcurrentHashMap<>();
@PostConstruct
public void init() {
.withError(RpcError.ErrorType.APPLICATION, errMsg);
return Futures.immediateFuture(rpcResultBuilder.build());
}
- List<RouterNat> natRouterList = new ArrayList<RouterNat>();
+ List<RouterNat> natRouterList = new ArrayList<>();
for (Uuid routerUuid : routerUuidList) {
long routerId = NatUtil.getVpnId(dataBroker, routerUuid.getValue());
if (routerId == NatConstants.INVALID_ID) {
} else {
// Capturing SNAT information
- List<SnatIpMapping> snatIpMapping = new ArrayList<SnatIpMapping>();
+ List<SnatIpMapping> snatIpMapping = new ArrayList<>();
for (IntextIpProtocolType protocolType : ipPortMapping.getIntextIpProtocolType()) {
for (IpPortMap ipPortMap : protocolType.getIpPortMap()) {
}
// Capturing DNAT information
- List<DnatIpMapping> dnatIpMapping = new ArrayList<DnatIpMapping>();
+ List<DnatIpMapping> dnatIpMapping = new ArrayList<>();
List<Ports> fipPorts = NatUtil.getFloatingIpPortsForRouter(dataBroker, routerUuid);
if (fipPorts.isEmpty()) {
LOG.warn("constructNatInformation : No DNAT IP Mapping found for router-uuid {}", routerUuid.getValue());
natRouterBuilder.setDnatIpMapping(dnatIpMapping);
}
- List<RouterNat> natRouterList = new ArrayList<RouterNat>();
+ List<RouterNat> natRouterList = new ArrayList<>();
natRouterList.add(natRouterBuilder.build());
return natRouterList;
}
final List<Uuid> updateSnMapsIds = portupdateIps.stream().map(FixedIps::getSubnetId)
.collect(Collectors.toList());
Set<Uuid> originalRouterIds = new HashSet<>();
- Set<Uuid> oldVpnIds = new HashSet<Uuid>();
+ Set<Uuid> oldVpnIds = new HashSet<>();
Uuid oldRouterId = null;
for (Uuid snId: originalSnMapsIds) {
if (!updateSnMapsIds.remove(snId)) {
public static List<Routes> getVpnExtraroutes(DataBroker broker, String vpnName, String vpnRd) {
InstanceIdentifier<ExtraRoutes> vpnExtraRoutesId = getVpnToExtrarouteIdentifier(vpnName, vpnRd);
Optional<ExtraRoutes> vpnOpc = MDSALUtil.read(broker, LogicalDatastoreType.OPERATIONAL, vpnExtraRoutesId);
- return vpnOpc.isPresent() ? vpnOpc.get().getRoutes() : new ArrayList<Routes>();
+ return vpnOpc.isPresent() ? vpnOpc.get().getRoutes() : new ArrayList<>();
}
public static Optional<Routes> getVpnExtraroutes(DataBroker broker, String vpnName,