| /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 | 44 val eventLoop: EventLoop? in runBlocking() constant
48 eventLoop = ThreadLocalEventLoop.eventLoop in runBlocking()
49 newContext = GlobalScope.newCoroutineContext(context + eventLoop) in runBlocking()
53 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
57 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking()
65 private val eventLoop: EventLoop? constant
79 eventLoop?.incrementUseCount() in joinBlocking()
84 val parkNanos = eventLoop?.processNextEvent() ?: Long.MAX_VALUE in joinBlocking()
90 eventLoop?.decrementUseCount() in joinBlocking()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | DispatchedTask.kt | 183 val eventLoop = ThreadLocalEventLoop.eventLoop in resumeUnconfined() constant
184 if (eventLoop.isUnconfinedLoopActive) { in resumeUnconfined()
186 eventLoop.dispatchUnconfined(this) in resumeUnconfined()
189 runUnconfinedEventLoop(eventLoop) { in resumeUnconfined()
196 eventLoop: EventLoop, in runUnconfinedEventLoop()
199 eventLoop.incrementUseCount(unconfined = true) in runUnconfinedEventLoop()
204 if (!eventLoop.processUnconfinedEvent()) break in runUnconfinedEventLoop()
213 eventLoop.decrementUseCount(unconfined = true) in runUnconfinedEventLoop()
|
| D | DispatchedContinuation.kt | 285 val eventLoop = ThreadLocalEventLoop.eventLoop in executeUnconfined() constant
287 if (doYield && eventLoop.isUnconfinedQueueEmpty) return false in executeUnconfined()
288 return if (eventLoop.isUnconfinedLoopActive) { in executeUnconfined()
292 eventLoop.dispatchUnconfined(this) in executeUnconfined()
296 runUnconfinedEventLoop(eventLoop, block = block) in executeUnconfined()
|
| /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 | 165 channel.eventLoop(), in newStream()
189 EventLoop eventLoop = group.next();
192 new ClientKeepAlivePinger(this), eventLoop, keepAliveTimeNanos, keepAliveTimeoutNanos,
211 b.group(eventLoop);
336 if (channel.eventLoop().inEventLoop()) {
342 channel.eventLoop().submit(
362 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()
|
| /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 | NettyServerStreamTest.java | 289 handler, channel.eventLoop(), http2Stream, DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, in createStream()
|
| D | NettyClientTransportTest.java | 265 transport.channel().eventLoop().execute(new Runnable() { in negotiationFailurePropagatesToStatus()
347 transport.channel().eventLoop().execute(new Runnable() { in handlerExceptionDuringNegotiatonPropagatesToStatus()
|
| D | NettyClientStreamTest.java | 549 super(handler, channel.eventLoop(), maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 125 internal val eventLoop: EventLoop constant
135 internal fun setEventLoop(eventLoop: EventLoop) { in setEventLoop()
136 ref.set(eventLoop) in setEventLoop()
431 fun scheduleTask(now: Long, delayed: DelayedTaskQueue, eventLoop: EventLoopImplBase): Int { in timeToExecute()
434 … if (eventLoop.isCompleted) return SCHEDULE_COMPLETED // non-local return from scheduleTask in timeToExecute()
|
| /external/flatbuffers/tests/FlatBuffers.GRPC.Swift/Sources/server/ |
| D | main.swift | 48 return context.eventLoop.makeSucceededFuture(Message<HelloReply>(builder: &builder))
59 return context.eventLoop.makeSucceededFuture(.ok)
|
| /external/llvm-project/lldb/utils/lui/ |
| D | debuggerdriver.py | 110 def eventLoop(self): member in DebuggerDriver
123 self.eventLoop()
|
| D | sandbox.py | 71 sandbox.eventLoop()
|
| D | lui.py | 146 view.eventLoop()
|
| D | cui.py | 222 def eventLoop(self): member in CursesUI
|
| /external/python/pycparser/utils/benchmark/inputs/ |
| D | redis.c.ppout | 1746 typedef void aeFileProc(struct aeEventLoop *eventLoop, int fd, void *clientData, int mask);
1747 typedef int aeTimeProc(struct aeEventLoop *eventLoop, long long id, void *clientData);
1748 typedef void aeEventFinalizerProc(struct aeEventLoop *eventLoop, void *clientData);
1749 typedef void aeBeforeSleepProc(struct aeEventLoop *eventLoop);
1793 void aeDeleteEventLoop(aeEventLoop *eventLoop);
1794 void aeStop(aeEventLoop *eventLoop);
1795 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
1797 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask);
1798 int aeGetFileEvents(aeEventLoop *eventLoop, int fd);
1799 long long aeCreateTimeEvent(aeEventLoop *eventLoop, long long milliseconds,
[all …]
|