| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | uds_cargo_test.rs | 33 let listener = std::os::unix::net::UnixListener::bind(PATH).unwrap(); in sdv_uds_listener_baisc_test() localVariable
37 let listener = res.unwrap(); in sdv_uds_listener_baisc_test() localVariable
61 let listener = UnixListener::bind(PATH).unwrap(); in sdv_uds_listener_read_write_test() localVariable
112 let listener = UnixListener::bind(PATH).unwrap(); in sdv_uds_stream_test() localVariable
|
| D | tcp_test.rs | 33 let listener = TcpListener::bind("[::1]:0").await.unwrap(); in sdv_tcp_ipv6_connect() localVariable
84 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_try() localVariable
119 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_basic() localVariable
166 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_stream_peek() localVariable
194 let listener = TcpListener::bind(ADDR).await.expect("Bind Listener Failed"); in sdv_tcp_global_runtime() localVariable
294 let listener = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_split_borrow_half() localVariable
364 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_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_runtime/src/net/sys/unix/ |
| D | mod.rs | 17 mod listener; module
|
| 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
|
| /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_io/src/sys/unix/uds/ |
| D | mod.rs | 16 mod listener; module
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 257 let listener = loop { localVariable
|
| /commonlibrary/ets_utils/js_util_module/stream/src/ |
| D | stream_js.ts | 138 private listener: EventEmitter | undefined; property in Readable
710 public listener: EventEmitter | undefined; property in Writable
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker.cpp | 769 auto listener = new WorkerListener(env, callback, mode); in AddListener() local
1207 auto listener = new WorkerListener(env, callback, PERMANENT); in ParentPortAddEventListener() local
2255 std::string listener(type); in HandleEventListeners() local
2375 void Worker::AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in AddListenerInner()
2432 WorkerListener* listener = *item; in RemoveAllListenerInner() local
2534 … Worker::ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in ParentPortAddListenerInner()
2558 WorkerListener* listener = *item; in ParentPortRemoveAllListenerInner() local
2591 std::string listener(type); in ParentPortHandleEventListeners() local
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| D | sdv_async_certs_adapter.rs | 99 let listener = loop { in sdv_client_request_http2_verify_true() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 788 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in HandleEventListeners() local
889 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in RemoveListenerInner() local
940 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in ParentPortAddListenerInnerTest() local
959 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::PERMANENT); in ParentPortRemoveListenerInnerTest() local
997 auto listener = new Worker::WorkerListener(env, callback, Worker::ListenerMode::ONCE); in ParentPortHandleEventListeners() local
|