Searched refs:vsock_stream (Results 1 – 5 of 5) sorted by relevance
130 vsock_stream: VsockStream, field160 let (vsock_stream, peer_addr) = vsock_listener.accept().context("Failed to accept")?; in start_vm()161 info!("Accepted connection {:?}", vsock_stream); in start_vm()168 vsock_stream.set_read_timeout(Some(READ_TIMEOUT))?; in start_vm()169 vsock_stream.set_write_timeout(Some(WRITE_TIMEOUT))?; in start_vm()171 Ok(Self { vsock_stream, vm }) in start_vm()182 let mut buffer = BufWriter::with_capacity(WRITE_BUFFER_CAPACITY, &mut self.vsock_stream); in write_request()191 let response: Response = ciborium::from_reader(&mut self.vsock_stream) in read_response()
133 let mut vsock_stream = VsockStream::new(socket_device, host_addr(fdt)?)?; in try_main() localVariable134 while let ServiceVmRequest::Process(req) = vsock_stream.read_request()? { in try_main()138 vsock_stream.write_response(&response)?; in try_main()139 vsock_stream.flush()?; in try_main()141 vsock_stream.shutdown()?; in try_main()
48 let mut vsock_stream = Self { in new() localVariable53 vsock_stream.connect()?; in new()54 Ok(vsock_stream) in new()
62 let vsock_stream = VsockStream::connect(&addr) in connect() localVariable64 Ok(vsock_stream.into()) in connect()
360 let (vsock_stream, sockaddr) = vsock_listener.accept().map_err(Error::VsockAccept)?; in create_forwarder_session()365 Ok(ForwarderSession::new(tcp_stream.into(), vsock_stream.into())) in create_forwarder_session()