import org.opendaylight.controller.cluster.access.concepts.RuntimeRequestException;
import org.opendaylight.controller.cluster.access.concepts.SuccessEnvelope;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
-import scala.concurrent.duration.FiniteDuration;
public abstract class AbstractClientConnectionTest<T extends AbstractClientConnection<U>, U extends BackendInfo> {
@Test
public void testCheckTimeoutEmptyQueue() throws Exception {
- final Optional<FiniteDuration> timeout = connection.checkTimeout(context.ticker().read());
+ final Optional<Long> timeout = connection.checkTimeout(context.ticker().read());
Assert.assertFalse(timeout.isPresent());
}
public void testCheckTimeoutConnectionTimeouted() throws Exception {
final Consumer<Response<?, ?>> callback = mock(Consumer.class);
connection.sendRequest(createRequest(replyToProbe.ref()), callback);
- final long now = context.ticker().read() + ConnectedClientConnection.REQUEST_TIMEOUT_NANOS;
- final Optional<FiniteDuration> timeout = connection.checkTimeout(now);
+ final long now = context.ticker().read() + ConnectedClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS;
+ final Optional<Long> timeout = connection.checkTimeout(now);
Assert.assertNull(timeout);
}
final Consumer<Response<?, ?>> callback = mock(Consumer.class);
connection.sendRequest(createRequest(replyToProbe.ref()), callback);
final long now = context.ticker().read();
- final Optional<FiniteDuration> timeout = connection.checkTimeout(now);
+ final Optional<Long> timeout = connection.checkTimeout(now);
Assert.assertTrue(timeout.isPresent());
}