Searched defs:sender (Results 1 – 11 of 11) sorted by relevance
32 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv() localVariable70 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from() localVariable101 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_recv() localVariable144 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv_from() localVariable204 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_try_recv() localVariable243 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_block_on_try_recv() localVariable274 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv_poll() localVariable315 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_peek_from() localVariable349 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_send_to_try_peek_from() localVariable382 let sender = UdpSocket::bind(ADDR) in sdv_udp_send_to_recv_from_poll() localVariable[all …]
46 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect() localVariable66 let sender = tokioUdpSocket::bind(sender_addr).await.unwrap(); in tokio_udp_connect() localVariable99 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv() localVariable140 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_recv() localVariable186 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable223 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from() localVariable
108 let sender = send.clone(); in chained_spawn() localVariable150 let sender = send.clone(); in chained_spawn() localVariable
104 let sender = send.clone(); in std_multi_threaded_ping() localVariable
30 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_recv() localVariable90 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_to_recv_from() localVariable
69 sender: UnixStream, field142 let mut sender = &self.stream.sender; in write() localVariable
1631 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_recv_from_poll() localVariable1734 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from() localVariable1768 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_try_peek_from() localVariable1802 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_send_to_peek_from_poll() localVariable1835 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_peek() localVariable1873 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in ut_connected_try_peek() localVariable
196 pub(crate) sender: BoundedSender<RespMessage>, field213 pub(crate) sender: UnboundedSender<ReqMessage>, field224 pub(crate) sender: UnboundedSender<ReqMessage>, field375 let sender = self.sender.clone(); in dispatch() localVariable475 let sender = sender.clone(); in send_message_to_stream() localVariable
73 let sender = self.get_mut(); in poll() localVariable
214 let sender = self.resp_tx.clone(); in transmit_message() localVariable
467 let sender = UdpSocket::bind(ADDR).await.unwrap(); in ut_sleep_drop() localVariable