Lines Matching full:socket
108 /// Cannot bind to the UNIX domain socket path
109 #[error("Error binding to UNIX domain socket")]
184 /// Error binding API server socket
185 #[error("Error creation API server's socket")]
828 socket: &mut T, in vm_receive_config()
837 socket in vm_receive_config()
909 Response::ok().write_to(socket)?; in vm_receive_config()
917 socket: &mut T, in vm_receive_state()
926 socket in vm_receive_state()
974 Response::error().write_to(socket).ok(); in vm_receive_state()
979 Response::ok().write_to(socket)?; in vm_receive_state()
987 socket: &mut T, in vm_receive_memory()
994 let table = MemoryRangeTable::read_from(socket, req.length())?; in vm_receive_memory()
998 .receive_memory_regions(&table, socket) in vm_receive_memory()
1000 Response::error().write_to(socket).ok(); in vm_receive_memory()
1002 Response::ok().write_to(socket)?; in vm_receive_memory()
1018 info!("Connecting to TCP socket at {}", address); in send_migration_socket()
1020 let socket = TcpStream::connect(address).map_err(|e| { in send_migration_socket() localVariable
1021 MigratableError::MigrateSend(anyhow!("Error connecting to TCP socket: {}", e)) in send_migration_socket()
1024 Ok(SocketStream::Tcp(socket)) in send_migration_socket()
1027 info!("Connecting to UNIX socket at {:?}", path); in send_migration_socket()
1029 let socket = UnixStream::connect(&path).map_err(|e| { in send_migration_socket() localVariable
1030 MigratableError::MigrateSend(anyhow!("Error connecting to UNIX socket: {}", e)) in send_migration_socket()
1033 Ok(SocketStream::Unix(socket)) in send_migration_socket()
1042 MigratableError::MigrateReceive(anyhow!("Error binding to TCP socket: {}", e)) in receive_migration_socket()
1045 let (socket, _addr) = listener.accept().map_err(|e| { in receive_migration_socket()
1047 "Error accepting connection on TCP socket: {}", in receive_migration_socket()
1052 Ok(SocketStream::Tcp(socket)) in receive_migration_socket()
1056 MigratableError::MigrateReceive(anyhow!("Error binding to UNIX socket: {}", e)) in receive_migration_socket()
1059 let (socket, _addr) = listener.accept().map_err(|e| { in receive_migration_socket()
1061 "Error accepting connection on UNIX socket: {}", in receive_migration_socket()
1066 // Remove the UNIX socket file after accepting the connection in receive_migration_socket()
1068 MigratableError::MigrateReceive(anyhow!("Error removing UNIX socket file: {}", e)) in receive_migration_socket()
1071 Ok(SocketStream::Unix(socket)) in receive_migration_socket()
1078 socket: &mut SocketStream, in vm_maybe_send_dirty_pages()
1088 Request::memory(table.length()).write_to(socket).unwrap(); in vm_maybe_send_dirty_pages()
1089 table.write_to(socket)?; in vm_maybe_send_dirty_pages()
1091 vm.send_memory_regions(&table, socket)?; in vm_maybe_send_dirty_pages()
1092 Response::read_from(socket)?.ok_or_abandon( in vm_maybe_send_dirty_pages()
1093 socket, in vm_maybe_send_dirty_pages()
1107 // Set up the socket connection in send_migration()
1108 let mut socket = Self::send_migration_socket(&send_data_migration.destination_url)?; in send_migration() localVariable
1111 Request::start().write_to(&mut socket)?; in send_migration()
1112 Response::read_from(&mut socket)?.ok_or_abandon( in send_migration()
1113 &mut socket, in send_migration()
1148 match &mut socket { in send_migration()
1150 // Proceed with sending memory file descriptors over UNIX socket in send_migration()
1168 Request::config(config_data.len() as u64).write_to(&mut socket)?; in send_migration()
1169 socket in send_migration()
1172 Response::read_from(&mut socket)?.ok_or_abandon( in send_migration()
1173 &mut socket, in send_migration()
1190 .write_to(&mut socket) in send_migration()
1192 table.write_to(&mut socket)?; in send_migration()
1194 vm.send_memory_regions(&table, &mut socket)?; in send_migration()
1195 Response::read_from(&mut socket)?.ok_or_abandon( in send_migration()
1196 &mut socket, in send_migration()
1204 if !Self::vm_maybe_send_dirty_pages(vm, &mut socket)? { in send_migration()
1213 Self::vm_maybe_send_dirty_pages(vm, &mut socket)?; in send_migration()
1224 Request::state(snapshot_data.len() as u64).write_to(&mut socket)?; in send_migration()
1225 socket in send_migration()
1228 Response::read_from(&mut socket)?.ok_or_abandon( in send_migration()
1229 &mut socket, in send_migration()
1234 Request::complete().write_to(&mut socket)?; in send_migration()
1235 Response::read_from(&mut socket)?.ok_or_abandon( in send_migration()
1236 &mut socket, in send_migration()
2145 // Accept the connection and get the socket in vm_receive_migration()
2146 let mut socket = Vmm::receive_migration_socket(&receive_data_migration.receiver_url)?; in vm_receive_migration() localVariable
2152 let req = Request::read_from(&mut socket)?; in vm_receive_migration()
2159 Response::ok().write_to(&mut socket)?; in vm_receive_migration()
2166 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2171 &mut socket, in vm_receive_migration()
2180 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2184 self.vm_receive_state(&req, &mut socket, mm)?; in vm_receive_migration()
2187 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2195 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2199 self.vm_receive_memory(&req, &mut socket, &mut mm.lock().unwrap())?; in vm_receive_migration()
2202 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2210 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2214 match &mut socket { in vm_receive_migration()
2219 "Error receiving slot from socket: {}", in vm_receive_migration()
2233 Response::ok().write_to(&mut socket)?; in vm_receive_migration()
2238 "MemoryFd command received over TCP socket, which is not supported" in vm_receive_migration()
2240 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2248 Response::ok().write_to(&mut socket)?; in vm_receive_migration()
2251 Response::error().write_to(&mut socket)?; in vm_receive_migration()
2259 Response::ok().write_to(&mut socket).ok(); in vm_receive_migration()
2407 socket: None, in create_dummy_vm_config()
2413 socket: None, in create_dummy_vm_config()
2502 UserDeviceConfig::parse("socket=/path/to/socket,id=8,pci_segment=2").unwrap(); in test_vmm_vm_cold_add_user_device()
2597 let fs_config = FsConfig::parse("tag=mytag,socket=/tmp/sock").unwrap(); in test_vmm_vm_cold_add_fs()
2683 "mac=de:ad:be:ef:12:34,host_mac=12:34:de:ad:be:ef,vhost_user=true,socket=/tmp/sock", in test_vmm_vm_cold_add_net()
2777 let vsock_config = VsockConfig::parse("socket=/tmp/sock,cid=3,iommu=on").unwrap(); in test_vmm_vm_cold_add_vsock()