| /external/kotlinx.coroutines/kotlinx-coroutines-core/jsAndWasmJsShared/src/ |
| D | EventLoop.kt | 5 internal actual fun createEventLoop(): EventLoop = UnconfinedEventLoop() in createEventLoop()
9 internal class UnconfinedEventLoop : EventLoop() { in createEventLoop()
13 internal actual abstract class EventLoopImplPlatform : EventLoop() {
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| D | HandlerSubscriberTest.java | 26 import io.netty.channel.EventLoop;
119 protected boolean isCompatible(EventLoop loop) { in isCompatible()
129 … private static class CustomEmbeddedEventLoop extends AbstractEventExecutor implements EventLoop {
139 public EventLoop next() { in next()
140 return (EventLoop) super.next(); in next()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 19 internal abstract class EventLoop : CoroutineDispatcher() { in <lambda>() class
123 private val ref = commonThreadLocal<EventLoop?>(Symbol("ThreadLocalEventLoop"))
125 internal val eventLoop: EventLoop
128 internal fun currentOrNull(): EventLoop? = in currentOrNull()
135 internal fun setEventLoop(eventLoop: EventLoop) { in setEventLoop()
169 internal expect abstract class EventLoopImplPlatform() : EventLoop { in delayNanosToMillis()
529 internal expect fun createEventLoop(): EventLoop in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 54 val eventLoop: EventLoop? in runBlocking()
63 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
75 private val eventLoop: EventLoop?
|
| D | EventLoop.kt | 7 internal actual abstract class EventLoopImplPlatform: EventLoop() {
26 internal actual fun createEventLoop(): EventLoop = BlockingEventLoop(Thread.currentThread()) in createEventLoop()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 50 val eventLoop: EventLoop? in runBlocking()
59 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
108 private val eventLoop: EventLoop?
|
| D | EventLoop.kt | 9 internal actual abstract class EventLoopImplPlatform : EventLoop() {
28 internal actual fun createEventLoop(): EventLoop = EventLoopImpl()
|
| /external/crosvm/devices/src/usb/xhci/ |
| D | xhci_backend_device_provider.rs | 11 use crate::utils::EventLoop;
20 event_loop: Arc<EventLoop>, in start() argument
|
| D | intr_resample_handler.rs | 16 use crate::utils::EventLoop;
27 event_loop: &EventLoop, in start() argument
|
| D | transfer_ring_controller.rs | 21 use crate::utils::EventLoop;
81 event_loop: Arc<EventLoop>, in new() argument
|
| D | ring_buffer_controller.rs | 28 use crate::utils::EventLoop;
85 event_loop: Arc<EventLoop>,
103 event_loop: Arc<EventLoop>, in new_with_handler() argument
331 let (l, j) = EventLoop::start("test".to_string(), None).unwrap(); in test_ring_buffer_controller()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | Http1TunnelConnectionPool.java | 23 import io.netty.channel.EventLoop;
48 private final EventLoop eventLoop;
59 … public Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
67 … public Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
77 Http1TunnelConnectionPool(EventLoop eventLoop, ChannelPool delegate, SslContext sslContext, in Http1TunnelConnectionPool()
|
| /external/crosvm/devices/src/utils/ |
| D | event_loop.rs | 49 pub struct EventLoop { struct
61 impl EventLoop { implementation
66 ) -> Result<(EventLoop, thread::JoinHandle<()>)> { in start() argument
81 let event_loop = EventLoop { in start()
260 let (l, j) = EventLoop::start("test".to_string(), None).unwrap(); in event_loop_test()
|
| D | async_job_queue.rs | 15 use super::EventLoop;
26 pub fn init(event_loop: &EventLoop) -> Result<Arc<AsyncJobQueue>> { in init()
|
| /external/crosvm/devices/src/usb/backend/ |
| D | device_provider.rs | 34 use crate::utils::EventLoop;
69 event_loop: Arc<EventLoop>, in start_helper() argument
110 event_loop: Arc<EventLoop>, in start() argument
133 event_loop: Arc<EventLoop>,
150 event_loop: Arc<EventLoop>, in new() argument
|
| /external/crosvm/devices/src/usb/backend/fido_backend/ |
| D | fido_provider.rs | 18 use crate::utils::EventLoop;
24 event_loop: Arc<EventLoop>, in attach_security_key() argument
|
| D | fido_device.rs | 27 use crate::utils::EventLoop;
75 event_loop: Arc<EventLoop>,
89 pub fn new(hidraw: File, event_loop: Arc<EventLoop>) -> Result<FidoDevice> { in new()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/util/ |
| D | ClosedLoopChannel.java | 26 import io.netty.channel.EventLoop;
73 protected boolean isCompatible(EventLoop loop) {
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 49 import io.netty.channel.EventLoop;
133 EventLoop eventLoop;
140 public EventLoop eventLoop() { in eventLoop()
148 EventLoop realEventLoop = super.eventLoop(); in createEventLoop()
152 eventLoop = mock(EventLoop.class, delegatesTo(realEventLoop)); in createEventLoop()
171 EventLoop eventLoop, final Runnable command, long delay, TimeUnit timeUnit) { in FakeClockScheduledNettyFuture()
347 EventLoop eventLoop = mock(EventLoop.class); in newMockContext()
|
| D | WriteQueueTest.java | 32 import io.netty.channel.EventLoop;
74 EventLoop eventLoop = Mockito.mock(EventLoop.class); in setUp()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 33 import io.netty.channel.EventLoop;
157 private final EventLoop eventLoop;
162 EventLoop eventLoop, in TransportState()
|
| D | NettyClientStream.java | 43 import io.netty.channel.EventLoop;
229 private final EventLoop eventLoop;
236 EventLoop eventLoop, in TransportState()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/wasmWasi/src/ |
| D | EventLoop.kt | 16 internal actual fun createEventLoop(): EventLoop = DefaultExecutor in <lambda>()
57 internal actual abstract class EventLoopImplPlatform : EventLoop() { in invokeOnTimeout()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | NettyRequestExecutorTest.java | 32 import io.netty.channel.EventLoop;
107 EventLoop mockEventLoop = mock(EventLoop.class); in cancelExecuteFuture_channelAcquired_submitsRunnable()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| D | RunBlockingTest.kt | 29 assertIs<EventLoop>(coroutineContext[ContinuationInterceptor]) in testPrivateEventLoop()
41 val outerEventLoop = coroutineContext[ContinuationInterceptor] as EventLoop in testOuterEventLoop()
|