Home
last modified time | relevance | path

Searched refs:event (Results 1 - 18 of 18) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dready.rs50 pub(crate) fn from_event(event: &Event) -> Ready {
53 if event.is_readable() {
57 if event.is_writable() {
61 if event.is_read_closed() {
65 if event.is_write_closed() {
173 fn is_readable(event: i32) -> bool { in is_readable()
174 (event as libc::c_int & libc::EPOLLIN) != 0 in is_readable()
175 || (event as libc::c_int & libc::EPOLLPRI) != 0 in is_readable()
178 fn is_writable(event: i32) -> bool { in is_writable()
179 (event a in is_writable()
243 let mut event = libc::epoll_event { ut_ready_from_event() variables
254 let mut event = libc::epoll_event { ut_ready_from_event() variables
265 let mut event = libc::epoll_event { ut_ready_from_event() variables
276 let mut event = libc::epoll_event { ut_ready_from_event() variables
[all...]
H A Dasync_source.rs56 /// If `interest` passed in is None, the interested event for fd
77 /// corresponding event will be returned.
142 let event = self.entry.get_readiness(interest);
144 if event.ready.is_empty() {
150 self.entry.clear_readiness(event);
H A Ddriver.rs252 let err = io::Error::new(io::ErrorKind::Other, "driver event store missing.");
263 for event in events.iter() {
264 let token = event.token();
273 let ready = Ready::from_event(event);
413 let event = interest.into_io_event();
417 event,
434 let event = interest.into_io_event();
438 event,
/commonlibrary/rust/ylong_runtime/ylong_io/src/
H A Dinterest.rs46 /// Convert interest to the event value.
93 let event = interest.into_io_event(); in ut_interest_to_io_event()
94 assert_eq!(event as c_int, libc::EPOLLET); in ut_interest_to_io_event()
97 let event = interest.into_io_event(); in ut_interest_to_io_event()
99 event as c_int, in ut_interest_to_io_event()
104 let event = interest.into_io_event(); in ut_interest_to_io_event()
105 assert_eq!(event as c_int, libc::EPOLLET | libc::EPOLLOUT); in ut_interest_to_io_event()
108 let event = interest.into_io_event(); in ut_interest_to_io_event()
110 event as c_int, in ut_interest_to_io_event()
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_server.rs41 for event in events.iter() { in main()
42 if SERVER == event.token() { in main()
51 match connections.get_mut(&event.token()) { in main()
53 if event.is_writable() { in main()
59 poll.register(connection, event.token(), Interest::READABLE)?; in main()
65 poll.register(connection, event.token(), Interest::READABLE)?; in main()
69 } else if event.is_readable() { in main()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dkqueue.rs138 let event = kevent_new( in register_waker()
145 self.kevent_notify(event) in register_waker()
151 let mut event = kevent_new( in wake() variables
157 event.fflags = libc::NOTE_TRIGGER; in wake()
158 self.kevent_notify(event) in wake()
162 fn kevent_notify(&self, mut event: Event) -> io::Result<()> { in kevent_notify()
163 syscall!(kevent(self.kq, &event, 1, &mut event, 1, ptr::null())).map(|_| { in kevent_notify()
164 if (event.flags & libc::EV_ERROR != 0) && event in kevent_notify()
[all...]
H A Depoll.rs132 /// An io event
190 /// 1. Create an event from libc::EPOLLERR
194 let event = Event { in ut_event_is_err()
198 assert!(event.is_error()); in ut_event_is_err()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs128 if let Some(event) = self.events.get(event_id) {
129 event.notify.store(true, SeqCst);
134 for event in &self.events {
135 if event.notify.swap(false, SeqCst) {
136 let _ = event.inner.send(());
H A Dmod.rs366 let event = registry.get_event(kind.0 as usize);
367 event.register(kind.0, move || signal_action(kind.0))?;
/commonlibrary/c_utils/base/src/
H A Dio_event_epoll.cpp59 struct epoll_event event; in OperateEpoll() local
60 bzero(&event, sizeof(event)); in OperateEpoll()
61 event.events = epollEvents; in OperateEpoll()
62 event.data.fd = fd; in OperateEpoll()
64 if (epoll_ctl(epollFd_, op, fd, &event) != 0) { in OperateEpoll()
H A Devent_demultiplexer.cpp93 struct epoll_event event; in Update() local
94 bzero(&event, sizeof(event)); in Update()
95 event.events = Reactor2Epoll(handler->Events()); in Update()
96 event.data.fd = handler->GetHandle(); in Update()
98 if (epoll_ctl(epollFd_, operation, handler->GetHandle(), &event) != 0) { in Update()
171 UTILS_LOGD("invalid event %{public}u.", reactorEvent); in Reactor2Epoll()
H A Dio_event_reactor.cpp218 new event: %{public}d, error code: %{public}d", __FUNCTION__, fd, emask, res); in UpdateToDemultiplexer()
233 ErrCode IOEventReactor::HandleEvents(int fd, EventId event) in HandleEvents() argument
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()
245 if (cur->events_ != Events::EVENT_NONE && cur->enabled_ && (cur->events_ & event) && cur->cb_) { in HandleEvents()
247 UTILS_LOGD("%{public}s: Handling event success: %{public}d with fd: %{public}d; \ in HandleEvents()
249 __FUNCTION__, event, fd, cur->events_, cur->enabled_); in HandleEvents()
251 UTILS_LOGD("%{public}s: Handling event ignore: %{public}d with fd: %{public}d; \ in HandleEvents()
253 __FUNCTION__, event, f in HandleEvents()
266 EventId event = events[idx].second; HandleAll() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Duds_test.rs81 for event in events.iter() { in server()
82 if SERVER == event.token() { in server()
89 match connections.get_mut(&event.token()) { in server()
91 if event.is_writable() { in server()
95 poll.register(connection, event.token(), Interest::READABLE)?; in server()
100 poll.register(connection, event.token(), Interest::READABLE)?; in server()
104 } else if event.is_readable() { in server()
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
H A Dsys_event.rs29 fn ffrt_sys_event_wait(event: FfrtSysEventHandleT, sec: i64) -> c_int; in ffrt_sys_event_wait()
30 fn ffrt_sys_event_destroy(event: FfrtSysEventHandleT, func: DestroyFunc, arg: *mut c_void); in ffrt_sys_event_destroy()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs169 let event = self.source.entry.readiness(interest).await?;
170 Ok(event.ready)
H A Ddatagram.rs99 let event = self.source.entry.readiness(interest).await?;
100 Ok(event.ready)
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs158 // Non-AFD event, including pipe. in feed_events()
167 // General asynchronous IO event. in feed_events()
170 if let Some(event) = sock_guard.sock_feed_event() { in feed_events()
171 events.push(event); in feed_events()
292 // User event in release_events()
294 // For pipe, dispatch the event so it can release resources in release_events()
374 // System call to run current event. in update_while_idle()
408 // event that we're no longer interested in; when that in update_while_pending()
410 // operation with the updated event mask. in update_while_pending()
415 // operation will be submitted with the correct event mas in update_while_pending()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.cpp702 // check 1st param is event in DispatchEvent()
705 "the type of DispatchEvent first param must be event object."); in DispatchEvent()
720 "the type of event type must be string."); in DispatchEvent()
728 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "dispatchEvent event type must be not null"); in DispatchEvent()
966 // worker side event data queue shall be empty before uv_async_send in InitGlobalCallStatus()
1082 "the type of worker event must be string."); in ParentPortDispatchEvent()
1449 napi_value event = nullptr; in HostOnMessageInner() local
1450 napi_create_object(hostEnv_, &event); in HostOnMessageInner()
1451 napi_set_named_property(hostEnv_, event, "data", result); in HostOnMessageInner()
1452 napi_value argv[1] = { event }; in HostOnMessageInner()
1962 napi_value event = nullptr; WorkerOnMessageInner() local
[all...]

Completed in 11 milliseconds