| /external/crosvm/third_party/vmm_vhost/src/ |
| D | slave_proxy.rs | 25 sock: Box<dyn Endpoint<SlaveReq>>,
37 request: SlaveReq, in send_message() argument
54 fn wait_for_reply(&mut self, hdr: &VhostUserMsgHeader<SlaveReq>) -> Result<u64> { in wait_for_reply()
55 if hdr.get_code() != SlaveReq::SHMEM_MAP in wait_for_reply()
56 && hdr.get_code() != SlaveReq::SHMEM_UNMAP in wait_for_reply()
57 && hdr.get_code() != SlaveReq::GPU_MAP in wait_for_reply()
91 pub fn new(ep: Box<dyn Endpoint<SlaveReq>>) -> Self { in new()
107 request: SlaveReq, in send_message() argument
146 self.send_message(SlaveReq::SHMEM_MAP, req, Some(&[fd.as_raw_descriptor()])) in shmem_map()
151 self.send_message(SlaveReq::SHMEM_UNMAP, req, None) in shmem_unmap()
[all …]
|
| D | master_req_handler.rs | 322 SlaveReq::CONFIG_CHANGE_MSG => { in handle_request()
328 SlaveReq::SHMEM_MAP => { in handle_request()
335 SlaveReq::SHMEM_UNMAP => { in handle_request()
341 SlaveReq::FS_MAP => { in handle_request()
348 SlaveReq::FS_UNMAP => { in handle_request()
354 SlaveReq::FS_SYNC => { in handle_request()
360 SlaveReq::FS_IO => { in handle_request()
367 SlaveReq::GPU_MAP => { in handle_request()
384 hdr: &VhostUserMsgHeader<SlaveReq>, in check_msg_size() argument
400 hdr: &VhostUserMsgHeader<SlaveReq>, in check_attached_files() argument
[all …]
|
| D | message.rs | 170 pub enum SlaveReq { enum
201 impl From<SlaveReq> for u32 {
202 fn from(req: SlaveReq) -> u32 { in from()
207 impl Req for SlaveReq { implementation
209 (*self > SlaveReq::NOOP) && (*self < SlaveReq::MAX_CMD) in is_valid()
1212 let code = SlaveReq::NOOP; in check_slave_request_code()
1214 let code = SlaveReq::MAX_CMD; in check_slave_request_code()
1216 assert!(code > SlaveReq::NOOP); in check_slave_request_code()
1217 let code = SlaveReq::CONFIG_CHANGE_MSG; in check_slave_request_code()
1220 let code: SlaveReq = unsafe { std::mem::transmute::<u32, SlaveReq>(10000u32) }; in check_slave_request_code()
|
| D | slave_req_handler.rs | 100 fn set_slave_req_fd(&self, _vu_req: Box<dyn Endpoint<SlaveReq>>) {} in set_slave_req_fd() argument
149 fn set_slave_req_fd(&mut self, _vu_req: Box<dyn Endpoint<SlaveReq>>) {} in set_slave_req_fd() argument
248 fn set_slave_req_fd(&self, vu_req: Box<dyn Endpoint<SlaveReq>>) { in set_slave_req_fd() argument
366 fn set_slave_req_fd(&self, vu_req: Box<dyn Endpoint<SlaveReq>>) { in set_slave_req_fd() argument
|
| D | connection.rs | 82 ) -> Result<Box<dyn Endpoint<SlaveReq>>>; in create_slave_request_endpoint() argument
|
| /external/crosvm/third_party/vmm_vhost/src/sys/ |
| D | windows.rs | 14 use crate::message::{MasterReq, SlaveReq};
16 pub(crate) type SlaveReqEndpoint = TubeEndpoint<SlaveReq>;
|
| D | unix.rs | 19 use crate::message::{MasterReq, SlaveReq};
21 pub(crate) type SlaveReqEndpoint = SocketEndpoint<SlaveReq>;
|
| /external/crosvm/devices/src/virtio/vhost/user/device/vvu/ |
| D | device.rs | 350 backend_channel: Option<VfioEndpoint<SlaveReq, BackendChannel>>,
471 fn create_slave_request_endpoint(&mut self) -> Result<Box<dyn Endpoint<SlaveReq>>> { in create_slave_request_endpoint() argument
519 fn create_slave_request_endpoint(&mut self) -> Result<Box<dyn Endpoint<SlaveReq>>> { in create_slave_request_endpoint() argument
535 let hdr = vhost_header_from_bytes::<SlaveReq>(&msg).expect("framing error"); in preprocess_tx()
539 SlaveReq::SHMEM_MAP => { in preprocess_tx()
569 SlaveReq::SHMEM_UNMAP => { in preprocess_tx()
601 let hdr = vhost_header_from_bytes::<SlaveReq>(&msg).unwrap(); in postprocess_rx()
603 if hdr.get_code() == SlaveReq::SHMEM_UNMAP { in postprocess_rx()
|
| /external/crosvm/third_party/vmm_vhost/src/connection/ |
| D | vfio.rs | 24 use crate::message::SlaveReq;
73 ) -> std::result::Result<Box<dyn EndpointTrait<SlaveReq>>, anyhow::Error>; in create_slave_request_endpoint() argument
164 ) -> Result<Box<dyn EndpointTrait<SlaveReq>>> { in create_slave_request_endpoint() argument
|
| D | tube.rs | 25 use crate::message::SlaveReq;
162 ) -> Result<Box<dyn Endpoint<SlaveReq>>> { in create_slave_request_endpoint() argument
|
| D | socket.rs | 224 ) -> Result<Box<dyn EndpointTrait<SlaveReq>>> { in create_slave_request_endpoint() argument
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | proxy.rs | 64 use vmm_vhost::message::SlaveReq;
282 slave_req_fd: Option<SocketEndpoint<SlaveReq>>,
403 impl RxAction for SlaveReq { implementation
404 fn is_header_valid(hdr: &VhostUserMsgHeader<SlaveReq>) -> bool { in is_header_valid()
414 hdr: &VhostUserMsgHeader<SlaveReq>, in process_message() argument
422 SlaveReq::SHMEM_UNMAP => worker.handle_unmap_reply(payload), in process_message()
427 fn get_ep(worker: &mut Worker) -> &mut SocketEndpoint<SlaveReq> { in get_ep() argument
432 fn handle_failure(_worker: &mut Worker, hdr: &VhostUserMsgHeader<SlaveReq>) -> Result<()> { in handle_failure()
487 self.process_rx::<SlaveReq>(&mut wait_ctx) in run()
1056 let hdr = vhost_header_from_bytes::<SlaveReq>(&msg).unwrap(); in process_message_from_backend()
[all …]
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | vsock.rs | 28 use vmm_vhost::message::SlaveReq;
435 fn set_slave_req_fd(&mut self, _vu_req: Box<dyn Endpoint<SlaveReq>>) { in set_slave_req_fd() argument
|
| D | handler.rs | 76 use vmm_vhost::message::SlaveReq;
645 fn set_slave_req_fd(&mut self, ep: Box<dyn Endpoint<SlaveReq>>) { in set_slave_req_fd() argument
|