Home
last modified time | relevance | path

Searched refs:queues (Results 1 – 25 of 78) sorted by relevance

1234

/openbmc/qemu/net/
H A Dvhost-user.c103 static void vhost_user_stop(int queues, NetClientState *ncs[]) in vhost_user_stop() argument
108 for (i = 0; i < queues; i++) { in vhost_user_stop()
120 static int vhost_user_start(int queues, NetClientState *ncs[], in vhost_user_start() argument
131 for (i = 0; i < queues; i++) { in vhost_user_start()
154 if (queues > max_queues) { in vhost_user_start()
301 int queues, i; in chr_closed_bh() local
303 queues = qemu_find_net_clients_except(name, ncs, in chr_closed_bh()
306 assert(queues < MAX_QUEUE_NUM); in chr_closed_bh()
310 for (i = queues -1; i >= 0; i--) { in chr_closed_bh()
314 net_client_set_link(ncs, queues, false); in chr_closed_bh()
[all …]
H A Dnet.c333 int i, queues = MAX(1, conf->peers.queues); in qemu_new_nic() local
338 nic = g_malloc0(info->size + sizeof(NetClientState) * queues); in qemu_new_nic()
344 for (i = 0; i < queues; i++) { in qemu_new_nic()
414 int queues, i; in qemu_del_net_client() local
422 queues = qemu_find_net_clients_except(nc->name, ncs, in qemu_del_net_client()
425 assert(queues != 0); in qemu_del_net_client()
445 for (i = 0; i < queues; i++) { in qemu_del_net_client()
457 for (i = 0; i < queues; i++) { in qemu_del_net_client()
465 int i, queues = MAX(nic->conf->peers.queues, 1); in qemu_del_nic() local
469 for (i = 0; i < queues; i++) { in qemu_del_nic()
[all …]
H A Daf-xdp.c487 int64_t i, queues; in net_init_af_xdp() local
499 queues = opts->has_queues ? opts->queues : 1; in net_init_af_xdp()
500 if (queues < 1) { in net_init_af_xdp()
502 queues, opts->ifname); in net_init_af_xdp()
532 sock_fds = parse_socket_fds(opts->sock_fds, queues, errp); in net_init_af_xdp()
538 for (i = 0; i < queues; i++) { in net_init_af_xdp()
H A Dfilter.c223 int queues; in netfilter_complete() local
231 queues = qemu_find_net_clients_except(nf->netdev_id, ncs, in netfilter_complete()
234 if (queues < 1) { in netfilter_complete()
238 } else if (queues > 1) { in netfilter_complete()
/openbmc/qemu/backends/
H A Dcryptodev-vhost-user.c76 static void cryptodev_vhost_user_stop(int queues, in cryptodev_vhost_user_stop() argument
81 for (i = 0; i < queues; i++) { in cryptodev_vhost_user_stop()
92 cryptodev_vhost_user_start(int queues, in cryptodev_vhost_user_start() argument
100 for (i = 0; i < queues; i++) { in cryptodev_vhost_user_start()
117 if (queues > max_queues) { in cryptodev_vhost_user_start()
158 int queues = b->conf.peers.queues; in cryptodev_vhost_user_event() local
160 assert(queues < MAX_CRYPTO_QUEUE_NUM); in cryptodev_vhost_user_event()
164 if (cryptodev_vhost_user_start(queues, s) < 0) { in cryptodev_vhost_user_event()
171 cryptodev_vhost_user_stop(queues, s); in cryptodev_vhost_user_event()
184 int queues = backend->conf.peers.queues; in cryptodev_vhost_user_init() local
[all …]
H A Dcryptodev-builtin.c80 int queues = backend->conf.peers.queues; in cryptodev_builtin_init() local
83 if (queues != 1) { in cryptodev_builtin_init()
590 int queues = backend->conf.peers.queues; in cryptodev_builtin_cleanup() local
599 for (i = 0; i < queues; i++) { in cryptodev_builtin_cleanup()
H A Dcryptodev-lkcf.c210 int queues = backend->conf.peers.queues, i; in cryptodev_lkcf_init() local
215 if (queues != 1) { in cryptodev_lkcf_init()
255 int queues = backend->conf.peers.queues; in cryptodev_lkcf_cleanup() local
293 for (i = 0; i < queues; i++) { in cryptodev_lkcf_cleanup()
/openbmc/qemu/tests/qtest/fuzz/
H A Dvirtio_scsi_fuzz.c64 static void virtio_scsi_fuzz(QTestState *s, QVirtioSCSIQueues* queues, in virtio_scsi_fuzz() argument
98 vqa.queue = vqa.queue % queues->num_queues; in virtio_scsi_fuzz()
106 q = queues->vq[vqa.queue]; in virtio_scsi_fuzz()
129 qvirtqueue_kick(s, dev, queues->vq[i], free_head[i]); in virtio_scsi_fuzz()
138 static QVirtioSCSIQueues *queues; in virtio_scsi_with_flag_fuzz() local
141 queues = qvirtio_scsi_init(scsi->vdev, *(uint64_t *)Data); in virtio_scsi_with_flag_fuzz()
142 virtio_scsi_fuzz(s, queues, in virtio_scsi_with_flag_fuzz()
H A Dvirtio_blk_fuzz.c61 static void virtio_blk_fuzz(QTestState *s, QVirtioBlkQueues* queues, in virtio_blk_fuzz() argument
95 vqa.queue = vqa.queue % queues->num_queues; in virtio_blk_fuzz()
102 q = queues->vq[vqa.queue]; in virtio_blk_fuzz()
125 qvirtqueue_kick(s, dev, queues->vq[i], free_head[i]); in virtio_blk_fuzz()
134 static QVirtioBlkQueues *queues; in virtio_blk_with_flag_fuzz() local
137 queues = qvirtio_blk_init(blk->vdev, *(uint64_t *)Data); in virtio_blk_with_flag_fuzz()
138 virtio_blk_fuzz(s, queues, in virtio_blk_with_flag_fuzz()
H A Dvirtio_net_fuzz.c54 q = net_if->queues[vqa.queue % 3]; in virtio_net_fuzz_multi()
93 while (!vqa.rx && q != net_if->queues[QVIRTIO_RX_VQ]) { in virtio_net_fuzz_multi()
/openbmc/qemu/tests/qtest/libqos/
H A Dvirtio-gpio.c24 qvirtqueue_cleanup(vdev->bus, gpio->queues[i], alloc); in virtio_gpio_cleanup()
26 g_free(gpio->queues); in virtio_gpio_cleanup()
44 gpio->queues = g_new(QVirtQueue *, 2); in virtio_gpio_setup()
46 gpio->queues[i] = qvirtqueue_setup(vdev, alloc, i); in virtio_gpio_setup()
H A Dvirtio-scmi.c26 qvirtqueue_cleanup(vdev->bus, scmi->queues[i], alloc); in virtio_scmi_cleanup()
28 g_free(scmi->queues); in virtio_scmi_cleanup()
46 scmi->queues = g_new(QVirtQueue *, 2); in virtio_scmi_setup()
48 scmi->queues[i] = qvirtqueue_setup(vdev, alloc, i); in virtio_scmi_setup()
H A Dvirtio-net.c34 qvirtqueue_cleanup(interface->vdev->bus, interface->queues[i], alloc); in virtio_net_cleanup()
36 g_free(interface->queues); in virtio_net_cleanup()
58 interface->queues = g_new(QVirtQueue *, interface->n_queues); in virtio_net_setup()
60 interface->queues[i] = qvirtqueue_setup(vdev, alloc, i); in virtio_net_setup()
H A Dvirtio-gpio.h22 QVirtQueue **queues; member
H A Dvirtio-scmi.h21 QVirtQueue **queues; member
H A Dvirtio-net.h33 QVirtQueue **queues; member
/openbmc/u-boot/tools/
H A Dgenboardscfg.py220 def read_queues(queues, params_list): argument
222 for q in queues:
243 queues = []
252 queues.append(q)
260 read_queues(queues, params_list)
270 read_queues(queues, params_list)
/openbmc/u-boot/drivers/nvme/
H A Dnvme.c215 return nvme_submit_sync_cmd(dev->queues[NVME_ADMIN_Q], cmd, in nvme_submit_admin_cmd()
245 dev->queues[qid] = nvmeq; in nvme_alloc_queue()
308 struct nvme_queue *nvmeq = dev->queues[i]; in nvme_free_queues()
310 dev->queues[i] = NULL; in nvme_free_queues()
356 nvmeq = dev->queues[NVME_ADMIN_Q]; in nvme_configure_admin_queue()
384 nvme_init_queue(dev->queues[NVME_ADMIN_Q], 0); in nvme_configure_admin_queue()
550 if (nvme_create_queue(dev->queues[i], i)) in nvme_create_io_queues()
717 status = nvme_submit_sync_cmd(dev->queues[NVME_IO_Q], in nvme_blk_rw()
783 ndev->queues = malloc(NVME_Q_NUM * sizeof(struct nvme_queue *)); in nvme_probe()
784 if (!ndev->queues) { in nvme_probe()
[all …]
/openbmc/qemu/tests/qtest/
H A Dvirtio-net-test.c151 QVirtQueue *rx = net_if->queues[0]; in send_recv_test()
152 QVirtQueue *tx = net_if->queues[1]; in send_recv_test()
163 QVirtQueue *rx = net_if->queues[0]; in stop_cont_test()
293 QVirtQueue *vq = dev->queues[1]; in large_tx()
H A Dvhost-user-test.c171 int queues; member
447 assert(msg.payload.state.index < s->queues * 2); in chr_read()
493 assert(msg.payload.state.index < s->queues * 2); in chr_read()
501 msg.payload.u64 = s->queues; in chr_read()
599 server->queues = 1; in test_server_new()
1026 s->queues = 2; in vhost_user_test_setup_multiqueue()
1030 s->queues, s->queues * 2 + 2); in vhost_user_test_setup_multiqueue()
1039 wait_for_rings_started(s, s->queues * 2); in test_multiqueue()
1049 if (s->queues > 1) { in vu_net_get_features()
1074 if (s->queues > 1) { in vu_net_get_protocol_features()
/openbmc/qemu/block/
H A Dnvme.c112 NVMeQueuePair **queues; member
536 NVMeQueuePair *q = s->queues[INDEX_ADMIN]; in nvme_admin_cmd_sync()
668 nvme_poll_queue(s->queues[i]); in nvme_poll_queues()
716 s->queues = g_renew(NVMeQueuePair *, s->queues, n + 1); in nvme_add_io_queue()
717 s->queues[n] = q; in nvme_add_io_queue()
733 NVMeQueuePair *q = s->queues[i]; in nvme_poll_cb()
852 s->queues = g_new(NVMeQueuePair *, 1); in nvme_init()
858 s->queues[INDEX_ADMIN] = q; in nvme_init()
973 nvme_free_queue_pair(s->queues[i]); in nvme_close()
975 g_free(s->queues); in nvme_close()
[all …]
/openbmc/qemu/docs/devel/migration/
H A Dcompatibility.rst130 queue. In qemu-5.2 it has the same number of queues as the number of
134 queues to a device that have only one queue, we don't know where to
135 put the extra information for the other 3 queues, and we fail
140 has 4, and we have 3 queues that are not properly initialized and
144 that when it is running pc-5.1, it needs to set the number of queues
151 qemu-5.2 -M pc-5.1 sets number of queues to be 1.
152 qemu-5.1 -M pc-5.1 expects number of queues to be 1.
158 qemu-5.1 -M pc-5.1 sets number of queues to be 1.
159 qemu-5.2 -M pc-5.1 expects number of queues to be 1.
168 lot if we have set the number of queues to 1 or not, because
[all …]
/openbmc/openbmc/meta-openembedded/meta-python/recipes-devtools/python/
H A Dpython3-posix-ipc_1.2.0.bb1 DESCRIPTION = "POSIX IPC primitives (semaphores, shared memory and message queues) for Python"
/openbmc/qemu/docs/tools/
H A Dqemu-storage-daemon.rst79 …dr.path=<socket-path>[,writable=on|off][,logical-block-size=<block-size>][,num-queues=<num-queues>]
80 …type=fd,addr.str=<fd>[,writable=on|off][,logical-block-size=<block-size>][,num-queues=<num-queues>]
82 …id>,node-name=<node-name>,name=<vduse-name>[,writable=on|off][,num-queues=<num-queues>][,queue-siz…
99 512). ``num-queues`` sets the number of virtqueues (the default is 1).
118 ``num-queues`` sets the number of virtqueues (the default is 1).
/openbmc/qemu/qapi/
H A Dnet.json351 # @queues: number of queues to be created for multiqueue capable tap
373 '*queues': 'uint32',
565 # @queues: number of queues to be used for multiqueue interfaces
568 # @start-queue: Use @queues starting from this queue number
577 # into XDP socket map for corresponding queues. @sock-fds and
594 '*queues': 'int',
611 # @queues: number of queues to be created for multiqueue vhost-user
620 '*queues': 'int' } }
634 # @queues: number of queues to be created for multiqueue vhost-vdpa
650 '*queues': 'int',

1234