| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | listener.rs | 45 let listener = ylong_io::UnixListener::bind(path)?; in bind() localVariable
88 let listener = ylong_io::UnixListener::from_std(listener); in from_std() localVariable
149 let listener = std::os::unix::net::UnixListener::bind(PATH).unwrap(); in ut_uds_listener_baisc_test() localVariable
153 let listener = res.unwrap(); in ut_uds_listener_baisc_test() localVariable
180 let listener = UnixListener::bind(PATH).unwrap(); in ut_uds_listener_read_write_test() localVariable
|
| D | mod.rs | 17 mod listener; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | uds_test.rs | 41 let listener = UnixListener::bind(PATH).unwrap(); in sdv_uds_stream_test() localVariable
220 let listener = std::os::unix::net::UnixListener::bind(PATH).unwrap(); in sdv_uds_listener_baisc_test() localVariable
224 let listener = res.unwrap(); in sdv_uds_listener_baisc_test() localVariable
|
| D | tcp_test.rs | 31 let listener = TcpListener::bind("[::1]:0").await.unwrap(); in sdv_tcp_ipv6_connect() localVariable
82 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_try() localVariable
117 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_basic() localVariable
164 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_peek() localVariable
192 let listener = TcpListener::bind(ADDR).await.expect("Bind Listener Failed"); in sdv_tcp_global_runtime() localVariable
292 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_split_borrow_half() localVariable
362 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_split_owned_half() localVariable
|
| D | join_set.rs | 99 let listener = TcpListener::bind(addr).await.unwrap(); in sdv_join_set_spawn_io() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_tcp_perf.rs | 114 let listener = TcpListener::bind(addr).await.unwrap(); in main() localVariable
158 let listener = tokioTcpListener::bind("127.0.0.1:9082").await.unwrap(); in main() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | mod.rs | 14 mod listener; module
|
| D | listener.rs | 45 let listener = unsafe { TcpListener::from_raw_socket(socket.as_raw_socket() as _) }; in bind() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | mod.rs | 14 mod listener; module
|
| D | split.rs | 135 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_test_borrow_half() localVariable
181 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_test_owned_half() localVariable
228 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_test_borrow_half_vector() localVariable
278 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_test_owned_half_vector() localVariable
|
| D | stream.rs | 685 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_tcp_stream_basic() localVariable
725 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_tcp_stream_peek() localVariable
758 let listener = TcpListener::bind(ADDR).await.unwrap(); in ut_tcp_stream_try() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| D | mod.rs | 16 mod listener; module
|
| D | listener.rs | 39 let listener = TcpListener { in bind() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| D | mod.rs | 16 mod listener; module
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 165 let listener = loop { localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker.cpp | 645 auto listener = new WorkerListener(env, callback, mode); in AddListener() local
1073 auto listener = new WorkerListener(env, callback, PERMANENT); in ParentPortAddEventListener() local
2025 std::string listener(type); in HandleEventListeners() local
2145 void Worker::AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in AddListenerInner()
2202 WorkerListener* listener = *item; in RemoveAllListenerInner() local
2304 … Worker::ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in ParentPortAddListenerInner()
2328 WorkerListener* listener = *item; in ParentPortRemoveAllListenerInner() local
2361 std::string listener(type); in ParentPortHandleEventListeners() local
|
| /commonlibrary/ets_utils/js_util_module/stream/src/ |
| D | stream_js.ts | 139 private listener: EventEmitter | undefined; property in Readable
710 public listener: EventEmitter | undefined; property in Writable
|