Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 121) sorted by relevance

12345

/qemu/net/
A Dqueue.c65 NetQueue *queue; in qemu_new_net_queue() local
71 queue->nq_count = 0; in qemu_new_net_queue()
76 queue->delivering = 0; in qemu_new_net_queue()
78 return queue; in qemu_new_net_queue()
90 g_free(queue); in qemu_del_net_queue()
102 if (queue->nq_count >= queue->nq_maxlen && !sent_cb) { in qemu_net_queue_append()
112 queue->nq_count++; in qemu_net_queue_append()
127 if (queue->nq_count >= queue->nq_maxlen && !sent_cb) { in qemu_net_queue_append_iov()
147 queue->nq_count++; in qemu_net_queue_append_iov()
164 ret = queue->deliver(sender, flags, &iov, 1, queue->opaque); in qemu_net_queue_deliver()
[all …]
/qemu/ui/
A Dvnc-jobs.c70 static VncJobQueue *queue; variable
88 vnc_lock_queue(queue); in vnc_job_new()
105 vnc_lock_queue(queue); in vnc_job_add_rect()
113 vnc_lock_queue(queue); in vnc_job_push()
137 vnc_lock_queue(queue); in vnc_jobs_join()
139 qemu_cond_wait(&queue->cond, &queue->mutex); in vnc_jobs_join()
246 vnc_lock_queue(queue); in vnc_worker_thread_loop()
247 while (QTAILQ_EMPTY(&queue->jobs) && !queue->exit) { in vnc_worker_thread_loop()
248 qemu_cond_wait(&queue->cond, &queue->mutex); in vnc_worker_thread_loop()
254 if (queue->exit) { in vnc_worker_thread_loop()
[all …]
A Dinput.c236 QemuInputEventQueueHead *queue = opaque; in qemu_input_queue_process() local
239 g_assert(!QTAILQ_EMPTY(queue)); in qemu_input_queue_process()
240 item = QTAILQ_FIRST(queue); in qemu_input_queue_process()
242 QTAILQ_REMOVE(queue, item, node); in qemu_input_queue_process()
246 while (!QTAILQ_EMPTY(queue)) { in qemu_input_queue_process()
247 item = QTAILQ_FIRST(queue); in qemu_input_queue_process()
261 QTAILQ_REMOVE(queue, item, node); in qemu_input_queue_process()
271 bool start_timer = QTAILQ_EMPTY(queue); in qemu_input_queue_delay()
276 QTAILQ_INSERT_TAIL(queue, item, node); in qemu_input_queue_delay()
293 QTAILQ_INSERT_TAIL(queue, item, node); in qemu_input_queue_event()
[all …]
/qemu/include/qemu/
A Dcoroutine.h102 void qemu_co_queue_init(CoQueue *queue);
117 #define qemu_co_queue_wait(queue, lock) \ argument
118 qemu_co_queue_wait_impl(queue, QEMU_MAKE_LOCKABLE(lock), 0)
119 #define qemu_co_queue_wait_flags(queue, lock, flags) \ argument
130 bool coroutine_fn qemu_co_queue_next(CoQueue *queue);
137 void coroutine_fn qemu_co_queue_restart_all(CoQueue *queue);
148 #define qemu_co_enter_next(queue, lock) \ argument
149 qemu_co_enter_next_impl(queue, QEMU_MAKE_LOCKABLE(lock))
161 #define qemu_co_enter_all(queue, lock) \ argument
162 qemu_co_enter_all_impl(queue, QEMU_MAKE_LOCKABLE(lock))
[all …]
/qemu/hw/usb/
A Dhcd-uhci.c80 UHCIQueue *queue; member
126 UHCIQueue *queue; in uhci_queue_new() local
129 queue->uhci = s; in uhci_queue_new()
132 queue->ep = ep; in uhci_queue_new()
137 return queue; in uhci_queue_new()
149 usb_device_ep_stopped(queue->ep->dev, queue->ep); in uhci_queue_free()
153 g_free(queue); in uhci_queue_free()
159 UHCIQueue *queue; in uhci_queue_find() local
186 async->queue = queue; in uhci_async_alloc()
206 UHCIQueue *queue = async->queue; in uhci_async_link() local
[all …]
A Dcore.c413 QTAILQ_INSERT_TAIL(&p->ep->queue, p, queue); in usb_queue_one()
433 assert(QTAILQ_EMPTY(&p->ep->queue)); in usb_handle_packet()
446 QTAILQ_INSERT_TAIL(&p->ep->queue, p, queue); in usb_handle_packet()
479 QTAILQ_REMOVE(&ep->queue, p, queue); in usb_packet_complete_one()
493 while (!QTAILQ_EMPTY(&ep->queue)) { in usb_packet_complete()
494 p = QTAILQ_FIRST(&ep->queue); in usb_packet_complete()
522 QTAILQ_REMOVE(&p->ep->queue, p, queue); in usb_cancel_packet()
687 QTAILQ_INIT(&dev->ep_ctl.queue); in usb_ep_init()
689 QTAILQ_INIT(&dev->ep_in[ep].queue); in usb_ep_init()
690 QTAILQ_INIT(&dev->ep_out[ep].queue); in usb_ep_init()
[all …]
/qemu/include/net/
A Dqueue.h49 void qemu_net_queue_append_iov(NetQueue *queue,
56 void qemu_del_net_queue(NetQueue *queue);
58 ssize_t qemu_net_queue_receive(NetQueue *queue,
62 ssize_t qemu_net_queue_send(NetQueue *queue,
69 ssize_t qemu_net_queue_send_iov(NetQueue *queue,
76 void qemu_net_queue_purge(NetQueue *queue, NetClientState *from);
77 bool qemu_net_queue_flush(NetQueue *queue);
/qemu/backends/
A Dcryptodev-vhost.c120 uint16_t queue) in cryptodev_get_vhost() argument
151 uint16_t queue, int enable) in vhost_set_vring_enable() argument
272 int queue, in cryptodev_vhost_virtqueue_mask() argument
280 assert(queue < MAX_CRYPTO_QUEUE_NUM); in cryptodev_vhost_virtqueue_mask()
282 cc = b->conf.peers.ccs[queue]; in cryptodev_vhost_virtqueue_mask()
283 vhost_crypto = cryptodev_get_vhost(cc, b, queue); in cryptodev_vhost_virtqueue_mask()
296 assert(queue < MAX_CRYPTO_QUEUE_NUM); in cryptodev_vhost_virtqueue_pending()
298 cc = b->conf.peers.ccs[queue]; in cryptodev_vhost_virtqueue_pending()
299 vhost_crypto = cryptodev_get_vhost(cc, b, queue); in cryptodev_vhost_virtqueue_pending()
324 uint16_t queue) in cryptodev_get_vhost() argument
[all …]
/qemu/util/
A Dqemu-coroutine-lock.c36 void qemu_co_queue_init(CoQueue *queue) in qemu_co_queue_init() argument
38 QSIMPLEQ_INIT(&queue->entries); in qemu_co_queue_init()
78 next = QSIMPLEQ_FIRST(&queue->entries); in qemu_co_enter_next_impl()
83 QSIMPLEQ_REMOVE_HEAD(&queue->entries, co_queue_next); in qemu_co_enter_next_impl()
94 bool coroutine_fn qemu_co_queue_next(CoQueue *queue) in qemu_co_queue_next() argument
97 return qemu_co_enter_next_impl(queue, NULL); in qemu_co_queue_next()
102 while (qemu_co_enter_next_impl(queue, lock)) { in qemu_co_enter_all_impl()
107 void coroutine_fn qemu_co_queue_restart_all(CoQueue *queue) in qemu_co_queue_restart_all() argument
110 qemu_co_enter_all_impl(queue, NULL); in qemu_co_queue_restart_all()
113 bool qemu_co_queue_empty(CoQueue *queue) in qemu_co_queue_empty() argument
[all …]
A Dqemu-co-shared-resource.c35 CoQueue queue; member
45 qemu_co_queue_init(&s->queue); in shres_create()
74 qemu_co_queue_wait(&s->queue, &s->lock); in co_get_from_shres()
83 qemu_co_queue_restart_all(&s->queue); in co_put_to_shres()
/qemu/tests/qtest/fuzz/
A Dvirtio_scsi_fuzz.c74 uint8_t queue; in virtio_scsi_fuzz() member
98 vqa.queue = vqa.queue % queues->num_queues; in virtio_scsi_fuzz()
106 q = queues->vq[vqa.queue]; in virtio_scsi_fuzz()
111 if (vq_touched[vqa.queue] == 0) { in virtio_scsi_fuzz()
112 vq_touched[vqa.queue] = 1; in virtio_scsi_fuzz()
113 free_head[vqa.queue] = qvirtqueue_add(s, q, req_addr, vqa.length, in virtio_scsi_fuzz()
120 qvirtqueue_kick(s, dev, q, free_head[vqa.queue]); in virtio_scsi_fuzz()
121 free_head[vqa.queue] = 0; in virtio_scsi_fuzz()
A Dvirtio_blk_fuzz.c71 uint8_t queue; in virtio_blk_fuzz() member
95 vqa.queue = vqa.queue % queues->num_queues; in virtio_blk_fuzz()
102 q = queues->vq[vqa.queue]; in virtio_blk_fuzz()
107 if (vq_touched[vqa.queue] == 0) { in virtio_blk_fuzz()
108 vq_touched[vqa.queue] = 1; in virtio_blk_fuzz()
109 free_head[vqa.queue] = qvirtqueue_add(s, q, req_addr, vqa.length, in virtio_blk_fuzz()
116 qvirtqueue_kick(s, dev, q, free_head[vqa.queue]); in virtio_blk_fuzz()
117 free_head[vqa.queue] = 0; in virtio_blk_fuzz()
/qemu/hw/i386/
A Dvmmouse.c66 uint32_t queue[VMMOUSE_QUEUE_SIZE]; member
131 s->queue[s->nb_queue++] = buttons; in vmmouse_mouse_event()
132 s->queue[s->nb_queue++] = x; in vmmouse_mouse_event()
133 s->queue[s->nb_queue++] = y; in vmmouse_mouse_event()
134 s->queue[s->nb_queue++] = dz; in vmmouse_mouse_event()
173 s->queue[s->nb_queue++] = VMMOUSE_VERSION; in vmmouse_read_id()
214 data[i] = s->queue[i]; in vmmouse_data()
218 memmove(s->queue, &s->queue[size], sizeof(s->queue[0]) * s->nb_queue); in vmmouse_data()
282 VMSTATE_UINT32_ARRAY(queue, VMMouseState, VMMOUSE_QUEUE_SIZE),
/qemu/hw/nvme/
A Dtrace-events53 pci_nvme_del_sq(uint16_t qid) "deleting submission queue sqid=%"PRIu16""
54 pci_nvme_del_cq(uint16_t cqid) "deleted completion queue, cqid=%"PRIu16""
97 pci_nvme_mmio_aqattr(uint64_t data) "wrote MMIO, admin queue attributes=0x%"PRIx64""
98 pci_nvme_mmio_asqaddr(uint64_t data) "wrote MMIO, admin submission queue address=0x%"PRIx64""
99 pci_nvme_mmio_acqaddr(uint64_t data) "wrote MMIO, admin completion queue address=0x%"PRIx64""
159 pci_nvme_err_invalid_del_sq(uint16_t qid) "invalid submission queue deletion, sid=%"PRIu16""
165 pci_nvme_err_invalid_del_cq_cqid(uint16_t cqid) "failed deleting completion queue, cqid=%"PRIu16""
214 pci_nvme_ub_db_wr_invalid_cq(uint32_t qid) "completion queue doorbell write for nonexistent queue, …
215 …alid_cqhead(uint32_t qid, uint16_t new_head) "completion queue doorbell write value beyond queue s…
216 pci_nvme_ub_db_wr_invalid_sq(uint32_t qid) "submission queue doorbell write for nonexistent queue, …
[all …]
/qemu/hw/virtio/
A Dvirtio-qmp.c819 if (queue < hdev->vq_index || queue >= hdev->vq_index + hdev->nvqs) { in qmp_x_query_virtio_vhost_queue_status()
826 status->kick = hdev->vqs[queue].kick; in qmp_x_query_virtio_vhost_queue_status()
827 status->call = hdev->vqs[queue].call; in qmp_x_query_virtio_vhost_queue_status()
828 status->desc = (uintptr_t)hdev->vqs[queue].desc; in qmp_x_query_virtio_vhost_queue_status()
830 status->used = (uintptr_t)hdev->vqs[queue].used; in qmp_x_query_virtio_vhost_queue_status()
831 status->num = hdev->vqs[queue].num; in qmp_x_query_virtio_vhost_queue_status()
832 status->desc_phys = hdev->vqs[queue].desc_phys; in qmp_x_query_virtio_vhost_queue_status()
833 status->desc_size = hdev->vqs[queue].desc_size; in qmp_x_query_virtio_vhost_queue_status()
834 status->avail_phys = hdev->vqs[queue].avail_phys; in qmp_x_query_virtio_vhost_queue_status()
836 status->used_phys = hdev->vqs[queue].used_phys; in qmp_x_query_virtio_vhost_queue_status()
[all …]
A Dvirtio-stub.c22 uint16_t queue, in qmp_x_query_virtio_vhost_queue_status() argument
29 uint16_t queue, in qmp_x_query_virtio_queue_status() argument
36 uint16_t queue, in qmp_x_query_virtio_queue_element() argument
/qemu/scripts/qemugdb/
A Dmtree.py35 self.queue = []
43 self.queue.append(ptr)
45 while self.queue:
46 ptr = self.queue.pop(0)
80 self.queue.append(alias)
/qemu/qapi/
A Dvirtio.json142 # @queue-sel: VirtIODevice queue_sel
179 'queue-sel': 'uint16',
508 # @queue-index: VirtQueue queue_index
539 'queue-index': 'uint16',
554 # @x-query-virtio-queue-status:
560 # @queue: VirtQueue index to examine
689 # @x-query-virtio-vhost-queue-status:
695 # @queue: vhost_virtqueue index to examine
835 # @x-query-virtio-queue-element:
841 # @queue: VirtQueue index to examine
[all …]
A Dcryptodev.json64 # Information about a queue of crypto device.
66 # @queue: the queue index of the crypto device
73 'data': { 'queue': 'uint32',
/qemu/hw/input/
A Dvirtio-input.c35 vinput->queue = g_realloc(vinput->queue, vinput->qsize * in virtio_input_send()
36 sizeof(vinput->queue[0])); in virtio_input_send()
38 vinput->queue[vinput->qindex++].event = *event; in virtio_input_send()
51 virtqueue_unpop(vinput->evt, vinput->queue[i].elem, 0); in virtio_input_send()
57 vinput->queue[i].elem = elem; in virtio_input_send()
62 elem = vinput->queue[i].elem; in virtio_input_send()
64 0, &vinput->queue[i].event, sizeof(virtio_input_event)); in virtio_input_send()
275 g_free(vinput->queue); in virtio_input_finalize()
A Dps2.c148 PS2Queue *q = &s->queue; in ps2_reset_queue()
158 return s->queue.count == 0; in ps2_queue_empty()
163 PS2Queue *q = &s->queue; in ps2_queue_noirq()
188 if (PS2_QUEUE_SIZE - s->queue.count < 1) { in ps2_queue()
198 if (PS2_QUEUE_SIZE - s->queue.count < 2) { in ps2_queue_2()
243 PS2Queue *q = &s->queue; in ps2_cqueue_1()
253 PS2Queue *q = &s->queue; in ps2_cqueue_2()
264 PS2Queue *q = &s->queue; in ps2_cqueue_3()
276 PS2Queue *q = &s->queue; in ps2_cqueue_reset()
546 q = &s->queue; in ps2_read_data()
[all …]
/qemu/contrib/vhost-user-input/
A Dmain.c35 } *queue; member
49 vi->queue = g_realloc_n(vi->queue, vi->qsize, sizeof(vi->queue[0])); in vi_input_send()
51 vi->queue[vi->qindex++].event = *event; in vi_input_send()
64 vu_queue_unpop(dev, vq, vi->queue[i].elem, 0); in vi_input_send()
70 vi->queue[i].elem = elem; in vi_input_send()
75 elem = vi->queue[i].elem; in vi_input_send()
77 0, &vi->queue[i].event, sizeof(virtio_input_event)); in vi_input_send()
410 g_free(vi.queue); in main()
/qemu/include/sysemu/
A Dcryptodev-vhost.h103 uint16_t queue);
136 int queue,
151 int queue, int idx);
/qemu/docs/
A Dcolo-proxy.txt174 -object filter-mirror,id=m0,netdev=hn0,queue=tx,outdev=mirror0
175 -object filter-redirector,netdev=hn0,id=redire0,queue=rx,indev=compare_out
176 -object filter-redirector,netdev=hn0,id=redire1,queue=rx,outdev=compare0
184 -object filter-redirector,id=f1,netdev=hn0,queue=tx,indev=red0
185 -object filter-redirector,id=f2,netdev=hn0,queue=rx,outdev=red1
186 -object filter-rewriter,id=f3,netdev=hn0,queue=all
199 -object filter-mirror,id=m0,netdev=hn0,queue=tx,outdev=mirror0,vnet_hdr_support
201 -object filter-redirector,netdev=hn0,id=redire1,queue=rx,outdev=compare0,vnet_hdr_support
209 -object filter-redirector,id=f1,netdev=hn0,queue=tx,indev=red0,vnet_hdr_support
210 -object filter-redirector,id=f2,netdev=hn0,queue=rx,outdev=red1,vnet_hdr_support
[all …]
/qemu/
A Dhmp-commands-info.hx928 .name = "virtio-queue-status",
929 .args_type = "path:s,queue:i",
930 .params = "path queue",
937 ``info virtio-queue-status`` *path* *queue*
938 Display status of a given virtio queue
943 .args_type = "path:s,queue:i",
944 .params = "path queue",
951 ``info virtio-vhost-queue-status`` *path* *queue*
952 Display status of a given vhost queue
958 .params = "path queue [index]",
[all …]

Completed in 59 milliseconds

12345