/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
H A D | poll.rs | 17 use crate::{Events, Interest, Selector, Source, Token}; 21 selector: Selector, 27 Selector::new().map(|selector| Poll { in new() 59 pub fn selector(&self) -> &Selector { in selector()
|
H A D | source.rs | 16 use crate::{Interest, Selector, Token}; 33 selector: &Selector, in register() 39 fn deregister(&mut self, selector: &Selector) -> io::Result<()>; in deregister()
|
H A D | lib.rs | 25 pub use sys::{Event, EventTrait, Events, Selector};
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
H A D | epoll.rs | 27 pub struct Selector { structure names 34 impl Selector { impls 35 /// Creates a new Selector. 39 pub fn new() -> io::Result<Selector> { in new() 47 Ok(Selector { in new() 115 impl Drop for Selector { 123 impl std::fmt::Debug for Selector { 170 use crate::{Event, EventTrait, Interest, Selector, Token}; 172 /// UT cases for `Selector::reregister`. 175 /// 1. Create a Selector [all...] |
H A D | source_fd.rs | 17 use crate::{Fd, Interest, Selector, Source, Token}; 26 selector: &Selector, in register() 33 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
H A D | waker.rs | 16 use crate::{Selector, Token}; 51 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> { 85 selector: Selector, 90 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> {
|
H A D | mod.rs | 43 pub use epoll::{Event, Events, Selector}; 50 pub use kqueue::{Event, Events, Selector};
|
H A D | kqueue.rs | 29 pub struct Selector { structure names 33 impl Selector { impls 34 /// Creates a new Selector. 38 pub fn new() -> io::Result<Selector> { in new() 43 Ok(Selector { kq }) in new() 128 pub fn try_clone(&self) -> io::Result<Selector> { in try_clone() 132 Ok(Selector { kq }) in try_clone() 136 /// before `Selector::wake` 149 /// `Selector::register_waker`. 274 impl Drop for Selector { [all...] |
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
H A D | waker.rs | 18 use crate::{Selector, Token}; 28 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> {
|
H A D | net.rs | 20 use crate::{Interest, Selector, Token}; 42 /// Register the socket to [`Selector`] 47 selector: &Selector, in register()
|
H A D | mod.rs | 31 pub use selector::Selector;
|
H A D | selector.rs | 46 pub struct Selector { structure names 50 impl Selector { impls 51 pub(crate) fn new() -> io::Result<Selector> { 52 SelectorInner::new().map(|inner| Selector { 83 /// Weather the Selector is polling.
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
H A D | listener.rs | 22 use crate::{Interest, Selector, Source, TcpStream, Token}; 147 selector: &Selector, in register() 155 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
|
H A D | stream.rs | 25 use crate::{Interest, Selector, Source, Token}; 322 selector: &Selector, in register() 330 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
H A D | datagram.rs | 20 use crate::{Interest, Selector, Source, Token}; 265 selector: &Selector, in register() 272 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
H A D | listener.rs | 24 use crate::{Interest, Selector, Source, Token, UnixStream}; 168 selector: &Selector, in register() 175 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
H A D | stream.rs | 21 use crate::{Interest, Selector, Source, Token}; 223 selector: &Selector, in fmt() 230 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in fmt()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
H A D | listener.rs | 25 use crate::{Interest, Selector, Source, Token}; 178 selector: &Selector, in register() 185 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
H A D | stream.rs | 22 use crate::{Interest, Selector, Source, Token}; 282 selector: &Selector, in fmt() 289 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in fmt()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
H A D | pipe.rs | 20 use ylong_io::{Interest, Selector, Source, Token}; 69 selector: &Selector, in register() 76 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
H A D | udp_socket.rs | 21 use crate::{Interest, Selector, Source, Token}; 759 selector: &Selector, in register() 766 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister() 778 selector: &Selector, in register() 785 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
H A D | udp_socket.rs | 22 use crate::{Interest, Selector, Source, Token}; 639 selector: &Selector, in register() 647 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister() 659 selector: &Selector, in register() 667 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
H A D | sys.rs | 23 use ylong_io::{Interest, Selector, Source, Token}; 155 selector: &Selector, in register() 162 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|