Searched defs:listener (Results 1 – 12 of 12) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | mod.rs | 14 mod listener; module
|
| D | split.rs | 136 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_borrow_half() localVariable
190 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_owned_half() localVariable
|
| D | stream.rs | 598 let listener = TcpListener::bind(addr).await.unwrap(); in ut_tcp_stream_basic() localVariable
636 let listener = TcpListener::bind(addr).await.unwrap(); in ut_tcp_stream_peek() 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/linux/tcp/ |
| D | mod.rs | 16 mod listener; module
|
| /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/tests/ |
| D | tcp_test.rs | 60 let listener = TcpListener::bind(addr).await; in sdv_tcp_global_runtime() localVariable
66 let listener = listener.unwrap(); in sdv_tcp_global_runtime() localVariable
|
| D | join_set.rs | 99 let listener = TcpListener::bind(addr).await.unwrap(); in sdv_join_set_spawn_io() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker_new.cpp | 348 auto listener = new WorkerListener(env, callback, mode); in AddListener() local
622 auto listener = new WorkerListener(env, callback, PERMANENT); in WorkerPortAddEventListener() local
1213 std::string listener(type); in HandleEventListeners() local
1309 void NewWorker::AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in AddListenerInner()
1364 WorkerListener* listener = *item; in RemoveAllListenerInner() local
1470 …wWorker::ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in ParentPortAddListenerInner()
1494 WorkerListener* listener = *item; in ParentPortRemoveAllListenerInner() local
1527 std::string listener(type); in ParentPortHandleEventListeners() local
|
| D | worker.cpp | 362 std::string listener(type); in HandleEventListeners() local
922 auto listener = new WorkerListener(env, callback, mode); in AddListener() local
946 void Worker::AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in AddListenerInner()
1116 WorkerListener* listener = *item; in RemoveAllListenerInner() local
1355 auto listener = new WorkerListener(env, callback, PERMANENT); in ParentPortAddEventListener() local
1492 … Worker::ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in ParentPortAddListenerInner()
1516 WorkerListener* listener = *item; in ParentPortRemoveAllListenerInner() local
1549 std::string listener(type); in ParentPortHandleEventListeners() local
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 165 let listener = loop { localVariable
|