private static final long serialVersionUID = 1L;
MockFailure(final WritableIdentifier target, final RequestException cause) {
private static final long serialVersionUID = 1L;
MockFailure(final WritableIdentifier target, final RequestException cause) {
private static final long serialVersionUID = 1L;
MockRequest(final WritableIdentifier target, final ActorRef replyTo) {
private static final long serialVersionUID = 1L;
MockRequest(final WritableIdentifier target, final ActorRef replyTo) {
mockRequest = new MockRequest(mockIdentifier, mockReplyTo);
mockRequest2 = new MockRequest(mockIdentifier, mockReplyTo);
mockResponse = mockRequest.toRequestFailure(mockCause);
mockRequest = new MockRequest(mockIdentifier, mockReplyTo);
mockRequest2 = new MockRequest(mockIdentifier, mockReplyTo);
mockResponse = mockRequest.toRequestFailure(mockCause);
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
final Optional<FiniteDuration> ret = queue.setBackendInfo(proof, mockBackendInfo);
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
final Optional<FiniteDuration> ret = queue.setBackendInfo(proof, mockBackendInfo);
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
assertTrue(queue.expectProof(proof));
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
assertTrue(queue.expectProof(proof));
- public void testSetbackedWithRequestsNoTimer() {
- queue.enqueueRequest(0, mockRequest, mockCallback);
+ public void testSetBackendWithRequestsNoTimer() {
+ queue.enqueueRequest(mockRequest, mockCallback);
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
assertTrue(queue.expectProof(proof));
final CompletableFuture<BackendInfo> proof = new CompletableFuture<>();
assertTrue(queue.expectProof(proof));
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
// Second request, no timer fired
assertNotNull(ret);
assertTrue(ret.isPresent());
assertTransmit(mockRequest, 0);
// Second request, no timer fired
final boolean ret = queue.runTimeout();
assertFalse(ret);
}
@Test
public void testRunTimeoutWithTimeoutLess() throws NoProgressException {
final boolean ret = queue.runTimeout();
assertFalse(ret);
}
@Test
public void testRunTimeoutWithTimeoutLess() throws NoProgressException {
@Test(expected=NoProgressException.class)
public void testRunTimeoutWithoutProgressExact() throws NoProgressException {
@Test(expected=NoProgressException.class)
public void testRunTimeoutWithoutProgressExact() throws NoProgressException {
@Test(expected=NoProgressException.class)
public void testRunTimeoutWithoutProgressMore() throws NoProgressException {
@Test(expected=NoProgressException.class)
public void testRunTimeoutWithoutProgressMore() throws NoProgressException {
ClientActorBehavior ret = queue.complete(mockBehavior, mockResponseEnvelope);
verify(mockCallback).complete(mockResponse);
ClientActorBehavior ret = queue.complete(mockBehavior, mockResponseEnvelope);
verify(mockCallback).complete(mockResponse);
queue.complete(mockBehavior, mockResponseEnvelope);
ticker.increment(SequencedQueue.NO_PROGRESS_TIMEOUT_NANOS - 11);
queue.complete(mockBehavior, mockResponseEnvelope);
ticker.increment(SequencedQueue.NO_PROGRESS_TIMEOUT_NANOS - 11);
- assertEquals(0, actual.getRetry());
- assertEquals(sequence, actual.getSequence());
+ assertEquals(0, actual.getSessionId());
+ assertEquals(sequence, actual.getTxSequence());