Searched refs:recv_body (Results 1 – 8 of 8) sorted by relevance
| /external/rust/crates/crossbeam-channel/src/ |
| D | select_macro.rs | 579 (recv($r:expr) -> $res:pat => $recv_body:tt,)
592 $recv_body
614 (recv($r:expr) -> $res:pat => $recv_body:tt,)
627 $recv_body
|
| /external/rust/crates/vmm_vhost/src/vhost_user/ |
| D | master.rs | 632 let (reply, body, rfds) = self.main_sock.recv_body::<T>()?; in recv_reply()
676 let (reply, body, rfds) = self.main_sock.recv_body::<VhostUserU64>()?; in wait_for_ack()
797 let (_hdr, msg, rfds) = peer.recv_body::<VhostUserU64>().unwrap(); in test_features()
835 let (_hdr, msg, rfds) = peer.recv_body::<VhostUserU64>().unwrap(); in test_protocol_features()
850 let (_hdr, msg, rfds) = peer.recv_body::<VhostUserU64>().unwrap(); in test_protocol_features()
|
| D | slave_fs_cache.rs | 56 let (reply, body, rfds) = self.sock.recv_body::<VhostUserU64>()?; in wait_for_ack()
|
| D | connection.rs | 456 pub fn recv_body<T: Sized + Default + VhostUserMsgValidator>( in recv_body() method
|
| /external/rust/crates/quiche/examples/ |
| D | http3-client.rs | 239 http3_conn.recv_body(&mut conn, stream_id, &mut buf) in main()
|
| /external/rust/crates/quiche/src/h3/ |
| D | ffi.rs | 259 match conn.recv_body(quic_conn, stream_id, out) { in quiche_h3_recv_body()
|
| D | mod.rs | 991 pub fn recv_body( in recv_body() method
1981 self.client.recv_body(&mut self.pipe.client, stream, buf) in recv_body_client()
2006 self.server.recv_body(&mut self.pipe.server, stream, buf) in recv_body_server()
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | function_test.py | 940 def recv_body(n): function
956 recv_body.get_concrete_function())
|