| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | listener.rs | 31 fn new(listener: ylong_io::UnixListener) -> Result<Self> { in new()
32 let source = AsyncSource::new(listener, None)?; in new()
45 let listener = ylong_io::UnixListener::bind(path)?; in bind()
46 UnixListener::new(listener) in bind()
49 /// Waits a new incoming connection for this listener.
56 /// let listener = UnixListener::bind("/socket/path")?;
58 /// let res = listener.accept().await;
87 pub fn from_std(listener: net::UnixListener) -> Result<UnixListener> { in from_std()
88 let listener = ylong_io::UnixListener::from_std(listener); in from_std()
[all...] |
| H A D | mod.rs | 17 mod listener; modules
18 pub use listener::UnixListener;
|
| H A D | stream.rs | 89 pub fn from_std(listener: net::UnixStream) -> Result<UnixStream> { in from_std()
90 let stream = ylong_io::UnixStream::from_std(listener); in from_std()
|
| H A D | datagram.rs | 274 pub fn from_std(listener: net::UnixDatagram) -> Result<UnixDatagram> { in from_std()
275 let stream = ylong_io::UnixDatagram::from_std(listener); in from_std()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | uds_cargo_test.rs | 33 let listener = std::os::unix::net::UnixListener::bind(PATH).unwrap(); in sdv_uds_listener_baisc_test()
35 let res = UnixListener::from_std(listener); in sdv_uds_listener_baisc_test()
37 let listener = res.unwrap(); in sdv_uds_listener_baisc_test()
38 assert!(listener.as_fd().as_raw_fd() >= 0); in sdv_uds_listener_baisc_test()
39 assert!(listener.as_raw_fd() >= 0); in sdv_uds_listener_baisc_test()
40 assert!(listener.take_error().is_ok()); in sdv_uds_listener_baisc_test()
61 let listener = UnixListener::bind(PATH).unwrap(); in sdv_uds_listener_read_write_test()
78 let (mut stream, _) = listener.accept().await.unwrap(); in sdv_uds_listener_read_write_test()
112 let listener = UnixListener::bind(PATH).unwrap(); in sdv_uds_stream_test()
113 let (mut stream, _) = listener in sdv_uds_stream_test()
[all...] |
| H A D | tcp_test.rs | 26 /// 2. `TcpStream` connect to listener and try to read buf.
31 let listener = TcpListener::bind("[::1]:0").await.unwrap(); in sdv_tcp_ipv6_connect()
32 let addr = listener.local_addr().unwrap(); in sdv_tcp_ipv6_connect()
45 let (mut stream, _) = listener.accept().await.unwrap(); in sdv_tcp_ipv6_connect()
77 /// 2. `TcpStream` connect to listener and try to read buf.
82 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_try()
83 let addr = listener.local_addr().unwrap(); in sdv_tcp_stream_try()
97 let (stream, _) = listener.accept().await.unwrap(); in sdv_tcp_stream_try()
110 /// 2. `TcpStream` connect to listener.
117 let listener in sdv_tcp_stream_basic()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 128 /// 2. `TcpStream` connect to listener. in poll_flush()
135 let listener = TcpListener::bind(ADDR).await.unwrap(); in poll_flush()
136 let addr = listener.local_addr().unwrap(); in poll_flush()
156 let (mut stream, _) = listener.accept().await.unwrap(); in poll_flush()
174 /// 2. `TcpStream` connect to listener. in poll_flush()
181 let listener = TcpListener::bind(ADDR).await.unwrap(); in poll_flush()
182 let addr = listener.local_addr().unwrap(); in poll_flush()
203 let (mut stream, _) = listener.accept().await.unwrap(); in poll_flush()
221 /// 2. `TcpStream` connect to listener. in poll_flush()
228 let listener in poll_flush()
[all...] |
| H A D | mod.rs | 14 mod listener; modules
15 pub use listener::TcpListener;
|
| H A D | listener.rs | 78 /// Asynchronously accepts a new incoming connection from this listener.
108 /// Returns the local socket address of this listener.
194 pub(crate) fn new(listener: ylong_io::TcpListener) -> io::Result<Self> {
195 let source = AsyncSource::new(listener, None)?;
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | listener.rs | 45 let listener = unsafe { TcpListener::from_raw_socket(socket.as_raw_socket() as _) }; in bind()
49 Ok(listener) in bind()
53 pub fn from_std(listener: net::TcpListener) -> TcpListener { in from_std()
55 inner: listener, in from_std()
78 /// Returns the local socket address of this listener.
|
| H A D | mod.rs | 14 mod listener; modules
15 pub use listener::TcpListener;
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | mod.rs | 16 mod listener; modules
17 pub use listener::TcpListener;
|
| H A D | listener.rs | 39 let listener = TcpListener { in bind()
45 Ok(listener) in bind()
94 /// Returns the local socket address of this listener.
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | mod.rs | 16 mod listener; modules
17 pub use listener::UnixListener;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp_fd_limit.rs | 28 Ok(listener) => vec.push(listener), in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| H A D | ylong_tokio_tcp_perf.rs | 114 let listener = TcpListener::bind(addr).await.unwrap(); in main()
116 let (mut socket, _) = listener.accept().await.unwrap(); in main()
158 let listener = tokioTcpListener::bind("127.0.0.1:9082").await.unwrap(); in main()
160 let (mut socket, _) = listener.accept().await.unwrap(); in main()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.cpp | 586 "the number of listener parameters is not less than 2."); in AddListener()
597 "the type of listener first param must be string."); in AddListener()
602 "the type of listener the second param must be callable."); in AddListener()
614 auto listener = new WorkerListener(env, callback, mode); in AddListener() local
620 listener->SetMode(PERMANENT); in AddListener()
625 worker->AddListenerInner(env, typeStr, listener); in AddListener()
666 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "the type of remove listener type must be not null"); in RemoveListener()
1020 ErrorHelper::TYPE_ERROR, "worker listener param count must be more than WORKPARAMNUM."); in ParentPortAddEventListener()
1031 "the type of worker listener first param must be string."); in ParentPortAddEventListener()
1037 "the type of worker listener secon in ParentPortAddEventListener()
1048 auto listener = new WorkerListener(env, callback, PERMANENT); ParentPortAddEventListener() local
2096 AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) AddListenerInner() argument
2153 WorkerListener* listener = *item; RemoveAllListenerInner() local
2258 ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) ParentPortAddListenerInner() argument
2282 WorkerListener* listener = *item; ParentPortRemoveAllListenerInner() local
[all...] |
| H A D | worker.h | 68 bool operator==(const WorkerListener& listener) const;
78 bool operator()(const WorkerListener* listener) const in operator ()()
80 napi_value compareObj = NapiHelper::GetReferenceValue(env_, listener->callback_); in operator ()()
82 // the env of listener and cmp listener must be same env because of Synchronization method in operator ()()
201 * Adds an event listener to the worker.
209 * Adds an event listener to the worker and removes the event listener automatically after it is invoked once.
217 * Removes an event listener to the worker.
241 * Remove the event listener
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 128 let server = hyper::Server::from_tcp(tcp_listener).expect("build hyper server from tcp listener failed !");
165 let listener = loop {
168 Ok(listener) => break listener,
178 let port = listener.local_addr().unwrap().port();
199 let (stream, _) = listener.accept().await.expect("TCP listener accept error");
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 682 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in HandleEventListeners() local
684 worker->AddListenerInner(env, "onmessage", listener); in HandleEventListeners()
779 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in RemoveListenerInner() local
780 worker->AddListenerInner(env, "onmessage", listener); in RemoveListenerInner()
826 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in ParentPortAddListenerInnerTest() local
827 worker->ParentPortAddListenerInner(env, "onmessage", listener); in ParentPortAddListenerInnerTest()
828 worker->ParentPortAddListenerInner(env, "onmessage", listener); in ParentPortAddListenerInnerTest()
845 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in ParentPortRemoveListenerInnerTest() local
846 worker->ParentPortAddListenerInner(env, "onmessage", listener); in ParentPortRemoveListenerInnerTest()
883 auto listener in ParentPortHandleEventListeners() local
[all...] |