Searched refs:waiters (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | schedule_io.rs | 47 waiters: Mutex<Waiters>, field
139 let mut waiters = self.waiters.lock().unwrap(); in poll_readiness() localVariable
253 let mut waiters = self.waiters.lock().unwrap(); in wake0() localVariable
279 drop(waiters); in wake0()
343 let mut waiters = schedule_io.waiters.lock().unwrap(); in poll_init() localVariable
348 if waiters.is_shutdown { in poll_init()
364 waiters in poll_init()
381 let waiters = schedule_io.waiters.lock().unwrap(); in set_waker() localVariable
394 drop(waiters); in set_waker()
450 let mut waiters = self.schedule_io.waiters.lock().unwrap(); in drop() localVariable
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/support/platform/src/fwk/ |
| H A D | platform_event.c | 38 DListHeadInit(&pe->waiters); in PlatformEventInit()
60 DLIST_FOR_EACH_ENTRY_SAFE(waiter, tmp, &pe->waiters, struct PlatformEventWaiter, node) { in PlatformEventClearWaiters()
97 DLIST_FOR_EACH_ENTRY_SAFE(pos, tmp, &pe->waiters, struct PlatformEventWaiter, node) { in PlatformEventPost()
170 DListInsertTail(&waiter.node, &pe->waiters); in PlatformEventReadSlowlly()
253 DListInsertTail(&waiter->node, &pe->waiters); in PlatformEventListen()
269 DLIST_FOR_EACH_ENTRY_SAFE(waiter, tmp, &pe->waiters, struct PlatformEventWaiter, node) { in PlatformEventUnlisten()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | array.rs | 44 waiters: WakerList, field
71 waiters: WakerList::new(), in new()
155 self.waiters.notify_one(); in try_recv()
192 self.waiters.notify_all(); in close()
240 self.array.waiters.insert(cx.waker().clone()); in poll()
248 self.array.waiters.notify_one(); in poll()
|
| /ohos5.0/drivers/hdf_core/framework/support/platform/include/fwk/ |
| H A D | platform_event.h | 27 struct DListHead waiters; member
|