| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | kqueue.rs | 46 /// Waits for io events to come within a time limit.
47 pub fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
48 events.clear(); in select()
65 events.as_mut_ptr(), in select()
66 events.capacity() as c_int, in select()
69 unsafe { events.set_len(n_events as usize) }; in select()
74 /// Registers the fd with specific interested events
77 let mut events = Vec::with_capacity(2); in register() variables
80 events.push(kevent); in register()
85 events in register()
95 let mut events = Vec::with_capacity(2); reregister() variables
116 let mut events = vec![ deregister() variables
[all...] |
| H A D | epoll.rs | 53 /// Waits for io events to come within a time limit.
54 pub fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
59 events.clear(); in select()
63 events.as_mut_ptr(), in select()
64 events.capacity() as i32, in select()
67 Ok(n_events) => unsafe { events.set_len(n_events as usize) }, in select()
75 /// Registers the fd with specific interested events
78 events: interests.into_io_event(), in register()
88 /// Re-registers the fd with specific interested events
91 events in reregister()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 51 /// IO reactor that listens to fd events and wakes corresponding tasks.
63 /// Stores IO events that need to be handled
65 events: Option<Events>,
160 /// Ready events count. This value will only increment, not decrease.
166 /// epoll events.
202 let events = Events::with_capacity(EVENTS_MAX_CAPACITY);
218 events: Some(events),
230 /// Runs the driver. This method will blocking wait for fd events to come in
231 /// and then wakes the corresponding tasks through the events
249 let mut events = match self.events.take() { global() variables
[all...] |
| H A D | ready.rs | 244 events: 0b00, in ut_ready_from_event()
247 event.events |= libc::EPOLLIN as u32; in ut_ready_from_event()
255 events: 0b00, in ut_ready_from_event()
258 event.events |= libc::EPOLLOUT as u32; in ut_ready_from_event()
266 events: 0b00, in ut_ready_from_event()
269 event.events |= (libc::EPOLLIN | libc::EPOLLRDHUP) as u32; in ut_ready_from_event()
277 events: 0x00, in ut_ready_from_event()
280 event.events |= (libc::EPOLLOUT | libc::EPOLLERR) as u32; in ut_ready_from_event()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | selector.rs | 33 use crate::sys::windows::events::{
57 pub(crate) fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> {
58 self.inner.select(events, timeout)
79 /// Registered/re-registered IO events are placed in this queue.
104 fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
105 events.clear(); in select()
109 let len = self.select_inner(events, timeout)?; in select()
115 self.select_inner(events, timeout)?; in select()
121 fn select_inner(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<usize> { in select_inner()
132 .get_results(&mut events in select_inner()
[all...] |
| H A D | events.rs | 57 /// Storage completed events
60 pub(crate) events: Vec<Event>,
68 events: Vec::with_capacity(cap), in with_capacity()
74 self.events.clear(); in clear()
84 iter: &self.events, in iter()
91 self.events.is_empty() in is_empty()
96 self.events.len() in len()
|
| H A D | mod.rs | 36 mod events; modules
37 pub use events::{Event, Events};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 83 events: Vec<Event>,
90 events: (0..=SignalKind::get_max()) in default()
112 self.events
120 self.events
128 if let Some(event) = self.events.get(event_id) {
134 for event in &self.events {
|
| /commonlibrary/c_utils/base/src/ |
| H A D | io_event_epoll.cpp | 61 event.events = epollEvents; in OperateEpoll()
83 ErrCode IOEventEpoll::ModifyEvents(int fd, REventId events) in ModifyEvents() argument
92 if (events == Events::EVENT_NONE) { in ModifyEvents()
99 if (!OperateEpoll(op, fd, Reactor2Epoll(events))) { in ModifyEvents()
100 UTILS_LOGE("%{public}s: Modify events failed.", __FUNCTION__); in ModifyEvents()
118 res.emplace_back(std::make_pair(epollEvents[idx].data.fd, Epoll2Reactor(epollEvents[idx].events))); in Polling()
|
| H A D | io_event_reactor.cpp | 101 if ((ioHandlers_[fd].events & target->events_) != target->events_) { in AddHandler()
210 if (emask == ioHandlers_[fd].events) { in UpdateToDemultiplexer()
211 UTILS_LOGW("%{public}s: Warning, Interested events not changed.", __FUNCTION__); in UpdateToDemultiplexer()
217 UTILS_LOGE("%{public}s: Modify events on backend failed. fd: %{public}d, \ in UpdateToDemultiplexer()
222 ioHandlers_[fd].events = emask; in UpdateToDemultiplexer()
238 if (!(ioHandlers_[fd].events & event)) { in HandleEvents()
239 UTILS_LOGD("%{public}s: Non-interested event: %{public}d with fd: %{public}d, interested events: \ in HandleEvents()
240 %{public}d", __FUNCTION__, event, fd, ioHandlers_[fd].events); in HandleEvents()
248 handler interested events: %{public}d, active-status: %{public}d", \ in HandleEvents()
252 handler interested events in HandleEvents()
262 HandleAll(const std::vector<std::pair<int, EventId>>& events) HandleAll() argument
[all...] |
| H A D | event_handler.cpp | 40 void EventHandler::HandleEvents(uint32_t events) in HandleEvents() argument
42 if (events & (EventReactor::READ_EVENT)) { in HandleEvents()
|
| H A D | event_demultiplexer.cpp | 95 event.events = Reactor2Epoll(handler->Events()); in Update()
132 uint32_t events = epollEvents[idx].events; in Polling() local
137 eventQue.emplace_back(events); in Polling()
|
| H A D | io_event_handler.cpp | 28 IOEventHandler::IOEventHandler(int fd, EventId events, const EventCallback& cb) in IOEventHandler() argument
29 :prev_(nullptr), next_(nullptr), fd_(fd), events_(events), cb_(cb), enabled_(false) {} in IOEventHandler()
|
| H A D | event_handler.h | 52 void HandleEvents(uint32_t events);
|
| H A D | io_event_epoll.h | 49 virtual ErrCode ModifyEvents(int fd, REventId events);
|
| /commonlibrary/c_utils/base/include/ |
| H A D | io_event_handler.h | 29 explicit IOEventHandler(int fd, EventId events = Events::EVENT_NONE, const EventCallback& cb = nullptr);
45 inline void SetEvents(EventId events) in SetEvents() argument
47 events_ = events; in SetEvents()
|
| H A D | io_event_reactor.h | 76 EventId events; member
82 events = Events::EVENT_NONE; in FdEvents()
94 ErrCode HandleEvents(int fd, EventId events);
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/ |
| H A D | mod.rs | 46 mod events; modules
47 pub use events::EventTrait;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/ |
| H A D | registry.rs | 33 events: Vec<Event>,
39 events: (0..=EVENT_MAX_NUM).map(|_| Event::default()).collect(), in default()
59 self.events
67 if let Some(event) = self.events.get(event_id) {
|
| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_server.rs | 34 let mut events = Events::with_capacity(128); in main() variables
39 poll.poll(&mut events, None)?; in main()
41 for event in events.iter() { in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | poll.rs | 32 /// Gets all interested io events within a time limit and writes them into
37 pub fn poll(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll()
38 self.selector.select(events, timeout) in poll()
41 /// Registers the I/O source's fd in order to monitor its io events.
50 /// io events.
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 74 let mut events = Events::with_capacity(128); in server() variables
79 poll.poll(&mut events, None)?; in server()
81 for event in events.iter() { in server()
|
| /commonlibrary/memory_utils/libsync/src/ |
| H A D | sync.c | 31 work.events = POLLIN; in SyncWait()
|
| /commonlibrary/rust/ylong_runtime/ylong_ffrt/src/ |
| H A D | sys_event.rs | 32 /// Registers the fd to ffrt's epoll. Callback will be called when io events
36 events: c_uint, in ffrt_poller_register()
45 /// timer events arrived.
60 /// Wakes up the poller to poll timer/io events.
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 131 // 3. Set interest events in BENCHMARK_F()
141 // 5. disable events in BENCHMARK_F()
146 // 6. enable events in BENCHMARK_F()
152 // 7. disable one of the events in BENCHMARK_F()
175 // 3. Set interest events in BENCHMARK_F()
1401 // 1. Define file descriptor and events in BENCHMARK_F()
1403 EventId events = Events::EVENT_READ; in BENCHMARK_F() local
1406 std::shared_ptr<IOEventHandler> handler = std::make_shared<IOEventHandler>(fd, events); in BENCHMARK_F()
1410 AssertEqual(handler->GetEvents(), events, "handler->GetEvents() did not equal events a in BENCHMARK_F()
1428 EventId events = Events::EVENT_READ; BENCHMARK_F() local
[all...] |