- if (isCancelled()) {
- if (cf.isSuccess()) {
- LOG.debug("Closing channel for cancelled promise {}", NetconfSessionPromise.this);
- cf.channel().close();
- }
- return;
- }
-
- if (cf.isSuccess()) {
- LOG.debug("Promise {} connection successful", NetconfSessionPromise.this);
- return;
- }
-
- LOG.debug("Attempt to connect to {} failed", NetconfSessionPromise.this.address, cf.cause());
-
- final Future<Void> rf = NetconfSessionPromise.this.strategy.scheduleReconnect(cf.cause());
- rf.addListener(new ReconnectingStrategyListener());
- NetconfSessionPromise.this.pending = rf;
- }
- }
-
- private class ReconnectingStrategyListener implements FutureListener<Void> {
- @Override
- public void operationComplete(final Future<Void> sf) {
- synchronized (NetconfSessionPromise.this) {
- // Triggered when a connection attempt is to be made.
- Preconditions.checkState(NetconfSessionPromise.this.pending.equals(sf));
-
- /*
- * The promise we gave out could have been cancelled,
- * which cascades to the reconnect attempt getting
- * cancelled, but there is a slight race window, where
- * the reconnect attempt is already enqueued, but the
- * listener has not yet been notified -- if cancellation
- * happens at that point, we need to catch it here.
- */
- if (!isCancelled()) {
- if (sf.isSuccess()) {
- connect();
- } else {
- setFailure(sf.cause());
- }