Searched refs:drained (Results 1 – 21 of 21) sorted by relevance
158 int drained = d.drainTo(baos); in testDrainTo_all() local159 assertEquals(baos.size(), drained); in testDrainTo_all() local176 int drained = d.drainTo(baos); in testDrainTo_partial() local177 assertEquals(baos.size(), drained); in testDrainTo_partial() local
117 int drained = drain(q, Lists.newArrayList(), 2, 10, TimeUnit.MILLISECONDS, interruptibly); in testDrainTimesOut() local118 assertTrue(drained <= 1); in testDrainTimesOut()124 if (drained == 0) { in testDrainTimesOut()
12 print fmt: "drained size %lx, skipped size %lx", REC->drained_size, REC->skipped_size
58 until the combiner is drained.63 onto `run_finally` runs after we have drained the queue. That means
44 will block the calling worker until the main thread has drained the
149 be triggered until the messages are drained.
274 buffer is drained down to the low watermark and writing can
412 operations that simultaneously filled _and_ drained a buffer, or handle418 pointer to a struct holding the total number of bytes drained read and the
383 be triggered until the messages are drained.
1681 drained.
928 assure that all threads get released (drained) before any one of them can loop
3605 and continue until drained or loop ended.
5470 And of their wonted vigour left them drained, 9699 From underground;) the liquid ore he drained
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
7908 流失 < be\-drained\-away;27974 流失 > be\-drained\-away;
57758 drained %29527 drend
48817 drained %37572 drend