Home
last modified time | relevance | path

Searched refs:nextBackoffNanos (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DExponentialBackoffPolicy.java45 private long nextBackoffNanos = initialBackoffNanos; field in ExponentialBackoffPolicy
48 public long nextBackoffNanos() { in nextBackoffNanos() method in ExponentialBackoffPolicy
49 long currentBackoffNanos = nextBackoffNanos; in nextBackoffNanos()
50 nextBackoffNanos = Math.min((long) (currentBackoffNanos * multiplier), maxBackoffNanos); in nextBackoffNanos()
DBackoffPolicy.java30 long nextBackoffNanos(); in nextBackoffNanos() method
DInternalSubchannel.java289 reconnectPolicy.nextBackoffNanos() - connectingTimer.elapsed(TimeUnit.NANOSECONDS); in scheduleBackoff()
DManagedChannelImpl.java1348 long delayNanos = nameResolverBackoffPolicy.nextBackoffNanos(); in onError()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DExponentialBackoffPolicyTest.java47 if (maxBackoffNanos == policy.nextBackoffNanos()) { in maxDelayReached()
51 assertEquals("max delay not reached", maxBackoffNanos, policy.nextBackoffNanos()); in maxDelayReached()
DInternalSubchannelTest.java133 when(mockBackoffPolicy1.nextBackoffNanos()).thenReturn(10L, 100L); in setUp()
134 when(mockBackoffPolicy2.nextBackoffNanos()).thenReturn(10L, 100L); in setUp()
135 when(mockBackoffPolicy3.nextBackoffNanos()).thenReturn(10L, 100L); in setUp()
192 verify(mockBackoffPolicy1, times(++backoff1Consulted)).nextBackoffNanos(); in singleAddressReconnect()
217 verify(mockBackoffPolicy1, times(++backoff1Consulted)).nextBackoffNanos(); in singleAddressReconnect()
258 verify(mockBackoffPolicy1, times(backoff1Consulted)).nextBackoffNanos(); in singleAddressReconnect()
259 verify(mockBackoffPolicy2, times(backoff2Consulted)).nextBackoffNanos(); in singleAddressReconnect()
302 verify(mockBackoffPolicy1, times(++backoff1Consulted)).nextBackoffNanos(); in twoAddressesReconnect()
338 verify(mockBackoffPolicy1, times(++backoff1Consulted)).nextBackoffNanos(); in twoAddressesReconnect()
391 verify(mockBackoffPolicy2, times(++backoff2Consulted)).nextBackoffNanos(); in twoAddressesReconnect()
[all …]
DManagedChannelImplIdlenessTest.java433 public long nextBackoffNanos() { in get()
DManagedChannelImplTest.java2827 public long nextBackoffNanos() { in get() method
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java252 when(backoffPolicy1.nextBackoffNanos()).thenReturn(10L, 100L); in setUp()
253 when(backoffPolicy2.nextBackoffNanos()).thenReturn(10L, 100L); in setUp()
1417 inOrder.verify(backoffPolicy1).nextBackoffNanos(); in grpclbBalancerStreamRetry()
1436 inOrder.verify(backoffPolicy1).nextBackoffNanos(); in grpclbBalancerStreamRetry()
1470 inOrder.verify(backoffPolicy2).nextBackoffNanos(); in grpclbBalancerStreamRetry()
1486 verify(backoffPolicy1, times(2)).nextBackoffNanos(); in grpclbBalancerStreamRetry()
1487 verify(backoffPolicy2, times(1)).nextBackoffNanos(); in grpclbBalancerStreamRetry()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java633 prevLbRpcStartNanos + lbRpcRetryPolicy.nextBackoffNanos() - time.currentTimeNanos(); in handleStreamClosed()