| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | EventLoop.kt | 9 internal actual fun createEventLoop(): EventLoop = UnconfinedEventLoop() in createEventLoop()
13 internal class UnconfinedEventLoop : EventLoop() { in createEventLoop()
17 internal actual abstract class EventLoopImplPlatform : EventLoop() {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 35 val eventLoop: EventLoop? in runBlocking()
44 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
55 private val eventLoop: EventLoop?
|
| D | EventLoop.kt | 10 internal actual abstract class EventLoopImplPlatform: EventLoop() {
21 internal actual fun createEventLoop(): EventLoop = EventLoopImpl()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 23 internal abstract class EventLoop : CoroutineDispatcher() { in <lambda>() class
123 private val ref = CommonThreadLocal<EventLoop?>()
125 internal val eventLoop: EventLoop
128 internal fun currentOrNull(): EventLoop? = in currentOrNull()
135 internal fun setEventLoop(eventLoop: EventLoop) { in setEventLoop()
171 internal expect abstract class EventLoopImplPlatform() : EventLoop { in delayNanosToMillis()
521 internal expect fun createEventLoop(): EventLoop in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 44 val eventLoop: EventLoop? in runBlocking()
53 eventLoop = (contextInterceptor as? EventLoop)?.takeIf { it.shouldBeProcessedFromContext() } in runBlocking()
65 private val eventLoop: EventLoop?
|
| D | EventLoop.kt | 7 internal actual abstract class EventLoopImplPlatform: EventLoop() {
26 internal actual fun createEventLoop(): EventLoop = BlockingEventLoop(Thread.currentThread())
|
| /external/crosvm/devices/src/utils/ |
| D | event_loop.rs | 42 pub struct EventLoop { struct
54 impl EventLoop { argument
59 ) -> Result<(EventLoop, thread::JoinHandle<()>)> { in start() argument
77 let event_loop = EventLoop { in start()
221 let (l, j) = EventLoop::start("test".to_string(), None).unwrap(); in event_loop_test()
|
| D | async_job_queue.rs | 6 use super::{EventHandler, EventLoop};
20 pub fn init(event_loop: &EventLoop) -> Result<Arc<AsyncJobQueue>> { in init()
|
| /external/crosvm/devices/src/usb/xhci/ |
| D | xhci_backend_device_provider.rs | 7 use crate::utils::{EventLoop, FailHandle};
17 event_loop: Arc<EventLoop>, in start() argument
|
| D | intr_resample_handler.rs | 6 use crate::utils::{EventHandler, EventLoop};
20 event_loop: &EventLoop, in start() argument
|
| D | transfer_ring_controller.rs | 8 use crate::utils::EventLoop;
69 event_loop: Arc<EventLoop>, in new() argument
|
| D | ring_buffer_controller.rs | 7 use crate::utils::{self, EventHandler, EventLoop};
79 event_loop: Arc<EventLoop>,
97 event_loop: Arc<EventLoop>, in new_with_handler() argument
323 let (l, j) = EventLoop::start("test".to_string(), None).unwrap(); in test_ring_buffer_controller()
|
| D | xhci.rs | 17 use crate::utils::{Error as UtilsError, EventLoop, FailHandle};
73 event_loop: Arc<EventLoop>,
95 EventLoop::start("xhci".to_string(), Some(fail_handle.clone())) in new()
|
| D | device_slot.rs | 17 use crate::utils::{EventLoop, FailHandle};
98 event_loop: Arc<EventLoop>, in new() argument
251 event_loop: Arc<EventLoop>,
264 event_loop: Arc<EventLoop>, in new() argument
|
| D | command_ring_controller.rs | 17 use crate::utils::EventLoop;
67 event_loop: Arc<EventLoop>, in new() argument
|
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 13 use crate::utils::{EventHandler, EventLoop, FailHandle};
56 event_loop: Arc<EventLoop>, in start_helper() argument
97 event_loop: Arc<EventLoop>, in start() argument
122 event_loop: Arc<EventLoop>,
139 event_loop: Arc<EventLoop>, in new() argument
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 48 import io.netty.channel.EventLoop;
128 EventLoop eventLoop;
135 public EventLoop eventLoop() { in eventLoop()
143 EventLoop realEventLoop = super.eventLoop(); in createEventLoop()
147 eventLoop = mock(EventLoop.class, delegatesTo(realEventLoop)); in createEventLoop()
166 EventLoop eventLoop, final Runnable command, long delay, TimeUnit timeUnit) { in FakeClockScheduledNettyFuture()
336 EventLoop eventLoop = mock(EventLoop.class); in newMockContext()
|
| D | WriteQueueTest.java | 32 import io.netty.channel.EventLoop;
72 EventLoop eventLoop = Mockito.mock(EventLoop.class); in setUp()
|
| D | NettyStreamTestBase.java | 41 import io.netty.channel.EventLoop;
71 protected EventLoop eventLoop;
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerStream.java | 33 import io.netty.channel.EventLoop;
159 private final EventLoop eventLoop;
163 EventLoop eventLoop, in TransportState()
|
| D | NettyClientStream.java | 41 import io.netty.channel.EventLoop;
213 private final EventLoop eventLoop;
219 EventLoop eventLoop, in TransportState()
|
| D | NettyClientTransport.java | 49 import io.netty.channel.EventLoop;
189 EventLoop eventLoop = group.next();
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | RunBlockingTest.kt | 29 assertTrue(coroutineContext[ContinuationInterceptor] is EventLoop) in testPrivateEventLoop()
41 val outerEventLoop = coroutineContext[ContinuationInterceptor] as EventLoop in testOuterEventLoop()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test-resources/stacktraces/timeout/ |
| D | testStacktraceIsRecoveredFromSuspensionPoint.txt | 10 at kotlinx.coroutines.EventLoopImplBase$DelayedRunnableTask.run(EventLoop.common.kt:492)
|
| /external/rust/crates/mio/ |
| D | CHANGELOG.md | 418 * `EventLoop` and types to `deprecated` mod. All contents of the
444 * Renamed `EventLoop::register_opt` to `EventLoop::register` (#257)
456 * Mio's socket types are permanently associated with an EventLoop (#308)
466 * [BUGFIX] EventLoop::register requests all events, not just readable.
|