| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | SerializingExecutorTest.java | 86 singleExecutor.drain(); in serial()
91 singleExecutor.drain(); in serial()
101 singleExecutor.drain(); in parallel()
115 singleExecutor.drain(); in reentrant()
132 singleExecutor.drain(); in testFirstRunnableThrows()
150 singleExecutor.drain(); in lastRunnableThrows()
156 singleExecutor.drain(); in lastRunnableThrows()
182 singleExecutor.drain(); in firstExecuteThrows()
223 public void drain() { in drain() method in SerializingExecutorTest.SingleExecutor
|
| D | ChannelExecutorTest.java | 77 executor.drain(); in singleThread()
83 executor.drain(); in singleThread()
125 executor.drain(); in multiThread()
135 executor.drain(); in multiThread()
162 executor.drain(); in taskThrows()
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 71 private static <T> int drain(BlockingQueue<T> q, Collection<? super T> buffer, int maxElements, in drain() method in QueuesTest
74 ? Queues.drain(q, buffer, maxElements, timeout, unit) in drain()
94 int elements = drain(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS, interruptibly); in testMultipleProducers()
109 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, TimeUnit.MILLISECONDS)); in testDrainTimesOut()
117 int drained = drain(q, Lists.newArrayList(), 2, 10, TimeUnit.MILLISECONDS, interruptibly); in testDrainTimesOut()
139 assertEquals(0, drain(q, ImmutableList.of(), 0, 10, TimeUnit.MILLISECONDS, interruptibly)); in testZeroElements()
163 int elements = Queues.drain(q, buf, -1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
169 Queues.drain(q, buf, 1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
181 Queues.drain(q, ImmutableList.of(), 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testDrain_throws()
245 assertEquals(0, Queues.drain(q, ImmutableList.of(), 0, 10, TimeUnit.MILLISECONDS)); in assertInterruptibleDrained()
[all …]
|
| /external/clang/test/ARCMT/ |
| D | atautorelease-3.m | 6 - drain; method
25 [chunkPool drain];
26 [pool drain];
38 [chunkPool drain];
39 [pool drain];
|
| D | atautorelease.m | 16 [pool drain];
18 [pool drain];
35 [pool2 drain];
58 [pool drain];
|
| D | atautorelease-2.m | 6 - drain; method
25 [chunkPool drain];
26 [pool drain];
|
| D | cxx-rewrite.mm | 16 [pool drain];
31 [pool drain];
|
| D | atautorelease-check.m | 63 - (void)drain; method
80 [chunkPool drain];
81 [pool drain];
|
| D | atautorelease-2.m.result | 6 - drain;
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalSubchannel.java | 213 channelExecutor.drain(); in obtainActiveTransport()
279 channelExecutor.drain(); in scheduleBackoff()
316 channelExecutor.drain(); in resetConnectBackoff()
378 channelExecutor.drain(); in updateAddresses()
411 channelExecutor.drain(); in shutdown()
452 }).drain(); in handleTransportInUseState()
463 channelExecutor.drain(); in shutdownNow()
476 channelExecutor.drain(); in getAddressGroups()
525 channelExecutor.drain(); in getState()
567 channelExecutor.drain(); in transportReady()
[all …]
|
| D | DelayedClientTransport.java | 170 channelExecutor.drain(); in newStream()
223 channelExecutor.drain(); in shutdown()
247 channelExecutor.executeLater(savedReportTransportTerminated).drain(); in shutdownNow()
337 channelExecutor.drain(); in reprocess()
381 channelExecutor.drain(); in cancel()
|
| D | ManagedChannelImpl.java | 317 }).drain(); in getStats()
481 }).drain();
593 channelExecutor.drain(); in ManagedChannelImpl()
710 }).drain(); in shutdown()
734 }).drain(); in shutdownNow()
868 }).drain(); in getState()
881 }).drain(); in notifyWhenStateChanged()
907 .drain(); in resetConnectBackoff()
923 channelExecutor.executeLater(new PrepareToLoseNetworkRunnable()).drain(); in enterIdle()
1242 channelExecutor.executeLater(task).drain(); in runSerialized()
[all …]
|
| /external/perfetto/docs/ |
| D | ftrace.md | 22 main thread [drain] [unblock]
33 drain period (100ms)
47 When at least one worker has woken up, we schedule a drain operation
48 on the main thread for the next drain period (every 100ms by default).
49 The drain operation parses ftrace data from the staging pipes of
|
| /external/clang/test/SemaObjC/ |
| D | ivar-access-package.m | 16 - drain; method
45 [pool drain];
|
| /external/webrtc/talk/media/devices/ |
| D | macdevicemanagermm.mm | 95 [pool drain];
104 [pool drain];
139 [pool drain];
181 [pool drain];
|
| /external/clang/test/Analysis/ |
| D | uninit-ps-rdar6145427.m | 25 @interface NSAutoreleasePool : NSObject {} - (void)drain; @end method
37 [pool drain];
|
| D | PR2599.m | 37 - (void)drain; method
61 [pool drain];
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-stream.rst | 254 be followed by :meth:`drain`.
261 should be followed by :meth:`drain`.
263 .. coroutinemethod:: drain()
269 await writer.drain()
273 the high watermark, *drain()* blocks until the size of the
275 be resumed. When there is nothing to wait for, the :meth:`drain`
351 await writer.drain()
|
| /external/u-boot/arch/arm/dts/ |
| D | tegra124-nyan-big.dts | 202 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
210 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
491 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
499 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
794 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
802 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
1070 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
1078 nvidia,open-drain = <TEGRA_PIN_ENABLE>;
1149 nvidia,open-drain = <TEGRA_PIN_DISABLE>;
1157 nvidia,open-drain = <TEGRA_PIN_DISABLE>;
[all …]
|
| /external/libvpx/libvpx/vp8/encoder/ |
| D | lookahead.c | 148 int drain) { in vp8_lookahead_pop() argument
152 if (ctx->sz && (drain || ctx->sz == ctx->max_sz - 1)) { in vp8_lookahead_pop()
|
| D | lookahead.h | 74 struct lookahead_entry *vp8_lookahead_pop(struct lookahead_ctx *ctx, int drain);
|
| /external/libvpx/libvpx/vp9/encoder/ |
| D | vp9_lookahead.c | 191 int drain) { in vp9_lookahead_pop() argument
194 if (ctx && ctx->sz && (drain || ctx->sz == ctx->max_sz - MAX_PRE_FRAMES)) { in vp9_lookahead_pop()
|
| /external/catch2/include/internal/ |
| D | catch_default_main.hpp | 38 [pool drain];
|
| /external/libaom/libaom/av1/encoder/ |
| D | lookahead.c | 187 int drain) { in av1_lookahead_pop() argument
190 if (ctx && ctx->sz && (drain || ctx->sz == ctx->max_sz - MAX_PRE_FRAMES)) { in av1_lookahead_pop()
|
| D | lookahead.h | 85 struct lookahead_entry *av1_lookahead_pop(struct lookahead_ctx *ctx, int drain);
|