Switch to yangtools-provided mockito configuration

[bgpcep.git] / framework / src / main / java / org / opendaylight / protocol / framework / ProtocolSessionPromise.java

diff --git a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java
index 41898a53f5cbe5f3c1a0e1585dbcbbee23787764..70669982962b54bed881579ed17c7eabeb9d1c6c 100644 (file)
--- a/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java
+++ b/framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java
@@ -37,7 +37,8 @@ final class ProtocolSessionPromise<S extends ProtocolSession<?>> extends Default
        @GuardedBy("this")
        private Future<?> pending;
 
-       ProtocolSessionPromise(final EventExecutor executor, final InetSocketAddress address, final ReconnectStrategy strategy, final Bootstrap b) {
+       ProtocolSessionPromise(final EventExecutor executor, final InetSocketAddress address, final ReconnectStrategy strategy,
+                       final Bootstrap b) {
                super(executor);
                this.strategy = Preconditions.checkNotNull(strategy);
                this.address = Preconditions.checkNotNull(address);
@@ -61,7 +62,7 @@ final class ProtocolSessionPromise<S extends ProtocolSession<?>> extends Default
                                                LOG.debug("Promise {} connection resolved", lock);
 
                                                // Triggered when a connection attempt is resolved.
-                                               Preconditions.checkState(ProtocolSessionPromise.this.pending == cf);
+                                               Preconditions.checkState(ProtocolSessionPromise.this.pending.equals(cf));
 
                                                /*
                                                 * The promise we gave out could have been cancelled,
@@ -81,14 +82,14 @@ final class ProtocolSessionPromise<S extends ProtocolSession<?>> extends Default
                                                }
 
                                                if (!cf.isSuccess()) {
-                                                       LOG.info("Attempt to connect to connect to {} failed", address, cf.cause());
+                                                       LOG.info("Attempt to connect to connect to {} failed", ProtocolSessionPromise.this.address, cf.cause());
                                                        final Future<Void> rf = ProtocolSessionPromise.this.strategy.scheduleReconnect(cf.cause());
                                                        rf.addListener(new FutureListener<Void>() {
                                                                @Override
                                                                public void operationComplete(final Future<Void> sf) {
                                                                        synchronized (lock) {
                                                                                // Triggered when a connection attempt is to be made.
-                                                                               Preconditions.checkState(ProtocolSessionPromise.this.pending == sf);
+                                                                               Preconditions.checkState(ProtocolSessionPromise.this.pending.equals(sf));
 
                                                                                /*
                                                                                 * The promise we gave out could have been cancelled,