Searched refs:snapshot_socket (Results 1 – 2 of 2) sorted by relevance
25 SharedFD read_fd, SharedFD snapshot_socket) { in WorkerInnerLoop() argument29 readable_fds.Set(snapshot_socket); in WorkerInnerLoop()49 if (readable_fds.IsSet(snapshot_socket)) { in WorkerInnerLoop()54 snapshot_socket->Read(&suspend_request, sizeof(suspend_request)), in WorkerInnerLoop()55 "socket read failed: " << snapshot_socket->StrError()); in WorkerInnerLoop()61 snapshot_socket->Write(&ack_response, sizeof(ack_response)), in WorkerInnerLoop()62 "socket write failed: " << snapshot_socket->StrError()); in WorkerInnerLoop()67 snapshot_socket->Read(&resume_request, sizeof(resume_request)), in WorkerInnerLoop()68 "socket read failed: " << snapshot_socket->StrError()); in WorkerInnerLoop()
61 mut snapshot_socket: std::os::unix::net::UnixStream, in ta_main()162 fd_set.insert(snapshot_socket.as_fd()); in ta_main()225 if fd_set.contains(snapshot_socket.as_fd()) { in ta_main()228 if let Err(e) = snapshot_socket.read_exact(std::slice::from_mut(&mut suspend_request)) { in ta_main()240 if let Err(e) = snapshot_socket.write_all(&[SNAPSHOT_SOCKET_MESSAGE_SUSPEND_ACK]) { in ta_main()246 if let Err(e) = snapshot_socket.read_exact(std::slice::from_mut(&mut resume_request)) { in ta_main()