| /qemu/util/ |
| H A D | vhost-user-server.c | 85 static void panic_cb(VuDev *vu_dev, const char *buf) in panic_cb() argument
111 vu_message_read(VuDev *vu_dev, int conn_fd, VhostUserMsg *vmsg) in vu_message_read() argument
120 VuServer *server = container_of(vu_dev, VuServer, vu_dev); in vu_message_read()
213 VuDev *vu_dev = &server->vu_dev; in vu_client_trip() local
215 while (!vu_dev->broken) { in vu_client_trip()
222 if (!vu_dispatch(vu_dev) && server->ctx) { in vu_client_trip()
235 vu_deinit(vu_dev); in vu_client_trip()
263 VuDev *vu_dev = vu_fd_watch->vu_dev; in kick_handler() local
265 vu_fd_watch->cb(vu_dev, 0, vu_fd_watch->pvt); in kick_handler()
268 if (vu_dev->broken) { in kick_handler()
[all …]
|
| /qemu/block/export/ |
| H A D | vhost-user-blk-server.c | 45 VuDev *vu_dev = &req->server->vu_dev; in vu_blk_req_complete() local
47 vu_queue_push(vu_dev, req->vq, &req->elem, in_len); in vu_blk_req_complete()
48 vu_queue_notify(vu_dev, req->vq); in vu_blk_req_complete()
82 static void vu_blk_process_vq(VuDev *vu_dev, int idx) in vu_blk_process_vq() argument
84 VuServer *server = container_of(vu_dev, VuServer, vu_dev); in vu_blk_process_vq()
85 VuVirtq *vq = vu_get_queue(vu_dev, idx); in vu_blk_process_vq()
90 req = vu_queue_pop(vu_dev, vq, sizeof(VuBlkReq)); in vu_blk_process_vq()
106 static void vu_blk_queue_set_started(VuDev *vu_dev, int idx, bool started) in vu_blk_queue_set_started() argument
110 assert(vu_dev); in vu_blk_queue_set_started()
112 vq = vu_get_queue(vu_dev, idx); in vu_blk_queue_set_started()
[all …]
|
| /qemu/contrib/vhost-user-scsi/ |
| H A D | vhost-user-scsi.c | 214 static void vus_panic_cb(VuDev *vu_dev, const char *buf) in vus_panic_cb() argument
219 assert(vu_dev); in vus_panic_cb()
221 gdev = container_of(vu_dev, VugDev, parent); in vus_panic_cb()
230 static void vus_proc_req(VuDev *vu_dev, int idx) in vus_proc_req() argument
237 assert(vu_dev); in vus_proc_req()
239 gdev = container_of(vu_dev, VugDev, parent); in vus_proc_req()
242 vq = vu_get_queue(vu_dev, idx); in vus_proc_req()
244 g_warning("Error fetching VQ (dev=%p, idx=%d)", vu_dev, idx); in vus_proc_req()
245 vus_panic_cb(vu_dev, NULL); in vus_proc_req()
255 elem = vu_queue_pop(vu_dev, vq, sizeof(VuVirtqElement)); in vus_proc_req()
[all …]
|
| /qemu/contrib/vhost-user-blk/ |
| H A D | vhost-user-blk.c | 84 static void vub_panic_cb(VuDev *vu_dev, const char *buf) in vub_panic_cb() argument
89 assert(vu_dev); in vub_panic_cb()
91 gdev = container_of(vu_dev, VugDev, parent); in vub_panic_cb()
103 VuDev *vu_dev = &gdev->parent; in vub_req_complete() local
106 vu_queue_push(vu_dev, req->vq, req->elem, in vub_req_complete()
108 vu_queue_notify(vu_dev, req->vq); in vub_req_complete()
229 VuDev *vu_dev = &gdev->parent; in vub_virtio_process_req() local
236 elem = vu_queue_pop(vu_dev, vq, sizeof(VuVirtqElement) + sizeof(VubReq)); in vub_virtio_process_req()
331 static void vub_process_vq(VuDev *vu_dev, int idx) in vub_process_vq() argument
338 gdev = container_of(vu_dev, VugDev, parent); in vub_process_vq()
[all …]
|
| /qemu/subprojects/libvhost-user/ |
| H A D | libvhost-user-glib.c | 105 set_watch(VuDev *vu_dev, int fd, int vu_evt, vu_watch_cb cb, void *pvt) in set_watch() argument
110 g_assert(vu_dev); in set_watch()
114 dev = container_of(vu_dev, VugDev, parent); in set_watch()
120 remove_watch(VuDev *vu_dev, int fd) in remove_watch() argument
124 g_assert(vu_dev); in remove_watch()
127 dev = container_of(vu_dev, VugDev, parent); in remove_watch()
|
| /qemu/include/qemu/ |
| H A D | vhost-user-server.h | 23 VuDev *vu_dev; member
49 VuDev vu_dev; member
|