Searched defs:recv (Results 1 – 10 of 10) sorted by relevance
35 let mut recv = native_struct::SessionHandShake::default(); in if_session_hand_shake_works() localVariable53 let mut recv = native_struct::TransferPayload::default(); in if_session_transfer_payload_works() localVariable80 let mut recv = native_struct::TransferConfig { in if_transfer_config_works() localVariable100 let mut recv = native_struct::PayloadHead::default(); in if_session_payload_head_works() localVariable
130 let recv = self.recv().await?; in handshake() localVariable154 async fn recv(&mut self) -> io::Result<Vec<u8>> { in recv() method228 let recv = self.recv().await?; in general_task() localVariable247 let recv = self.recv().await?; in bug_report_task() localVariable269 let recv = self.recv().await; in loop_recv() localVariable300 let recv = self.recv().await; in app_install_task() localVariable
135 let recv = recv_opt.unwrap(); in handle_client() localVariable201 let recv = transfer::tcp::recv_channel_message(rd).await.unwrap(); in handshake_with_client() localVariable
52 let mut recv = SessionHandShake::default(); in handshake_with_daemon() localVariable
82 let mut recv = native_struct::SessionHandShake::default(); in handshake_init() localVariable186 let mut recv = native_struct::SessionHandShake::default(); in get_new_session_id() localVariable205 let mut recv = native_struct::SessionHandShake::default(); in handshake_task() localVariable
101 std::unique_ptr<char[]> recv = std::make_unique<char[]>(nread + 1); in ProcessIncoming() local
99 let recv = ReadUartDevExt(self.fd, (expected_size - index) as i32); in read_frame() localVariable
255 pub async fn recv() -> io::Result<Vec<u8>> { in recv() method
252 std::string recv = Decode(); in FlushData() local
52449 int (*recv)(struct tpm_chip *, u8 *, size_t); member