+ private void deleteLocalAdjacency(final long dpId, final long vpnId, final VrfEntry vrfEntry) {
+ LOG.trace("deleteLocalAdjacency called with dpid {}, vpnId{}, VrfEntry {}",dpId, vpnId, vrfEntry);;
+ try {
+ Future<RpcResult<Void>> result =
+ l3nexthopService.removeLocalNextHop(new RemoveLocalNextHopInputBuilder().setDpnId(dpId)
+ .setIpPrefix(vrfEntry.getDestPrefix())
+ .setNexthopIp(vrfEntry.getNextHopAddress())
+ .setVpnId(vpnId)
+ .build());
+ RpcResult<Void> rpcResult = result.get();
+ if (rpcResult.isSuccessful()) {
+ LOG.debug("Local Next hop for {} on dpn {} successfully deleted", vrfEntry.getDestPrefix(), dpId);
+ } else {
+ LOG.error("Local Next hop for {} on dpn {} not deleted", vrfEntry.getDestPrefix(), dpId);
+ }
+ } catch (NullPointerException | InterruptedException | ExecutionException e) {
+ LOG.trace("", e);
+ }
+ }
+
+ public void populateFibOnNewDpn(long dpnId, long vpnId, String rd) {
+ LOG.trace("New dpn {} for vpn {} : populateFibOnNewDpn", dpnId, rd);
+ InstanceIdentifier<VrfTables> id = buildVrfId(rd);
+ Optional<VrfTables> vrfTable = read(LogicalDatastoreType.OPERATIONAL, id);
+ if(vrfTable.isPresent()) {
+ for(VrfEntry vrfEntry : vrfTable.get().getVrfEntry()) {
+ addRouteInternal(dpnId, vpnId, vrfTable.get().getKey(), vrfEntry);
+ }
+ }
+ }
+
+ public void cleanUpDpnForVpn(long dpnId, long vpnId, String rd) {
+ LOG.trace("Remove dpn {} for vpn {} : cleanUpDpnForVpn", dpnId, rd);
+ InstanceIdentifier<VrfTables> id = buildVrfId(rd);
+ Optional<VrfTables> vrfTable = read(LogicalDatastoreType.OPERATIONAL, id);
+ if(vrfTable.isPresent()) {
+ for(VrfEntry vrfEntry : vrfTable.get().getVrfEntry()) {
+ deleteRoute(dpnId, vpnId, vrfTable.get().getKey(), vrfEntry);
+ }
+ }
+ }
+
+ public static InstanceIdentifier<VrfTables> buildVrfId(String rd) {
+ InstanceIdentifierBuilder<VrfTables> idBuilder =
+ InstanceIdentifier.builder(FibEntries.class).child(VrfTables.class, new VrfTablesKey(rd));
+ InstanceIdentifier<VrfTables> id = idBuilder.build();
+ return id;
+ }
+