Home
last modified time | relevance | path

Searched refs:numPendingTasks (Results 1 – 14 of 14) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DConnectivityStateManagerTest.java68 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());
DRetriableStreamTest.java188 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 …]
DFakeClockTest.java142 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()
DDnsNameResolverTest.java154 assertEquals(0, fakeClock.numPendingTasks()); in noMorePendingTasks()
155 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
216 assertEquals(0, fakeClock.numPendingTasks()); in resolve_neverCache()
222 assertEquals(0, fakeClock.numPendingTasks()); in resolve_neverCache()
248 assertEquals(0, fakeClock.numPendingTasks()); in resolve_cacheForever()
255 assertEquals(0, fakeClock.numPendingTasks()); in resolve_cacheForever()
282 assertEquals(0, fakeClock.numPendingTasks()); in resolve_usingCache()
290 assertEquals(0, fakeClock.numPendingTasks()); in resolve_usingCache()
316 assertEquals(0, fakeClock.numPendingTasks()); in resolve_cacheExpired()
323 assertEquals(0, fakeClock.numPendingTasks()); in resolve_cacheExpired()
[all …]
DInternalSubchannelTest.java140 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()
DFakeClock.java288 public int numPendingTasks() { in numPendingTasks() method in FakeClock
295 public int numPendingTasks(TaskFilter filter) { in numPendingTasks() method in FakeClock
DDelayedClientTransportTest.java119 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()
DManagedChannelImplTest.java241 assertEquals(numExpectedTasks, timer.numPendingTasks()); in createChannel()
277 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
295 assertEquals(0, timer.numPendingTasks()); in idleModeDisabled()
296 assertEquals(0, executor.numPendingTasks()); in idleModeDisabled()
651 assertEquals(0, callExecutor.numPendingTasks()); in callOptionsExecutor()
662 assertEquals(0, callExecutor.numPendingTasks()); in callOptionsExecutor()
691 assertEquals(1, timer.numPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER)); in nameResolutionFailed()
703 assertEquals(1, timer.numPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER)); in nameResolutionFailed()
713 assertEquals(0, timer.numPendingTasks()); in nameResolutionFailed()
721 assertEquals(0, timer.numPendingTasks()); in nameResolutionFailed()
[all …]
DManagedChannelImplIdlenessTest.java173 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
239 assertEquals(0, executor.numPendingTasks()); in delayedTransportHoldsOffIdleness()
DServerImplTest.java209 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/
DGrpclbLoadBalancerTest.java403 assertEquals(1, fakeClock.numPendingTasks(FALLBACK_MODE_TASK_FILTER)); in loadReporting()
419 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in loadReporting()
423 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in loadReporting()
557 assertEquals(1, fakeClock.numPendingTasks()); in loadReporting()
560 assertEquals(0, fakeClock.numPendingTasks()); in loadReporting()
631 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in abundantInitialResponse()
635 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in abundantInitialResponse()
669 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
673 assertEquals(1, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
681 assertEquals(0, fakeClock.numPendingTasks(LOAD_REPORTING_TASK_FILTER)); in raceBetweenLoadReportingAndLbStreamClosure()
[all …]
DCachedSubchannelPoolTest.java135 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/
DChannelExecutor.java93 final int numPendingTasks() { in numPendingTasks() method in ChannelExecutor
/external/grpc-grpc-java/core/
Dgrpc-core-1.14.0.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...