Searched refs:new_from_unix_seqpacket (Results 1 – 6 of 6) sorted by relevance
63 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Result<Tube> { in new_from_unix_seqpacket() method209 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Result<ProtoTube> { in new_from_unix_seqpacket() method210 Ok(ProtoTube(Tube::new_from_unix_seqpacket(sock)?)) in new_from_unix_seqpacket()
67 let tube_send = Tube::new_from_unix_seqpacket(sock_send).unwrap(); in test_send_recv_new_from_seqpacket()68 let tube_recv = Tube::new_from_unix_seqpacket(sock_recv).unwrap(); in test_send_recv_new_from_seqpacket()
51 let socket = Tube::new_from_unix_seqpacket(s).map_err(|_| ())?; in handle_request_with_timeout()
187 .push(Tube::new_from_unix_seqpacket(stream).unwrap()), in run_gpu_device()
390 Ok(s) => return Ok(Tube::new_from_unix_seqpacket(s).unwrap()), in run_wl_device()
1754 Some(Tube::new_from_unix_seqpacket( in run_vm()3241 let tube = ProtoTube::new_from_unix_seqpacket(sock)?; in make_addr_tube_from_maybe_existing()3796 TaggedControlTube::Vm(Tube::new_from_unix_seqpacket(socket)?), in run_control()4550 let tube = match Tube::new_from_unix_seqpacket(socket) { in start_vhost_user_control_server()