Searched refs:vsock_stream (Results 1 – 7 of 7) sorted by relevance
| /packages/modules/Virtualization/tests/vts/src/ |
| D | vts_libavf_test.rs | 37 fn process_request(vsock_stream: &mut VsockStream, request: Request) -> Result<Response> { in process_request()
38 write_request(vsock_stream, &ServiceVmRequest::Process(request))?; in process_request()
39 read_response(vsock_stream) in process_request()
43 fn write_request(vsock_stream: &mut VsockStream, request: &ServiceVmRequest) -> Result<()> { in write_request()
44 let mut buffer = BufWriter::with_capacity(WRITE_BUFFER_CAPACITY, vsock_stream); in write_request()
51 fn read_response(vsock_stream: &mut VsockStream) -> Result<Response> { in read_response()
52 let response: Response = ciborium::from_reader(vsock_stream) in read_response()
67 Ok((vsock_stream, _peer_addr)) => return Ok(vsock_stream), in listen_from_guest()
145 let mut vsock_stream = listener_thread.join().unwrap()?; in run_rialto() localVariable
146 vsock_stream.set_read_timeout(Some(READ_TIMEOUT))?; in run_rialto()
[all …]
|
| /packages/modules/Virtualization/tests/old_images_avf_test/src/ |
| D | main.rs | 38 fn process_request(vsock_stream: &mut VsockStream, request: Request) -> Result<Response> { in process_request()
39 write_request(vsock_stream, &ServiceVmRequest::Process(request))?; in process_request()
40 read_response(vsock_stream) in process_request()
44 fn write_request(vsock_stream: &mut VsockStream, request: &ServiceVmRequest) -> Result<()> { in write_request()
45 let mut buffer = BufWriter::with_capacity(WRITE_BUFFER_CAPACITY, vsock_stream); in write_request()
52 fn read_response(vsock_stream: &mut VsockStream) -> Result<Response> { in read_response()
53 let response: Response = ciborium::from_reader(vsock_stream) in read_response()
68 Ok((vsock_stream, _peer_addr)) => return Ok(vsock_stream), in listen_from_guest()
140 let mut vsock_stream = listener_thread.join().unwrap()?; in run_vm() localVariable
141 vsock_stream.set_read_timeout(Some(READ_TIMEOUT))?; in run_vm()
[all …]
|
| /packages/modules/Virtualization/libs/libservice_vm_manager/src/ |
| D | lib.rs | 130 vsock_stream: VsockStream, field
160 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()
|
| /packages/modules/Virtualization/guest/rialto/src/ |
| D | main.rs | 135 let mut vsock_stream = VsockStream::new(socket_device, host_addr(fdt)?)?; in try_main() localVariable
136 while let ServiceVmRequest::Process(req) = vsock_stream.read_request()? { in try_main()
140 vsock_stream.write_response(&response)?; in try_main()
141 vsock_stream.flush()?; in try_main()
143 vsock_stream.shutdown()?; in try_main()
|
| D | communication.rs | 48 let mut vsock_stream = Self { in new() localVariable
53 vsock_stream.connect()?; in new()
54 Ok(vsock_stream) in new()
|
| /packages/modules/Virtualization/libs/libforwarder/src/ |
| D | stream.rs | 62 let vsock_stream = VsockStream::connect(&addr) in connect() localVariable
64 Ok(vsock_stream.into()) in connect()
|
| /packages/modules/Virtualization/android/forwarder_host/src/ |
| D | forwarder_host.rs | 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()
|