Home
last modified time | relevance | path

Searched defs:sender (Results 1 – 8 of 8) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
Dylong_tokio_udp.rs45 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect() localVariable
65 let sender = tokioUdpSocket::bind(sender_addr).await.unwrap(); in tokio_udp_connect() localVariable
97 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv() localVariable
138 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_recv() localVariable
183 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable
220 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from() localVariable
Dylong_tokio_multi_threaded.rs108 let sender = send.clone(); in chained_spawn() localVariable
150 let sender = send.clone(); in chained_spawn() localVariable
Dsync_benchmarks.rs104 let sender = send.clone(); in std_multi_threaded_ping() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dudp_test.rs32 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send_recv() localVariable
88 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send_to_recv_from() localVariable
123 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_send() localVariable
197 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_try_recv_from() localVariable
242 let sender = match UdpSocket::bind(sender_addr).await { in sdv_udp_try_send() localVariable
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
Dudp_socket_test.rs30 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_recv() localVariable
90 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_to_recv_from() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
Dudp.rs1469 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ut_udp_basic_v4() localVariable
1542 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ut_udp_basic_v6() localVariable
1593 let sender = UdpSocket::bind(sender_addr) in ut_send_recv_poll() localVariable
1639 let sender = UdpSocket::bind(sender_addr) in ut_send_to_recv_from_poll() localVariable
1752 let sender = UdpSocket::bind($sender_addr) localVariable
1861 let sender = UdpSocket::bind(sender_addr) in ut_send_to_peek_from() localVariable
1901 let sender = UdpSocket::bind(sender_addr) in ut_send_to_try_peek_from() localVariable
1941 let sender = UdpSocket::bind(sender_addr) in ut_send_to_peek_from_poll() localVariable
1978 let sender = UdpSocket::bind(sender_addr) in ut_connected_peek() localVariable
2019 let sender = UdpSocket::bind(sender_addr) in ut_connected_try_peek() localVariable
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
Ddispatcher.rs191 pub(crate) sender: UnboundedSender<Send2Ctrl>, field
198 pub(crate) sender: UnboundedSender<Send2Ctrl>, field
345 let mut sender = StreamBuffer::new(); in insert() localVariable
579 let sender = self.sender.clone(); in dispatch() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
Dwheel.rs472 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ut_sleep_drop() localVariable