Home
last modified time | relevance | path

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

12345678910>>...12

/openbmc/qemu/net/
H A Dqueue.c65 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()
76 queue->delivering = 0; in qemu_new_net_queue()
78 return queue; in qemu_new_net_queue()
81 void qemu_del_net_queue(NetQueue *queue) in qemu_del_net_queue() argument
[all …]
/openbmc/qemu/ui/
H A Dvnc-jobs.c70 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()
107 vnc_unlock_queue(queue); in vnc_job_add_rect()
113 vnc_lock_queue(queue); in vnc_job_push()
[all …]
/openbmc/qemu/include/qemu/
H A Dcoroutine.h103 void qemu_co_queue_init(CoQueue *queue);
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,
131 bool coroutine_fn qemu_co_queue_next(CoQueue *queue);
138 void coroutine_fn qemu_co_queue_restart_all(CoQueue *queue);
149 #define qemu_co_enter_next(queue, lock) \ argument
150 qemu_co_enter_next_impl(queue, QEMU_MAKE_LOCKABLE(lock))
[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.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);
/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/u-boot/drivers/net/
H A Dmvneta.c579 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()
588 q_map |= (1 << queue); in mvneta_port_up()
594 for (queue = 0; queue < rxq_number; queue++) { in mvneta_port_up()
595 struct mvneta_rx_queue *rxq = &pp->rxqs[queue]; in mvneta_port_up()
597 q_map |= (1 << queue); in mvneta_port_up()
700 static void mvneta_set_ucast_table(struct mvneta_port *pp, int queue) in mvneta_set_ucast_table() argument
705 if (queue == -1) { in mvneta_set_ucast_table()
708 val = 0x1 | (queue << 1); in mvneta_set_ucast_table()
[all …]
/openbmc/qemu/backends/
H A Dcryptodev-vhost.c120 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
296 assert(queue < MAX_CRYPTO_QUEUE_NUM); in cryptodev_vhost_virtqueue_pending()
[all …]
/openbmc/qemu/util/
H 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()
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()
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()
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()
[all …]
H 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()
/openbmc/qemu/tests/qtest/fuzz/
H 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()
H 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()
/openbmc/u-boot/drivers/net/pfe_eth/
H A Dpfe_cmd.c171 u32 qm_read_drop_stat(u32 tmu, u32 queue, u32 *total_drops, int do_reset) in qm_read_drop_stat() argument
176 writel((tmu << 8) | queue, TMU_TEQ_CTRL); in qm_read_drop_stat()
177 writel((tmu << 8) | queue, TMU_LLM_CTRL); in qm_read_drop_stat()
179 qtotal[tmu][queue] += val; in qm_read_drop_stat()
181 *total_drops = qtotal[tmu][queue]; in qm_read_drop_stat()
183 qtotal[tmu][queue] = 0; in qm_read_drop_stat()
187 static ssize_t tmu_queue_stats(char *buf, int tmu, int queue) in tmu_queue_stats() argument
192 printf("%d-%02d, ", tmu, queue); in tmu_queue_stats()
194 drops = qm_read_drop_stat(tmu, queue, NULL, 0); in tmu_queue_stats()
197 writel((tmu << 8) | queue, TMU_TEQ_CTRL); in tmu_queue_stats()
[all …]
/openbmc/dbus-sensors/src/nvidia-gpu/
H A DMctpRequester.cpp218 auto& queue = it->second.queue; in sendRecvMsg() local
219 queue.push_back(std::move(reqCtx)); in sendRecvMsg()
221 if (queue.size() == 1) in sendRecvMsg()
245 auto& queue = it->second.queue; in handleResult() local
246 auto& reqCtx = queue.front(); in handleResult()
271 queue.pop_front(); in handleResult()
322 auto& queue = it->second.queue; in processQueue() local
324 if (queue.empty()) in processQueue()
328 auto& reqCtx = queue.front(); in processQueue()
/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/qemu/hw/i386/
H 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),
/openbmc/qemu/scripts/qemugdb/
H 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)
/openbmc/u-boot/arch/arm/dts/
H A Dkeystone-k2e-netcp.dtsi18 queue-range = <0 0x2000>;
38 queue-pools {
135 tx-queue = <896>;
185 rx-queue-depth = <128 128 0 0>;
187 rx-queue = <528>;
188 tx-completion-queue = <530>;
197 rx-queue-depth = <128 128 0 0>;
199 rx-queue = <529>;
200 tx-completion-queue = <531>;
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>;
H A Dkeystone-k2hk-netcp.dtsi18 queue-range = <0 0x4000>;
50 queue-pools {
153 tx-queue = <648>;
187 rx-queue-depth = <128 128 0 0>;
189 rx-queue = <8704>;
190 tx-completion-queue = <8706>;
199 rx-queue-depth = <128 128 0 0>;
201 rx-queue = <8705>;
202 tx-completion-queue = <8707>;
/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/ipmitool/lib/
H A Dipmi_sdradd.c243 struct sdrr_queue *queue) in sdrr_get_records() argument
247 queue->head = NULL; in sdrr_get_records()
248 queue->tail = NULL; in sdrr_get_records()
268 if (queue->head == NULL) in sdrr_get_records()
269 queue->head = sdrr; in sdrr_get_records()
271 queue->tail->next = sdrr; in sdrr_get_records()
272 queue->tail = sdrr; in sdrr_get_records()
575 ipmi_sdr_read_records(const char *filename, struct sdrr_queue *queue) in ipmi_sdr_read_records() argument
581 queue->head = NULL; in ipmi_sdr_read_records()
582 queue->tail = NULL; in ipmi_sdr_read_records()
[all …]
/openbmc/openbmc/poky/meta/recipes-core/musl/
H A Dbsd-headers.bb6 LIC_FILES_CHKSUM = "file://sys-queue.h;beginline=1;endline=32;md5=c6352b0f03bb448600456547d334b56f"
9 SRC_URI = "file://sys-queue.h \
22 install -Dm 0644 ${S}/sys-queue.h ${D}${includedir}/sys/queue.h
/openbmc/qemu/hw/virtio/
H 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
/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 …]

12345678910>>...12