| /base/startup/init/services/loopevent/loop/ |
| H A D | le_epoll.c | 41 EventEpoll *epoll = (EventEpoll *)loop; in Close_() local
42 LE_LOGV("Close_ epollFd %d", epoll->epollFd); in Close_()
43 close(epoll->epollFd); in Close_()
44 free(epoll); in Close_()
51 EventEpoll *epoll = (EventEpoll *)loop; in AddEvent_() local
57 if (IsValid_(epoll) && fd >= 0) { in AddEvent_()
58 ret = epoll_ctl(epoll->epollFd, EPOLL_CTL_ADD, fd, &event); in AddEvent_()
67 EventEpoll *epoll = (EventEpoll *)loop; in ModEvent_() local
73 if (IsValid_(epoll) && fd >= 0) { in ModEvent_()
74 ret = epoll_ctl(epoll in ModEvent_()
83 EventEpoll *epoll = (EventEpoll *)loop; DelEvent_() local
99 EventEpoll *epoll = (EventEpoll *)loop; RunLoop_() local
148 EventEpoll *epoll = (EventEpoll *)malloc(sizeof(EventEpoll) + sizeof(struct epoll_event) * (maxevents)); CreateEpollLoop() local
[all...] |
| H A D | le_epoll.h | 17 #include <sys/epoll.h>
|
| /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()
164 assert!(handler.add_epoll_handler(epoll.clone()).is_ok()); in test_add_epoll_handler()
167 epoll.signal(data); in test_add_epoll_handler()
168 assert!(epoll.wait(Duration::from_millis(100))); in test_add_epoll_handler()
169 info!(LOG_LABEL, "In test_add_epoll_handler, data:{}", @public(epoll.data())); in test_add_epoll_handler()
170 assert_eq!(epoll.data(), data); in test_add_epoll_handler()
171 assert!(handler.remove_epoll_handler(epoll).is_ok()); in test_add_epoll_handler()
211 let epoll = Arc::new(EpollHandler::new()); in test_post_perioric_task()
212 let cloned_epoll = epoll.clone(); in test_post_perioric_task()
213 assert!(handler.add_epoll_handler(epoll in test_post_perioric_task()
[all...] |
| /base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | scheduler.rs | 16 //! Implementation of epoll event loop.
54 /// Abstraction of epoll handler.
56 /// Return file descriptor of this epoll handler.
58 /// Dispatch epoll events to this epoll handler.
119 /// `Driver` encapsulate event loop of epoll.
121 epoll: Arc<Epoll>,
126 fn new(epoll: Arc<Epoll>, is_running: Arc<AtomicBool>) -> Self in new()
128 Self { epoll, is_running } in new()
141 if let Some(epoll_events) = self.epoll in run()
[all...] |
| /base/msdp/device_status/intention/prototype/include/ |
| H A D | i_epoll_event_source.h | 19 #include <sys/epoll.h>
|
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| H A D | ffrt_descriptor_listener.h | 22 #include <sys/epoll.h>
|
| H A D | epoll_io_waiter.h | 23 #include <sys/epoll.h>
34 // Use epoll to listen file descriptor.
42 * Initialize epoll.
66 // File descriptor for epoll.
68 // File descriptor used to wake up epoll.
|
| H A D | deamon_io_waiter.h | 23 #include <sys/epoll.h>
34 // Use epoll to listen file descriptor.
43 * Initialize epoll.
69 // File descriptor for epoll.
71 // File descriptor used to wake up epoll.
|
| /base/msdp/device_status/utils/ipc/include/ |
| H A D | stream_socket.h | 24 #include <sys/epoll.h>
|
| /base/hiviewdfx/hiview/base/test/unittest/common/ |
| H A D | event_loop_test.h | 19 #include <sys/epoll.h>
|
| /base/hiviewdfx/hiview/plugins/reliability/leak_detectors/ |
| H A D | fault_detector_manager.cpp | 21 #include <sys/epoll.h>
|
| /base/msdp/device_status/intention/services/device_manager/src/ |
| H A D | monitor.cpp | 21 #include <sys/epoll.h>
|
| H A D | device_manager.cpp | 23 #include <sys/epoll.h>
|
| /base/hiviewdfx/hiview/test/plugins/examples_bundle/bundle_event_source_example/ |
| H A D | bundle_event_source_example.cpp | 23 #include <sys/epoll.h>
|
| /base/powermgr/thermal_manager/application/protector/src/ |
| H A D | thermal_protector_timer.cpp | 22 #include <sys/epoll.h>
56 THERMAL_HILOGE(FEATURE_PROTECTOR, "epoll create failed, epFd_ is invalid"); in CreateProvisionFd()
|
| H A D | thermal_sensor_provision.cpp | 31 #include <sys/epoll.h>
|
| H A D | thermal_sensor_provider.cpp | 22 #include <sys/epoll.h>
126 THERMAL_HILOGE(FEATURE_PROTECTOR, "epoll create failed, epFd_ is invalid"); in CreateProviderFd()
|
| /base/msdp/device_status/libs/src/ |
| H A D | devicestatus_algorithm_manager.cpp | 23 #include <sys/epoll.h>
|
| H A D | devicestatus_msdp_mock.cpp | 22 #include <sys/epoll.h>
128 FI_HILOGE("Create epoll fd failed"); in InitTimer()
135 FI_HILOGE("Close epoll fd failed, error:%{public}s, epFd_:%{public}d", strerror(errno), epFd_); in InitTimer()
|
| /base/powermgr/battery_manager/charger/src/ |
| H A D | battery_thread.cpp | 18 #include <sys/epoll.h>
124 BATTERY_HILOGE(FEATURE_CHARGING, "epoll create failed, epFd_ is invalid"); in Init()
|
| /base/time/time_service/services/timer/src/ |
| H A D | timer_handler.cpp | 18 #include <sys/epoll.h>
|
| /base/hiviewdfx/hiview/test/plugins/examples/event_source_example/ |
| H A D | event_source_example.cpp | 23 #include <sys/epoll.h>
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | epoll_io_waiter.cpp | 21 #include <sys/epoll.h>
77 HILOGE("Failed to create epoll, %{public}s", errmsg); in Init()
93 HILOGE("Failed to add awaken file descriptor into epoll, %{public}s", errmsg); in Init()
97 // Prepare epoll successfully. in Init()
141 HILOGE("Failed to wait epoll, %{public}s", errmsg); in WaitFor()
152 // Transform epoll events into file descriptor listener events. in WaitFor()
226 // Transform file descriptor listener events into epoll events. in AddFileDescriptor()
241 HILOGE("Failed to add file descriptor into epoll, %{public}s", errmsg); in AddFileDescriptor()
262 HILOGE("Failed to remove file descriptor from epoll, %{public}s", errmsg); in RemoveFileDescriptor()
|
| /base/hiviewdfx/hiview/plugins/sysevent_source/ |
| H A D | event_server.cpp | 24 #include <sys/epoll.h>
|
| /base/msdp/device_status/test/unittest/libs/src/ |
| H A D | device_status_mock_test.cpp | 20 #include <sys/epoll.h>
|