Searched refs:Event (Results 1 - 13 of 13) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | events.rs | 24 pub struct Event { structure names
29 impl Event { impls
30 /// Creates a new `Event` with `Token`.
31 pub(crate) fn new(token: Token) -> Event {
32 Event {
38 /// Sets `Event` as readable.
43 /// Converts `Event` to `CompletionStatus`.
48 /// Converts `CompletionStatus` to `Event`.
49 pub(super) fn from_completion_status(status: &CompletionStatus) -> Event {
50 Event {
[all...] |
| H A D | overlapped.rs | 17 use crate::Event;
23 pub(crate) callback: fn(&OVERLAPPED_ENTRY, Option<&mut Vec<Event>>),
|
| H A D | iocp.rs | 24 use crate::{Event, Token};
88 let mut event = Event::new(token);
|
| H A D | mod.rs | 14 //! Event-driven non-blocking Tcp/Udp for windows
37 pub use events::{Event, Events};
|
| H A D | selector.rs | 39 use crate::{Event, Interest, Token};
147 events: &mut Vec<Event>, in feed_events()
154 events.push(Event::from_completion_status(iocp_event)); in feed_events()
455 fn sock_feed_event(&mut self) -> Option<Event> { in sock_feed_event()
493 Some(Event { in sock_feed_event()
|
| H A D | winapi.rs | 147 Event: HANDLE, in NtDeviceIoControlFile()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/ |
| H A D | registry.rs | 21 pub(crate) struct Event {
25 impl Default for Event {
33 events: Vec<Event>,
39 events: (0..=EVENT_MAX_NUM).map(|_| Event::default()).collect(), in default()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 28 pub(crate) struct Event {
35 impl Default for Event {
47 impl Event { impls
83 events: Vec<Event>,
91 .map(|_| Event::default()) in default()
109 pub(crate) fn get_event(&self, event_id: usize) -> &Event {
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | kqueue.rs | 162 fn kevent_notify(&self, mut event: Event) -> io::Result<()> { in kevent_notify()
174 fn kevent_register(kq: RawFd, events: &mut [Event]) -> io::Result<()> { in kevent_register()
195 fn kevent_check_error(events: &mut [Event], ignored: &[i64]) -> io::Result<()> { in kevent_check_error()
206 fn kevent_new(ident: RawFd, filter: i16, flags: u16, udata: usize) -> Event { in kevent_new()
207 Event { in kevent_new()
217 pub type Event = libc::kevent; types
220 pub struct Events(Vec<Event>);
230 type Target = Vec<Event>;
248 impl EventTrait for Event {
|
| H A D | mod.rs | 14 //! Event-driven non-blocking Tcp/Udp for unix
43 pub use epoll::{Event, Events, Selector};
50 pub use kqueue::{Event, Events, Selector};
|
| H A D | epoll.rs | 130 pub type Events = Vec<Event>; in fmt()
133 pub type Event = libc::epoll_event; types
135 impl EventTrait for Event {
170 use crate::{Event, EventTrait, Interest, Selector, Token};
187 /// UT case for `Event::is_error`
194 let event = Event { in ut_event_is_err()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | lib.rs | 14 //! Event-driven nonblocking net-io components.
25 pub use sys::{Event, EventTrait, Events, Selector};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | ready.rs | 24 use ylong_io::{Event, EventTrait};
50 pub(crate) fn from_event(event: &Event) -> Ready {
228 // @expect 1. Event readable to get readable Ready instances
229 // 2. Event writable, call writable Ready instances
230 // 3. Event Read Close, Call Read Close Ready Instance
231 // 4. Event Write Close, Call Write Close Ready Instance
|
Completed in 5 milliseconds