@Test
public void testSendRequestNeedsBackend() {
queue.sendRequest(mockRequest, mockCallback);
- final Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ final Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
setupBackend();
queue.sendRequest(mockRequest, mockCallback);
- final Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ final Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
@Test
public void testRunTimeoutEmpty() throws NoProgressException {
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertFalse(ret.isPresent());
}
@Test
public void testRunTimeoutWithoutShift() throws NoProgressException {
queue.sendRequest(mockRequest, mockCallback);
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
public void testRunTimeoutWithTimeoutLess() throws NoProgressException {
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.REQUEST_TIMEOUT_NANOS - 1);
+ ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS - 1);
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertTrue(ret.isPresent());
}
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.REQUEST_TIMEOUT_NANOS);
+ ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS);
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);
}
queue.sendRequest(mockRequest, mockCallback);
- ticker.advance(AbstractClientConnection.REQUEST_TIMEOUT_NANOS + 1);
+ ticker.advance(AbstractClientConnection.BACKEND_ALIVE_TIMEOUT_NANOS + 1);
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);
}
ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS);
// No problem
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertFalse(ret.isPresent());
}
ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS + 1);
// No problem
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNotNull(ret);
assertFalse(ret.isPresent());
}
ticker.advance(AbstractClientConnection.NO_PROGRESS_TIMEOUT_NANOS - 11);
- Optional<FiniteDuration> ret = queue.checkTimeout(ticker.read());
+ Optional<Long> ret = queue.checkTimeout(ticker.read());
assertNull(ret);
}