| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | udp_test.rs | 32 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv() localVariable
70 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from() localVariable
101 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_recv() localVariable
144 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv_from() localVariable
204 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv() localVariable
243 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_block_on_try_recv() localVariable
274 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv_poll() localVariable
315 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_peek_from() localVariable
349 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_try_peek_from() localVariable
382 let sender = UdpSocket::bind(ADDR) in sdv_udp_send_to_recv_from_poll() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_udp.rs | 46 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect() localVariable
66 let sender = tokioUdpSocket::bind(sender_addr).await.unwrap(); in tokio_udp_connect() localVariable
99 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv() localVariable
140 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_recv() localVariable
186 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable
223 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from() localVariable
|
| D | ylong_tokio_multi_threaded.rs | 108 let sender = send.clone(); in chained_spawn() localVariable
150 let sender = send.clone(); in chained_spawn() localVariable
|
| D | sync_benchmarks.rs | 104 let sender = send.clone(); in std_multi_threaded_ping() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | udp_socket_test.rs | 30 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/signal/unix/ |
| D | registry.rs | 69 sender: UnixStream, field
142 let mut sender = &self.stream.sender; in write() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 1631 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_recv_from_poll() localVariable
1734 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from() localVariable
1768 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_try_peek_from() localVariable
1802 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from_poll() localVariable
1835 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_peek() localVariable
1873 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_try_peek() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 365 pub(crate) sender: BoundedSender<RespMessage>, field
382 pub(crate) sender: UnboundedSender<ReqMessage>, field
393 pub(crate) sender: UnboundedSender<ReqMessage>, field
542 let sender = self.sender.clone(); in dispatch() localVariable
654 let sender = sender.clone(); in send_message_to_stream() localVariable
877 pub(crate) sender: UnboundedSender<ReqMessage>, field
1039 let sender = self.req_tx.clone(); in dispatch() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | input.rs | 73 let sender = self.get_mut(); in poll() localVariable
|
| D | output.rs | 219 let sender = self.resp_tx.clone(); in transmit_message() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | wheel.rs | 467 let sender = UdpSocket::bind(ADDR).await.unwrap(); in ut_sleep_drop() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | streams.rs | 92 let sender = self.frame_tx.clone(); in transmit_message() localVariable
|