UnicastSubsequentAddressFamily.class);
private ImmutableSet<TablesKey> tables = ImmutableSet.of();
- private ImmutableSet<TablesKey> advertizedTables = ImmutableSet.of();
private final RIB rib;
private final Map<TablesKey, AdjRibOutListener> adjRibOutListenerSet = new HashMap<>();
private final List<RouteTarget> rtMemberships = new ArrayList<>();
createEffRibInWriter();
this.effRibInWriter.init();
registerPrefixesCounters(this.effRibInWriter, this.effRibInWriter);
- for (final TablesKey key : this.advertizedTables) {
+ for (final TablesKey key : getAfiSafisAdvertized()) {
createAdjRibOutListener(key, true);
}
setLocalRestartingState(false);
final Set<TablesKey> setTables = advertizedTableTypes.stream().map(t -> new TablesKey(t.getAfi(), t.getSafi()))
.collect(Collectors.toSet());
this.tables = ImmutableSet.copyOf(setTables);
- this.advertizedTables = ImmutableSet.copyOf(Sets.intersection(tables, getAfiSafisAdvertized()));
this.addPathTableMaps = mapTableTypesFamilies(addPathTablesType);
final boolean restartingLocally = isLocalRestarting();
if (!restartingLocally) {
addBgp4Support();
- for (final TablesKey key : this.advertizedTables) {
+ for (final TablesKey key : getAfiSafisAdvertized()) {
createAdjRibOutListener(key, true);
}
}
@Override
public boolean supportsTable(final TablesKey tableKey) {
- return this.advertizedTables.contains(tableKey) && this.sessionUp;
+ return this.sessionUp && getAfiSafisAdvertized().contains(tableKey);
}
@Override
SendReceive getSupportedAddPathTables(@Nonnull TablesKey tableKey);
/**
- * Returns true if peer supports table and we have advertized support for it, i.e. any prefix from this table should
+ * Returns true if we have advertized support for a table, i.e. any prefix from this table should
* be subject to export towards the peer.
*
* @param tableKey table
- * @return true if the table is supported by the peer and we have advertized support for it.
+ * @return true if the table is being advertized to the peer.
*/
boolean supportsTable(@Nonnull TablesKey tableKey);