Searched refs:vsock_stream (Results 1 – 3 of 3) sorted by relevance
126 vsock_stream: VsockStream, field156 let (vsock_stream, peer_addr) = vsock_listener.accept().context("Failed to accept")?; in start_vm()157 info!("Accepted connection {:?}", vsock_stream); in start_vm()164 vsock_stream.set_read_timeout(Some(READ_TIMEOUT))?; in start_vm()165 vsock_stream.set_write_timeout(Some(WRITE_TIMEOUT))?; in start_vm()167 Ok(Self { vsock_stream, vm }) in start_vm()178 let mut buffer = BufWriter::with_capacity(WRITE_BUFFER_CAPACITY, &mut self.vsock_stream); in write_request()187 let response: Response = ciborium::from_reader(&mut self.vsock_stream) in read_response()
181 let mut vsock_stream = VsockStream::new(socket_device, host_addr())?; in try_main() localVariable182 while let ServiceVmRequest::Process(req) = vsock_stream.read_request()? { in try_main()186 vsock_stream.write_response(&response)?; in try_main()187 vsock_stream.flush()?; in try_main()189 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()