Home
last modified time | relevance | path

Searched full:queue (Results 1 – 25 of 801) sorted by relevance

12345678910>>...33

/openbmc/qemu/net/
H A Dqueue.c25 #include "net/queue.h"
26 #include "qemu/queue.h"
36 * until we have invoked the callback. Only in that case will we queue
65 NetQueue *queue; in qemu_new_net_queue() local
67 queue = g_new0(NetQueue, 1); in qemu_new_net_queue()
69 queue->opaque = opaque; in qemu_new_net_queue()
70 queue->nq_maxlen = 10000; in qemu_new_net_queue()
71 queue->nq_count = 0; in qemu_new_net_queue()
72 queue->deliver = deliver; in qemu_new_net_queue()
74 QTAILQ_INIT(&queue->packets); in qemu_new_net_queue()
[all …]
/openbmc/qemu/ui/
H A Dvnc-jobs.c41 * - jobs queue lock: for each operation on the queue (push, pop, isEmpty?)
67 * We use a single global queue, but most of the functions are
70 static VncJobQueue *queue; variable
72 static void vnc_lock_queue(VncJobQueue *queue) in vnc_lock_queue() argument
74 qemu_mutex_lock(&queue->mutex); in vnc_lock_queue()
77 static void vnc_unlock_queue(VncJobQueue *queue) in vnc_unlock_queue() argument
79 qemu_mutex_unlock(&queue->mutex); in vnc_unlock_queue()
88 vnc_lock_queue(queue); in vnc_job_new()
90 vnc_unlock_queue(queue); in vnc_job_new()
105 vnc_lock_queue(queue); in vnc_job_add_rect()
[all …]
/openbmc/phosphor-host-ipmid/
H A Dhost-cmd-manager.hpp8 #include <queue>
38 /** @brief Extracts the next entry in the queue and returns
46 * Also, if the queue has more commands, then it will alert the
51 /** @brief Pushes the command onto the queue.
53 * @detail If the queue is empty, then it alerts the Host. If not,
55 * the commands in Queue.
62 /** @brief Check if anything in queue and alert host if so */
68 * to all the commands that are in the Queue and queue
73 /** @brief Clears the command queue
75 * @detail Clears the command queue and calls all callbacks
[all …]
/openbmc/qemu/include/system/
H A Dcryptodev-vhost.h52 * Get the maximum queue number of @crypto.
55 * Returns: the maximum queue number
91 * @cc: the client object for each queue
93 * @queue: the cryptodev backend queue index
96 * @b and @queue
103 uint16_t queue);
107 * @total_queues: the total count of queue
118 * @total_queues: the total count of queue
128 * @queue: the cryptodev backend queue index
136 int queue,
[all …]
H A Dcryptodev-vhost-user.h35 * @cc: the client object for each queue
37 * @queue: the queue index
40 * @b and @queue
48 uint16_t queue);
/openbmc/u-boot/drivers/virtio/
H A Dvirtio_mmio.h51 /* Queue selector - Write Only */
54 /* Maximum size of the currently selected queue - Read Only */
57 /* Queue size for the currently selected queue - Write Only */
62 /* Used Ring alignment for the currently selected queue - Write Only */
65 /* Guest's PFN for the currently selected queue - Read Write */
70 /* Ready bit for the currently selected queue - Read Write */
73 /* Queue notifier - Write Only */
85 /* Selected queue's Descriptor Table address, 64 bits in two halves */
89 /* Selected queue's Available Ring address, 64 bits in two halves */
93 /* Selected queue's Used Ring address, 64 bits in two halves */
H A Dvirtio_pci.h19 /* A 32-bit r/w PFN for the currently selected queue */
22 /* A 16-bit r/o queue size for the currently selected queue */
25 /* A 16-bit r/w queue selector */
28 /* A 16-bit r/w queue notifier */
45 /* A 16-bit vector for selected queue notifications */
58 * How many bits to shift physical queue address written to QUEUE_PFN.
73 /* Vector value used to disable MSI for queue */
/openbmc/u-boot/drivers/net/
H A Dep93xx_eth.h15 * #define this to dump device status and queue info during initialization and
37 * Receive descriptor queue entry
45 * Receive status queue entry
57 * Transmit descriptor queue entry
67 * Transmit status queue entry
77 * Transmit descriptor queue
86 * Transmit status queue
95 * Receive descriptor queue
104 * Receive status queue
H A Dmvneta.c136 /* Exception Interrupt Port/Queue Cause register */
141 /* bits 0..7 = TXQ SENT, one bit per queue.
142 * bits 8..15 = RXQ OCCUP, one bit per queue.
143 * bits 16..23 = RXQ FREE, one bit per queue.
156 /* Data Path Port/Queue Cause Register */
339 /* Number of this TX queue, in the range 0-7 */
365 /* rx queue number, in the range 0-7 */
579 int queue; in mvneta_port_up() local
585 for (queue = 0; queue < txq_number; queue++) { in mvneta_port_up()
586 struct mvneta_tx_queue *txq = &pp->txqs[queue]; in mvneta_port_up()
[all …]
/openbmc/u-boot/drivers/usb/musb-new/
H A Dmusb_uboot.c124 struct int_queue *queue; in _musb_create_int_queue() local
137 queue = malloc(sizeof(*queue)); in _musb_create_int_queue()
138 if (!queue) in _musb_create_int_queue()
141 construct_urb(&queue->urb, &queue->hep, dev, USB_ENDPOINT_XFER_INT, in _musb_create_int_queue()
144 ret = musb_urb_enqueue(&host->hcd, &queue->urb, 0); in _musb_create_int_queue()
147 free(queue); in _musb_create_int_queue()
152 return queue; in _musb_create_int_queue()
156 struct usb_device *dev, struct int_queue *queue) in _musb_destroy_int_queue() argument
158 int index = usb_pipein(queue->urb.pipe) * 16 + in _musb_destroy_int_queue()
159 usb_pipeendpoint(queue->urb.pipe); in _musb_destroy_int_queue()
[all …]
/openbmc/qemu/hw/nvme/
H A Dtrace-events51 … sqid, uint16_t cqid, uint16_t qsize, uint16_t qflags) "create submission queue, addr=0x%"PRIx64",…
52 …t16_t vector, uint16_t size, uint16_t qflags, int ien) "create completion queue, addr=0x%"PRIx64",…
53 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""
100 pci_nvme_mmio_asqaddr_hi(uint64_t data, uint64_t new_addr) "wrote MMIO, admin submission queue high…
101 pci_nvme_mmio_acqaddr_hi(uint64_t data, uint64_t new_addr) "wrote MMIO, admin completion queue high…
159 pci_nvme_err_invalid_del_sq(uint16_t qid) "invalid submission queue deletion, sid=%"PRIu16""
[all …]
/openbmc/qemu/hw/usb/
H A Dhcd-uhci.c80 UHCIQueue *queue; member
126 UHCIQueue *queue; in uhci_queue_new() local
128 queue = g_new0(UHCIQueue, 1); in uhci_queue_new()
129 queue->uhci = s; in uhci_queue_new()
130 queue->qh_addr = qh_addr; in uhci_queue_new()
131 queue->token = uhci_queue_token(td); in uhci_queue_new()
132 queue->ep = ep; in uhci_queue_new()
133 QTAILQ_INIT(&queue->asyncs); in uhci_queue_new()
134 QTAILQ_INSERT_HEAD(&s->queues, queue, next); in uhci_queue_new()
135 queue->valid = QH_VALID; in uhci_queue_new()
[all …]
/openbmc/qemu/include/net/
H A Dqueue.h38 * 0 - queue packet for future redelivery
49 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);
/openbmc/qemu/include/qemu/
H A Dcoroutine.h20 #include "qemu/queue.h"
60 /* A queue of waiters. Elements are added atomically in front of
91 * CoQueues are a mechanism to queue coroutines in order to continue executing
103 void qemu_co_queue_init(CoQueue *queue);
107 * Enqueue at front instead of back. Use this to re-queue a request when
118 #define qemu_co_queue_wait(queue, lock) \ argument
119 qemu_co_queue_wait_impl(queue, QEMU_MAKE_LOCKABLE(lock), 0)
120 #define qemu_co_queue_wait_flags(queue, lock, flags) \ argument
121 qemu_co_queue_wait_impl(queue, QEMU_MAKE_LOCKABLE(lock), (flags))
122 void coroutine_fn qemu_co_queue_wait_impl(CoQueue *queue, QemuLockable *lock,
[all …]
/openbmc/qemu/tests/qtest/fuzz/
H A Dvirtio_scsi_fuzz.c74 uint8_t queue; in virtio_scsi_fuzz() member
81 /* Keep track of the free head for each queue we interact with */ in virtio_scsi_fuzz()
92 /* Copy the action, so we can normalize length, queue and flags */ in virtio_scsi_fuzz()
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()
[all …]
H A Dvirtio_blk_fuzz.c71 uint8_t queue; in virtio_blk_fuzz() member
78 /* Keep track of the free head for each queue we interact with */ in virtio_blk_fuzz()
89 /* Copy the action, so we can normalize length, queue and flags */ in virtio_blk_fuzz()
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()
[all …]
/openbmc/qemu/include/standard-headers/linux/
H A Dvirtio_mmio.h77 /* Queue selector - Write Only */
80 /* Maximum size of the currently selected queue - Read Only */
83 /* Queue size for the currently selected queue - Write Only */
89 /* Used Ring alignment for the currently selected queue - Write Only */
92 /* Guest's PFN for the currently selected queue - Read Write */
98 /* Ready bit for the currently selected queue - Read Write */
101 /* Queue notifier - Write Only */
113 /* Selected queue's Descriptor Table address, 64 bits in two halves */
117 /* Selected queue's Available Ring address, 64 bits in two halves */
121 /* Selected queue's Used Ring address, 64 bits in two halves */
/openbmc/qemu/subprojects/libvhost-user/
H A Dlibvhost-user.h264 * If the queue is processed in order, in which case it will be
315 * Backend could get it from queue size field of VhostUserInflight.
524 * @qidx: queue index
526 * Returns the queue number @qidx.
533 * @vq: a VuVirtq queue
534 * @handler: the queue handler callback
536 * Set the queue handler. This function may be called several times
537 * for the same queue. If called with NULL @handler, the handler is
546 * @vq: a VuVirtq queue
551 * Set queue's host notifier. This function may be called several
[all …]
/openbmc/qemu/backends/
H A Dcryptodev-vhost.c66 /* vhost-user needs vq_index to initiate a specific queue pair */ in cryptodev_vhost_init()
120 uint16_t queue) in cryptodev_get_vhost() argument
131 vhost_crypto = cryptodev_vhost_user_get_vhost(cc, b, queue); in cryptodev_get_vhost()
151 uint16_t queue, int enable) in vhost_set_vring_enable() argument
154 cryptodev_get_vhost(cc, b, queue); in vhost_set_vring_enable()
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()
289 int queue, int idx) in cryptodev_vhost_virtqueue_pending() argument
[all …]
/openbmc/u-boot/include/fsl-mc/
H A Dfsl_dpni.h140 #define DPNI_CMD_SET_BUFFER_LAYOUT(cmd, layout, queue) \ argument
142 MC_CMD_OP(cmd, 0, 0, 8, enum dpni_queue_type, queue); \
229 #define DPNI_RSP_GET_QUEUE(cmd, queue) \ argument
231 MC_RSP_OP(cmd, 1, 0, 32, uint32_t, (queue)->destination.id); \
232 MC_RSP_OP(cmd, 1, 56, 4, enum dpni_dest, (queue)->destination.type); \
233 MC_RSP_OP(cmd, 1, 62, 1, char, (queue)->destination.stash_ctrl); \
234 MC_RSP_OP(cmd, 1, 63, 1, char, (queue)->destination.hold_active); \
235 MC_RSP_OP(cmd, 2, 0, 64, uint64_t, (queue)->flc); \
236 MC_RSP_OP(cmd, 3, 0, 64, uint64_t, (queue)->user_context); \
237 MC_RSP_OP(cmd, 4, 0, 32, uint32_t, (queue)->fqid); \
[all …]
/openbmc/qemu/qapi/
H A Dvirtio.json144 # @queue-sel: VirtIODevice queue_sel
181 'queue-sel': 'uint16',
261 # "queue-sel": 1,
433 # "queue-sel": 2,
510 # @queue-index: VirtQueue queue_index
541 'queue-index': 'uint16',
556 # @x-query-virtio-queue-status:
562 # @queue: VirtQueue index to examine
568 # Returns: Status of the queue
572 # VirtIODevice VirtQueue index (queue) does not exist for the
[all …]
/openbmc/qemu/util/
H A Dqemu-coroutine-lock.c32 #include "qemu/queue.h"
36 void qemu_co_queue_init(CoQueue *queue) in qemu_co_queue_init() argument
38 QSIMPLEQ_INIT(&queue->entries); in qemu_co_queue_init()
41 void coroutine_fn qemu_co_queue_wait_impl(CoQueue *queue, QemuLockable *lock, in qemu_co_queue_wait_impl() argument
46 QSIMPLEQ_INSERT_HEAD(&queue->entries, self, co_queue_next); in qemu_co_queue_wait_impl()
48 QSIMPLEQ_INSERT_TAIL(&queue->entries, self, co_queue_next); in qemu_co_queue_wait_impl()
65 * mutex's queue. This avoids the thundering herd effect. in qemu_co_queue_wait_impl()
74 bool qemu_co_enter_next_impl(CoQueue *queue, QemuLockable *lock) in qemu_co_enter_next_impl() argument
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()
[all …]
/openbmc/openpower-vpd-parser/vpd-manager/src/
H A Dlogger.cpp161 // acquire lock on queue in logMessage()
164 // push message to queue in logMessage()
172 // log message to journal if we fail to push message to queue in logMessage()
195 // flush the queue in fileWorker()
198 // read the first message in queue in fileWorker()
202 // pop the message from queue in fileWorker()
205 // unlock mutex on queue in fileWorker()
216 // lock mutex on queue in fileWorker()
221 // log message to journal if we fail to push message to queue in fileWorker()
225 // queue in fileWorker()
[all …]
/openbmc/openbmc/poky/bitbake/bin/
H A Dbitbake-worker22 import queue
86 worker_queue = queue.Queue()
111 except queue.Empty:
366 self.queue = bytearray()
369 start = len(self.queue)
371 self.queue.extend(self.input.read(512*1024) or b"")
376 end = len(self.queue)
377 index = self.queue.find(b"</event>")
379 msg = self.queue[:index+8]
382 self.queue = self.queue[index+8:]
[all …]
/openbmc/u-boot/arch/arm/dts/
H A Dkeystone-k2l-netcp.dtsi18 queue-range = <0 0x2000>;
38 queue-pools {
134 tx-queue = <896>;
168 rx-queue-depth = <128 128 0 0>;
170 rx-queue = <528>;
171 tx-completion-queue = <530>;
180 rx-queue-depth = <128 128 0 0>;
182 rx-queue = <529>;
183 tx-completion-queue = <531>;

12345678910>>...33