| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 68 assertEquals(0, executor.numPendingTasks()); in registerCallbackBeforeStateChanged()
73 assertEquals(0, executor.numPendingTasks()); in registerCallbackBeforeStateChanged()
93 assertEquals(0, executor.numPendingTasks()); in registerCallbackAfterStateChanged()
108 assertEquals(0, executor.numPendingTasks()); in callbackOnlyCalledOnTransition()
127 assertEquals(0, executor.numPendingTasks()); in callbacksAreOneShot()
132 assertEquals(0, executor.numPendingTasks()); in callbacksAreOneShot()
145 assertEquals(0, executor.numPendingTasks()); in callbacksAreOneShot()
191 assertEquals(0, executor.numPendingTasks()); in multipleCallbacks()
211 assertEquals(0, executor.numPendingTasks());
217 assertEquals(0, executor.numPendingTasks());
|
| D | RetriableStreamTest.java | 188 assertEquals(0, fakeClock.numPendingTasks()); in tearDown()
252 assertEquals(1, fakeClock.numPendingTasks()); in retry_everythingDrained()
260 assertEquals(1, fakeClock.numPendingTasks()); in retry_everythingDrained()
262 assertEquals(0, fakeClock.numPendingTasks()); in retry_everythingDrained()
296 assertEquals(1, fakeClock.numPendingTasks()); in retry_everythingDrained()
307 assertEquals(1, fakeClock.numPendingTasks()); in retry_everythingDrained()
309 assertEquals(0, fakeClock.numPendingTasks()); in retry_everythingDrained()
378 assertEquals(1, fakeClock.numPendingTasks()); in retry_headersRead_cancel()
603 assertEquals(1, fakeClock.numPendingTasks()); in retry_cancelWhileBackoff()
678 assertEquals(1, fakeClock.numPendingTasks()); in operationsWhileDraining()
[all …]
|
| D | FakeClockTest.java | 142 assertEquals(8, fakeClock.numPendingTasks()); in testPendingAndDueTasks()
147 assertEquals(6, fakeClock.numPendingTasks()); in testPendingAndDueTasks()
152 assertEquals(4, fakeClock.numPendingTasks()); in testPendingAndDueTasks()
157 assertEquals(2, fakeClock.numPendingTasks()); in testPendingAndDueTasks()
187 assertEquals(2, fakeClock.numPendingTasks()); in testTaskFilter()
188 assertEquals(1, fakeClock.numPendingTasks(filter)); in testTaskFilter()
|
| D | InternalSubchannelTest.java | 140 assertEquals(0, fakeClock.numPendingTasks()); in noMorePendingTasks()
141 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
462 assertEquals(0, fakeClock.numPendingTasks()); in updateAddresses_intersecting_ready()
507 assertEquals(0, fakeClock.numPendingTasks()); in updateAddresses_intersecting_connecting()
540 assertEquals(0, fakeClock.numPendingTasks()); in updateAddresses_disjoint_idle()
583 assertEquals(0, fakeClock.numPendingTasks()); in updateAddresses_disjoint_ready()
625 assertEquals(0, fakeClock.numPendingTasks()); in updateAddresses_disjoint_connecting()
671 assertEquals(0, fakeClock.numPendingTasks()); in connectIsLazy()
672 assertEquals(0, fakeExecutor.numPendingTasks()); in connectIsLazy()
1130 assertEquals(0, channelExecutor.numPendingTasks()); in assertExactCallbackInvokes()
|
| D | FakeClock.java | 288 public int numPendingTasks() { in numPendingTasks() method in FakeClock
295 public int numPendingTasks(TaskFilter filter) { in numPendingTasks() method in FakeClock
|
| D | DelayedClientTransportTest.java | 119 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
129 assertEquals(0, fakeExecutor.numPendingTasks()); in streamStartThenAssignTransport()
377 assertEquals(0, fakeExecutor.numPendingTasks()); in reprocessSemantics()
402 assertEquals(0, wfr3Executor.numPendingTasks()); in reprocessSemantics()
415 assertEquals(0, fakeExecutor.numPendingTasks()); in reprocessSemantics()
|
| D | ManagedChannelImplTest.java | 240 assertEquals(numExpectedTasks, timer.numPendingTasks()); in createChannel()
276 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
294 assertEquals(0, timer.numPendingTasks()); in idleModeDisabled()
295 assertEquals(0, executor.numPendingTasks()); in idleModeDisabled()
650 assertEquals(0, callExecutor.numPendingTasks()); in callOptionsExecutor()
661 assertEquals(0, callExecutor.numPendingTasks()); in callOptionsExecutor()
690 assertEquals(1, timer.numPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER)); in nameResolutionFailed()
702 assertEquals(1, timer.numPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER)); in nameResolutionFailed()
712 assertEquals(0, timer.numPendingTasks()); in nameResolutionFailed()
720 assertEquals(0, timer.numPendingTasks()); in nameResolutionFailed()
[all …]
|
| D | DnsNameResolverTest.java | 134 assertEquals(0, fakeClock.numPendingTasks()); in noMorePendingTasks()
135 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
195 assertEquals(0, fakeClock.numPendingTasks()); in resolve()
201 assertEquals(0, fakeClock.numPendingTasks()); in resolve()
|
| D | ManagedChannelImplIdlenessTest.java | 173 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
239 assertEquals(0, executor.numPendingTasks()); in delayedTransportHoldsOffIdleness()
|
| D | ServerImplTest.java | 209 assertEquals(0, executor.numPendingTasks()); in noPendingTasks()
210 assertEquals(0, timer.numPendingTasks()); in noPendingTasks()
931 assertEquals(1, executor.numPendingTasks(CONTEXT_CLOSER_TASK_FITLER)); in testCallContextIsBoundInListenerCallbacks()
1002 assertEquals(1, executor.numPendingTasks(CONTEXT_CLOSER_TASK_FITLER)); in testClientClose_cancelTriggersImmediateCancellation()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 402 assertEquals(1, fakeClock.numPendingTasks(FALLBACK_MODE_TASK_FILTER)); in loadReporting()
418 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in loadReporting()
422 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in loadReporting()
556 assertEquals(1, fakeClock.numPendingTasks()); in loadReporting()
559 assertEquals(0, fakeClock.numPendingTasks()); in loadReporting()
630 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in abundantInitialResponse()
634 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in abundantInitialResponse()
668 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
672 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
680 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
[all …]
|
| D | CachedSubchannelPoolTest.java | 135 assertThat(clock.numPendingTasks()).isEqualTo(0); in subchannelExpireAfterReturned()
179 assertThat(clock.numPendingTasks()).isEqualTo(0); in subchannelReused()
228 assertThat(clock.numPendingTasks()).isEqualTo(0); in clear()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ChannelExecutor.java | 93 final int numPendingTasks() { in numPendingTasks() method in ChannelExecutor
|