this.adjRibOutListenerSet.values().forEach(AdjRibOutListener::close);
this.adjRibOutListenerSet.clear();
final FluentFuture<? extends CommitInfo> future;
- if (!isRestartingGracefully()) {
- future = terminateConnection();
- } else {
+ if (isRestartingGracefully()) {
final Set<TablesKey> gracefulTables = getGracefulTables();
this.ribWriter.storeStaleRoutes(gracefulTables);
future = this.ribWriter.clearTables(Sets.difference(this.tables, gracefulTables));
this.peerRestartStopwatch = Stopwatch.createStarted();
handleRestartTimer();
}
+ } else {
+ future = terminateConnection();
}
releaseBindingChain(isWaitForSubmitted);