/ohos5.0/base/startup/init/services/loopevent/loop/ |
H A D | le_epoll.c | 43 close(epoll->epollFd); in Close_() 44 free(epoll); in Close_() 57 if (IsValid_(epoll) && fd >= 0) { in AddEvent_() 73 if (IsValid_(epoll) && fd >= 0) { in ModEvent_() 100 if (!IsValid_(epoll)) { in RunLoop_() 117 int number = epoll_wait(epoll->epollFd, epoll->waitEvents, loop->maxevents, timeout); in RunLoop_() 148 LE_CHECK(epoll->epollFd >= 0, free(epoll); in CreateEpollLoop() 151 *loop = (EventLoop *)epoll; in CreateEpollLoop() 153 epoll->loop.timeout = timeout; in CreateEpollLoop() 154 epoll->loop.close = Close_; in CreateEpollLoop() [all …]
|
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/test/src/ |
H A D | lib.rs | 163 let epoll = Arc::new(EpollHandler::new()); in test_add_epoll_handler() localVariable 167 epoll.signal(data); in test_add_epoll_handler() 168 assert!(epoll.wait(Duration::from_millis(100))); in test_add_epoll_handler() 170 assert_eq!(epoll.data(), data); in test_add_epoll_handler() 211 let epoll = Arc::new(EpollHandler::new()); in test_post_perioric_task() localVariable 212 let cloned_epoll = epoll.clone(); in test_post_perioric_task() 222 assert!(epoll.data() >= 10); in test_post_perioric_task() 230 let epoll = Arc::new(EpollHandler::new()); in test_post_delayed_task() localVariable 233 let cloned_epoll = epoll.clone(); in test_post_delayed_task() 239 assert!(epoll.wait(Duration::from_millis(100))); in test_post_delayed_task() [all …]
|
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
H A D | scheduler.rs | 121 epoll: Arc<Epoll>, field 128 Self { epoll, is_running } in new() 146 self.epoll.wake(&epoll_events); in run() 370 epoll: Arc<Epoll>, field 374 fn new(fd: RawFd, epoll: Arc<Epoll>) -> Self in new() 376 Self { fd, epoll } in new() 386 self.epoll.dispatch(self.fd, cx.waker()); in poll() 479 epoll: Arc<Epoll>, field 489 let epoll: Arc<Epoll> = Arc::default(); in new() localVariable 496 epoll, in new() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
H A D | mod.rs | 41 mod epoll; module 43 pub use epoll::{Event, Events, Selector};
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ |
H A D | README_zh.md | 12 - `ylong_io`:依赖 `libc` 库,结合系统的 epoll 机制,实现了非阻塞 TCP 和 UDP 功能,作为 `ylong_runtime` 异步 IO 的底座; 14 - `Kernel`:操作系统内核提供的能力,如 socket,epoll 等。 21 - `ylong_io`:提供了事件驱动型网络 IO,通过 epoll 实现了非阻塞性的 TCP 和 UDP。用户无需直接依赖该库。
|
H A D | README.md | 12 …- `ylong_io`: Relying on the `libc` library, combined with the epoll mechanism of the system, prov… 14 - `Kernel`: Capabilities provided by the operating system kernel, such as socket, epoll, etc. 21 - `ylong_io`: Provides nonblocking and event-driven TCP/UDP through epoll. Users do not need to dir…
|
/ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/ |
H A D | BUILD.gn | 89 "${device_status_root_path}/intention/common/epoll:intention_epoll", 136 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/base/msdp/device_status/intention/ipc/socket/ |
H A D | BUILD.gn | 90 "${device_status_root_path}/intention/common/epoll:intention_epoll", 137 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/ |
H A D | Cargo.toml | 8 keywords = ["ylong", "io", "epoll"]
|
/ohos5.0/base/msdp/device_status/services/ |
H A D | BUILD.gn | 122 "${device_status_root_path}/intention/common/epoll:intention_epoll", 194 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/foundation/multimodalinput/input/intention/services/device_manager/ |
H A D | BUILD.gn | 56 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/base/msdp/device_status/intention/services/device_manager/ |
H A D | BUILD.gn | 55 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/base/msdp/device_status/test/unittest/intention/common/ |
H A D | BUILD.gn | 54 "${device_status_root_path}/intention/common/epoll:intention_epoll",
|
/ohos5.0/base/startup/init/ |
H A D | README_zh.md | 34 │ │ ├── loop # 基于epoll封装的I/O多路复用接口
|
/ohos5.0/base/msdp/device_status/test/unittest/intention/cooperate/ |
H A D | BUILD.gn | 286 "${device_status_root_path}/intention/common/epoll/include", 351 "${device_status_root_path}/intention/common/epoll/include",
|
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/ |
H A D | BUILD.gn | 53 "src/public/src/epoll.c",
|
/ohos5.0/commonlibrary/c_utils/docs/zh-cn/ |
H A D | c_utils_guide_event.md | 3 事件处理系统。c_utils提供基于Reactor模式,以epoll为后台多路复用机制,通过文件描述符fd实现对各I/O设备的基于事件的异步处理机制。
|
/ohos5.0/docs/zh-cn/application-dev/ffrt/ |
H A D | ffrt-development-guideline.md | 2145 #include <sys/epoll.h>
|
/ohos5.0/docs/zh-cn/device-dev/porting/ |
H A D | porting-yangfan-on_standard-demo.md | 1348 #include <sys/epoll.h>
|
/ohos5.0/docs/en/application-dev/ffrt/ |
H A D | ffrt-development-guideline.md | 2151 #include <sys/epoll.h>
|
/ohos5.0/docs/en/device-dev/porting/ |
H A D | porting-yangfan-on_standard-demo.md | 1346 #include <sys/epoll.h>
|