| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 35 val eventLoop: EventLoop? in runBlocking() constant
39 eventLoop = ThreadLocalEventLoop.eventLoop in runBlocking()
40 newContext = GlobalScope.newCoroutineContext(context + eventLoop) in runBlocking()
44 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
48 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking()
55 private val eventLoop: EventLoop? constant
62 eventLoop?.incrementUseCount() in <lambda>()
65 val parkNanos = eventLoop?.processNextEvent() ?: Long.MAX_VALUE in <lambda>()
73 eventLoop?.decrementUseCount() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 39 val eventLoop: EventLoop? in runBlocking() constant
43 eventLoop = ThreadLocalEventLoop.eventLoop in runBlocking()
44 newContext = GlobalScope.newCoroutineContext(context + eventLoop) in runBlocking()
48 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
52 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking()
60 private val eventLoop: EventLoop? constant
74 eventLoop?.incrementUseCount() in joinBlocking()
79 val parkNanos = eventLoop?.processNextEvent() ?: Long.MAX_VALUE in joinBlocking()
85 eventLoop?.decrementUseCount() in joinBlocking()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Dispatched.kt | 25 val eventLoop = ThreadLocalEventLoop.eventLoop in executeUnconfined() constant
27 if (doYield && eventLoop.isUnconfinedQueueEmpty) return false in executeUnconfined()
28 return if (eventLoop.isUnconfinedLoopActive) { in executeUnconfined()
32 eventLoop.dispatchUnconfined(this) in executeUnconfined()
36 runUnconfinedEventLoop(eventLoop, block = block) in executeUnconfined()
42 val eventLoop = ThreadLocalEventLoop.eventLoop in resumeUnconfined() constant
43 if (eventLoop.isUnconfinedLoopActive) { in resumeUnconfined()
45 eventLoop.dispatchUnconfined(this) in resumeUnconfined()
48 runUnconfinedEventLoop(eventLoop) { in resumeUnconfined()
55 eventLoop: EventLoop, in runUnconfinedEventLoop()
[all …]
|
| D | EventLoop.common.kt | 124 internal val eventLoop: EventLoop constant
134 internal fun setEventLoop(eventLoop: EventLoop) { in setEventLoop()
135 ref.set(eventLoop) in setEventLoop()
425 fun scheduleTask(now: Long, delayed: DelayedTaskQueue, eventLoop: EventLoopImplBase): Int { in timeToExecute()
428 … if (eventLoop.isCompleted) return SCHEDULE_COMPLETED // non-local return from scheduleTask in timeToExecute()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 93 if (channel.eventLoop().inEventLoop()) { in request()
97 channel.eventLoop().execute(new Runnable() { in request()
159 private final EventLoop eventLoop; field in NettyServerStream.TransportState
163 EventLoop eventLoop, in TransportState() argument
171 this.eventLoop = eventLoop; in TransportState()
176 if (eventLoop.inEventLoop()) { in runOnTransportThread()
179 eventLoop.execute(r); in runOnTransportThread()
|
| D | NettyClientStream.java | 190 if (channel.eventLoop().inEventLoop()) { in request()
194 channel.eventLoop().execute(new Runnable() { in request()
213 private final EventLoop eventLoop; field in NettyClientStream.TransportState
219 EventLoop eventLoop, in TransportState() argument
225 this.eventLoop = checkNotNull(eventLoop, "eventLoop"); in TransportState()
275 if (eventLoop.inEventLoop()) { in runOnTransportThread()
278 eventLoop.execute(r); in runOnTransportThread()
|
| D | NettyClientTransport.java | 161 channel.eventLoop(), in newStream()
185 EventLoop eventLoop = group.next();
188 new ClientKeepAlivePinger(this), eventLoop, keepAliveTimeNanos, keepAliveTimeoutNanos,
207 b.group(eventLoop);
326 if (channel.eventLoop().inEventLoop()) {
332 channel.eventLoop().submit(
352 assert ch.eventLoop().inEventLoop();
|
| D | NettyServerTransport.java | 147 return channel.eventLoop(); in getScheduledExecutorService()
205 if (channel.eventLoop().inEventLoop()) { in getStats()
211 channel.eventLoop().submit( in getStats()
231 Preconditions.checkState(ch.eventLoop().inEventLoop()); in getStatsHelper()
|
| D | NettyServer.java | 256 Future<?> channelzFuture = channel.eventLoop().submit(new Runnable() { in start()
356 if (ch.eventLoop().inEventLoop()) { in getStats()
367 ch.eventLoop() in getStats()
|
| D | WriteQueue.java | 65 channel.eventLoop().execute(later); in scheduleFlush()
|
| D | NettyServerHandler.java | 424 ctx.channel().eventLoop(), in onHeadersRead()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 128 EventLoop eventLoop; field in NettyHandlerTestBase.FakeClockSupportedChanel
135 public EventLoop eventLoop() { in eventLoop() method in NettyHandlerTestBase.FakeClockSupportedChanel
136 if (eventLoop == null) { in eventLoop()
139 return eventLoop; in eventLoop()
143 EventLoop realEventLoop = super.eventLoop(); in createEventLoop()
147 eventLoop = mock(EventLoop.class, delegatesTo(realEventLoop)); in createEventLoop()
155 return new FakeClockScheduledNettyFuture(eventLoop, command, delay, timeUnit); in createEventLoop()
157 }).when(eventLoop).schedule(any(Runnable.class), anyLong(), any(TimeUnit.class)); in createEventLoop()
166 EventLoop eventLoop, final Runnable command, long delay, TimeUnit timeUnit) { in FakeClockScheduledNettyFuture() argument
167 super(eventLoop); in FakeClockScheduledNettyFuture()
[all …]
|
| D | WriteQueueTest.java | 72 EventLoop eventLoop = Mockito.mock(EventLoop.class); in setUp() local
80 }).when(eventLoop).execute(any(Runnable.class)); in setUp()
81 when(eventLoop.inEventLoop()).thenReturn(true); in setUp()
82 when(channel.eventLoop()).thenReturn(eventLoop); in setUp()
|
| D | NettyStreamTestBase.java | 71 protected EventLoop eventLoop; field in NettyStreamTestBase
93 when(channel.eventLoop()).thenReturn(eventLoop); in setUp()
102 when(eventLoop.inEventLoop()).thenReturn(true); in setUp()
112 }).when(eventLoop).execute(any(Runnable.class)); in setUp()
|
| D | ProtocolNegotiatorsTest.java | 333 channel.eventLoop().submit(NOOP_RUNNABLE).sync(); in httpProxy_completes()
349 channel.eventLoop().submit(NOOP_RUNNABLE).sync(); in httpProxy_completes()
364 channel.eventLoop().submit(NOOP_RUNNABLE).sync(); in httpProxy_completes()
397 channel.eventLoop().submit(NOOP_RUNNABLE).sync(); in httpProxy_500()
413 channel.eventLoop().submit(NOOP_RUNNABLE).sync(); in httpProxy_500()
|
| D | NettyClientHandlerTest.java | 171 channel().eventLoop(), in setUp()
515 channel().eventLoop(), in createIncrementsIdsForActualAndBufferdStreams()
524 channel().eventLoop(), in createIncrementsIdsForActualAndBufferdStreams()
760 EventLoop eventLoop, in TransportStateImpl() argument
763 super(handler, eventLoop, maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
|
| D | NettyClientTransportTest.java | 259 transport.channel().eventLoop().execute(new Runnable() { in negotiationFailurePropagatesToStatus()
341 transport.channel().eventLoop().execute(new Runnable() { in handlerExceptionDuringNegotiatonPropagatesToStatus()
|
| D | NettyServerStreamTest.java | 289 handler, channel.eventLoop(), http2Stream, DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, in createStream()
|
| D | NettyClientStreamTest.java | 549 super(handler, channel.eventLoop(), maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
|