Searched refs:new_from_unix_seqpacket (Results 1 – 6 of 6) sorted by relevance
64 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Result<Tube> { in new_from_unix_seqpacket() method238 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Result<ProtoTube> { in new_from_unix_seqpacket() method239 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()
52 let socket = Tube::new_from_unix_seqpacket(s).map_err(|_| ())?; in handle_request_with_timeout()
202 .push(Tube::new_from_unix_seqpacket(stream).unwrap()), in run_gpu_device()
363 Ok(s) => return Ok(Tube::new_from_unix_seqpacket(s).unwrap()), in run_wl_device()
666 Tube::new_from_unix_seqpacket(UnixSeqpacket::connect(path).with_context(|| { in create_virtio_devices()3403 let tube = ProtoTube::new_from_unix_seqpacket(sock)?; in make_addr_tube_from_maybe_existing()4073 TaggedControlTube::Vm(Tube::new_from_unix_seqpacket(socket)?), in run_control()4832 let tube = match Tube::new_from_unix_seqpacket(socket) { in start_vhost_user_control_server()