Home
last modified time | relevance | path

Searched refs:hctx_idx (Results 1 - 25 of 43) sorted by relevance

12

/kernel/linux/linux-6.6/block/
H A Dblk-mq.c612 blk_opf_t opf, blk_mq_req_flags_t flags, unsigned int hctx_idx) in blk_mq_alloc_request_hctx()
640 if (hctx_idx >= q->nr_hw_queues) in blk_mq_alloc_request_hctx()
652 data.hctx = xa_load(&q->hctx_table, hctx_idx); in blk_mq_alloc_request_hctx()
3284 unsigned int hctx_idx) in blk_mq_free_rqs()
3295 drv_tags = set->tags[hctx_idx]; in blk_mq_free_rqs()
3305 set->ops->exit_request(set, rq, hctx_idx); in blk_mq_free_rqs()
3335 unsigned int hctx_idx) in hctx_idx_to_type()
3343 if (hctx_idx >= start && hctx_idx < end) in hctx_idx_to_type()
3354 unsigned int hctx_idx) in blk_mq_get_hctx_node()
611 blk_mq_alloc_request_hctx(struct request_queue *q, blk_opf_t opf, blk_mq_req_flags_t flags, unsigned int hctx_idx) blk_mq_alloc_request_hctx() argument
3283 blk_mq_free_rqs(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx) blk_mq_free_rqs() argument
3334 hctx_idx_to_type(struct blk_mq_tag_set *set, unsigned int hctx_idx) hctx_idx_to_type() argument
3353 blk_mq_get_hctx_node(struct blk_mq_tag_set *set, unsigned int hctx_idx) blk_mq_get_hctx_node() argument
3361 blk_mq_alloc_rq_map(struct blk_mq_tag_set *set, unsigned int hctx_idx, unsigned int nr_tags, unsigned int reserved_tags) blk_mq_alloc_rq_map() argument
3398 blk_mq_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, int node) blk_mq_init_request() argument
3413 blk_mq_alloc_rqs(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx, unsigned int depth) blk_mq_alloc_rqs() argument
3646 blk_mq_exit_hctx(struct request_queue *q, struct blk_mq_tag_set *set, struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) blk_mq_exit_hctx() argument
3686 blk_mq_init_hctx(struct request_queue *q, struct blk_mq_tag_set *set, struct blk_mq_hw_ctx *hctx, unsigned hctx_idx) blk_mq_init_hctx() argument
3818 blk_mq_alloc_map_and_rqs(struct blk_mq_tag_set *set, unsigned int hctx_idx, unsigned int depth) blk_mq_alloc_map_and_rqs() argument
3838 __blk_mq_alloc_map_and_rqs(struct blk_mq_tag_set *set, int hctx_idx) __blk_mq_alloc_map_and_rqs() argument
3853 blk_mq_free_map_and_rqs(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx) blk_mq_free_map_and_rqs() argument
3863 __blk_mq_free_map_and_rqs(struct blk_mq_tag_set *set, unsigned int hctx_idx) __blk_mq_free_map_and_rqs() argument
3874 unsigned int j, hctx_idx; blk_mq_map_swqueue() local
4188 blk_mq_alloc_and_init_hctx( struct blk_mq_tag_set *set, struct request_queue *q, int hctx_idx, int node) blk_mq_alloc_and_init_hctx() argument
[all...]
H A Dblk-mq.h59 unsigned int hctx_idx);
62 unsigned int hctx_idx, unsigned int depth);
65 unsigned int hctx_idx);
H A Dblk-mq-sched.c384 unsigned int hctx_idx) in blk_mq_sched_alloc_map_and_rqs()
391 hctx->sched_tags = blk_mq_alloc_map_and_rqs(q->tag_set, hctx_idx, in blk_mq_sched_alloc_map_and_rqs()
382 blk_mq_sched_alloc_map_and_rqs(struct request_queue *q, struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) blk_mq_sched_alloc_map_and_rqs() argument
H A Dbsg-lib.c302 unsigned int hctx_idx, unsigned int numa_node) in bsg_init_rq()
313 unsigned int hctx_idx) in bsg_exit_rq()
301 bsg_init_rq(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) bsg_init_rq() argument
312 bsg_exit_rq(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx) bsg_exit_rq() argument
H A Dkyber-iosched.c464 static int kyber_init_hctx(struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) in kyber_init_hctx() argument
519 static void kyber_exit_hctx(struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) in kyber_exit_hctx() argument
/kernel/linux/linux-5.10/block/
H A Dblk-mq.c445 unsigned int op, blk_mq_req_flags_t flags, unsigned int hctx_idx) in blk_mq_alloc_request_hctx()
471 if (hctx_idx >= q->nr_hw_queues) in blk_mq_alloc_request_hctx()
483 data.hctx = q->queue_hw_ctx[hctx_idx]; in blk_mq_alloc_request_hctx()
2317 struct blk_mq_tags *tags, unsigned int hctx_idx) in blk_mq_clear_rq_mapping()
2319 struct blk_mq_tags *drv_tags = set->tags[hctx_idx]; in blk_mq_clear_rq_mapping()
2350 unsigned int hctx_idx) in blk_mq_free_rqs()
2362 set->ops->exit_request(set, rq, hctx_idx); in blk_mq_free_rqs()
2367 blk_mq_clear_rq_mapping(set, tags, hctx_idx); in blk_mq_free_rqs()
2392 unsigned int hctx_idx, in blk_mq_alloc_rq_map()
2400 node = blk_mq_hw_queue_to_node(&set->map[HCTX_TYPE_DEFAULT], hctx_idx); in blk_mq_alloc_rq_map()
444 blk_mq_alloc_request_hctx(struct request_queue *q, unsigned int op, blk_mq_req_flags_t flags, unsigned int hctx_idx) blk_mq_alloc_request_hctx() argument
2316 blk_mq_clear_rq_mapping(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx) blk_mq_clear_rq_mapping() argument
2349 blk_mq_free_rqs(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx) blk_mq_free_rqs() argument
2391 blk_mq_alloc_rq_map(struct blk_mq_tag_set *set, unsigned int hctx_idx, unsigned int nr_tags, unsigned int reserved_tags, unsigned int flags) blk_mq_alloc_rq_map() argument
2428 blk_mq_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, int node) blk_mq_init_request() argument
2443 blk_mq_alloc_rqs(struct blk_mq_tag_set *set, struct blk_mq_tags *tags, unsigned int hctx_idx, unsigned int depth) blk_mq_alloc_rqs() argument
2676 blk_mq_exit_hctx(struct request_queue *q, struct blk_mq_tag_set *set, struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) blk_mq_exit_hctx() argument
2728 blk_mq_init_hctx(struct request_queue *q, struct blk_mq_tag_set *set, struct blk_mq_hw_ctx *hctx, unsigned hctx_idx) blk_mq_init_hctx() argument
2856 __blk_mq_alloc_map_and_request(struct blk_mq_tag_set *set, int hctx_idx) __blk_mq_alloc_map_and_request() argument
2877 blk_mq_free_map_and_requests(struct blk_mq_tag_set *set, unsigned int hctx_idx) blk_mq_free_map_and_requests() argument
2891 unsigned int i, j, hctx_idx; blk_mq_map_swqueue() local
3180 blk_mq_alloc_and_init_hctx( struct blk_mq_tag_set *set, struct request_queue *q, int hctx_idx, int node) blk_mq_alloc_and_init_hctx() argument
[all...]
H A Dblk-mq.h56 unsigned int hctx_idx);
59 unsigned int hctx_idx,
64 unsigned int hctx_idx, unsigned int depth);
H A Dblk-mq-sched.c518 unsigned int hctx_idx) in blk_mq_sched_alloc_tags()
525 hctx->sched_tags = blk_mq_alloc_rq_map(set, hctx_idx, q->nr_requests, in blk_mq_sched_alloc_tags()
530 ret = blk_mq_alloc_rqs(set, hctx->sched_tags, hctx_idx, q->nr_requests); in blk_mq_sched_alloc_tags()
516 blk_mq_sched_alloc_tags(struct request_queue *q, struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) blk_mq_sched_alloc_tags() argument
H A Dbsg-lib.c294 unsigned int hctx_idx, unsigned int numa_node) in bsg_init_rq()
317 unsigned int hctx_idx) in bsg_exit_rq()
293 bsg_init_rq(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) bsg_init_rq() argument
316 bsg_exit_rq(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx) bsg_exit_rq() argument
H A Dkyber-iosched.c459 static int kyber_init_hctx(struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) in kyber_init_hctx() argument
513 static void kyber_exit_hctx(struct blk_mq_hw_ctx *hctx, unsigned int hctx_idx) in kyber_exit_hctx() argument
/kernel/linux/linux-5.10/drivers/nvme/target/
H A Dloop.c204 struct request *req, unsigned int hctx_idx, in nvme_loop_init_request()
211 (set == &ctrl->tag_set) ? hctx_idx + 1 : 0); in nvme_loop_init_request()
217 unsigned int hctx_idx) in nvme_loop_init_hctx()
220 struct nvme_loop_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_loop_init_hctx()
222 BUG_ON(hctx_idx >= ctrl->ctrl.queue_count); in nvme_loop_init_hctx()
237 unsigned int hctx_idx) in nvme_loop_init_admin_hctx()
242 BUG_ON(hctx_idx != 0); in nvme_loop_init_admin_hctx()
203 nvme_loop_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) nvme_loop_init_request() argument
216 nvme_loop_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_loop_init_hctx() argument
236 nvme_loop_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_loop_init_admin_hctx() argument
/kernel/linux/linux-6.6/drivers/nvme/target/
H A Dloop.c204 struct request *req, unsigned int hctx_idx, in nvme_loop_init_request()
213 (set == &ctrl->tag_set) ? hctx_idx + 1 : 0); in nvme_loop_init_request()
219 unsigned int hctx_idx) in nvme_loop_init_hctx()
222 struct nvme_loop_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_loop_init_hctx()
224 BUG_ON(hctx_idx >= ctrl->ctrl.queue_count); in nvme_loop_init_hctx()
239 unsigned int hctx_idx) in nvme_loop_init_admin_hctx()
244 BUG_ON(hctx_idx != 0); in nvme_loop_init_admin_hctx()
203 nvme_loop_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) nvme_loop_init_request() argument
218 nvme_loop_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_loop_init_hctx() argument
238 nvme_loop_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_loop_init_admin_hctx() argument
/kernel/linux/linux-5.10/drivers/mmc/core/
H A Dqueue.c233 unsigned int hctx_idx, unsigned int numa_node) in mmc_mq_init_request()
239 unsigned int hctx_idx) in mmc_mq_exit_request()
232 mmc_mq_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) mmc_mq_init_request() argument
238 mmc_mq_exit_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx) mmc_mq_exit_request() argument
/kernel/linux/linux-6.6/drivers/mmc/core/
H A Dqueue.c204 unsigned int hctx_idx, unsigned int numa_node) in mmc_mq_init_request()
219 unsigned int hctx_idx) in mmc_mq_exit_request()
203 mmc_mq_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) mmc_mq_init_request() argument
218 mmc_mq_exit_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx) mmc_mq_exit_request() argument
/kernel/linux/linux-5.10/drivers/nvme/host/
H A Drdma.c289 struct request *rq, unsigned int hctx_idx) in nvme_rdma_exit_request()
297 struct request *rq, unsigned int hctx_idx, in nvme_rdma_init_request()
302 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_rdma_init_request()
322 unsigned int hctx_idx) in nvme_rdma_init_hctx()
325 struct nvme_rdma_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_rdma_init_hctx()
327 BUG_ON(hctx_idx >= ctrl->ctrl.queue_count); in nvme_rdma_init_hctx()
334 unsigned int hctx_idx) in nvme_rdma_init_admin_hctx()
339 BUG_ON(hctx_idx != 0); in nvme_rdma_init_admin_hctx()
288 nvme_rdma_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_rdma_exit_request() argument
296 nvme_rdma_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_rdma_init_request() argument
321 nvme_rdma_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_rdma_init_hctx() argument
333 nvme_rdma_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_rdma_init_admin_hctx() argument
H A Dtcp.c449 struct request *rq, unsigned int hctx_idx) in nvme_tcp_exit_request()
457 struct request *rq, unsigned int hctx_idx, in nvme_tcp_init_request()
462 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_tcp_init_request()
479 unsigned int hctx_idx) in nvme_tcp_init_hctx()
482 struct nvme_tcp_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_tcp_init_hctx()
489 unsigned int hctx_idx) in nvme_tcp_init_admin_hctx()
448 nvme_tcp_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_tcp_exit_request() argument
456 nvme_tcp_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_tcp_init_request() argument
478 nvme_tcp_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_tcp_init_hctx() argument
488 nvme_tcp_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_tcp_init_admin_hctx() argument
H A Dfc.c1827 unsigned int hctx_idx) in nvme_fc_exit_request()
2117 unsigned int hctx_idx, unsigned int numa_node) in nvme_fc_init_request()
2121 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_fc_init_request()
2201 unsigned int hctx_idx) in nvme_fc_init_hctx()
2205 __nvme_fc_init_hctx(hctx, ctrl, hctx_idx + 1); in nvme_fc_init_hctx()
2212 unsigned int hctx_idx) in nvme_fc_init_admin_hctx()
2216 __nvme_fc_init_hctx(hctx, ctrl, hctx_idx); in nvme_fc_init_admin_hctx()
1826 nvme_fc_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_fc_exit_request() argument
2116 nvme_fc_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_fc_init_request() argument
2200 nvme_fc_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_fc_init_hctx() argument
2211 nvme_fc_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_fc_init_admin_hctx() argument
H A Dpci.c391 unsigned int hctx_idx) in nvme_admin_init_hctx()
396 WARN_ON(hctx_idx != 0); in nvme_admin_init_hctx()
404 unsigned int hctx_idx) in nvme_init_hctx()
407 struct nvme_queue *nvmeq = &dev->queues[hctx_idx + 1]; in nvme_init_hctx()
409 WARN_ON(dev->tagset.tags[hctx_idx] != hctx->tags); in nvme_init_hctx()
415 unsigned int hctx_idx, unsigned int numa_node) in nvme_init_request()
419 int queue_idx = (set == &dev->tagset) ? hctx_idx + 1 : 0; in nvme_init_request()
390 nvme_admin_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_admin_init_hctx() argument
403 nvme_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_init_hctx() argument
414 nvme_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) nvme_init_request() argument
/kernel/linux/linux-6.6/drivers/nvme/host/
H A Drdma.c286 struct request *rq, unsigned int hctx_idx) in nvme_rdma_exit_request()
294 struct request *rq, unsigned int hctx_idx, in nvme_rdma_init_request()
299 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_rdma_init_request()
320 unsigned int hctx_idx) in nvme_rdma_init_hctx()
323 struct nvme_rdma_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_rdma_init_hctx()
325 BUG_ON(hctx_idx >= ctrl->ctrl.queue_count); in nvme_rdma_init_hctx()
332 unsigned int hctx_idx) in nvme_rdma_init_admin_hctx()
337 BUG_ON(hctx_idx != 0); in nvme_rdma_init_admin_hctx()
285 nvme_rdma_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_rdma_exit_request() argument
293 nvme_rdma_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_rdma_init_request() argument
319 nvme_rdma_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_rdma_init_hctx() argument
331 nvme_rdma_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_rdma_init_admin_hctx() argument
H A Dtcp.c467 struct request *rq, unsigned int hctx_idx) in nvme_tcp_exit_request()
475 struct request *rq, unsigned int hctx_idx, in nvme_tcp_init_request()
481 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_tcp_init_request()
500 unsigned int hctx_idx) in nvme_tcp_init_hctx()
503 struct nvme_tcp_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_tcp_init_hctx()
510 unsigned int hctx_idx) in nvme_tcp_init_admin_hctx()
466 nvme_tcp_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_tcp_exit_request() argument
474 nvme_tcp_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_tcp_init_request() argument
499 nvme_tcp_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_tcp_init_hctx() argument
509 nvme_tcp_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_tcp_init_admin_hctx() argument
H A Dfc.c1834 unsigned int hctx_idx) in nvme_fc_exit_request()
2142 unsigned int hctx_idx, unsigned int numa_node) in nvme_fc_init_request()
2146 int queue_idx = (set == &ctrl->tag_set) ? hctx_idx + 1 : 0; in nvme_fc_init_request()
2227 nvme_fc_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) in nvme_fc_init_hctx() argument
2229 return __nvme_fc_init_hctx(hctx, data, hctx_idx + 1); in nvme_fc_init_hctx()
2234 unsigned int hctx_idx) in nvme_fc_init_admin_hctx()
2236 return __nvme_fc_init_hctx(hctx, data, hctx_idx); in nvme_fc_init_admin_hctx()
1833 nvme_fc_exit_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx) nvme_fc_exit_request() argument
2141 nvme_fc_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) nvme_fc_init_request() argument
2233 nvme_fc_init_admin_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_fc_init_admin_hctx() argument
H A Dpci.c396 unsigned int hctx_idx) in nvme_admin_init_hctx()
401 WARN_ON(hctx_idx != 0); in nvme_admin_init_hctx()
409 unsigned int hctx_idx) in nvme_init_hctx()
412 struct nvme_queue *nvmeq = &dev->queues[hctx_idx + 1]; in nvme_init_hctx()
414 WARN_ON(dev->tagset.tags[hctx_idx] != hctx->tags); in nvme_init_hctx()
420 struct request *req, unsigned int hctx_idx, in nvme_pci_init_request()
395 nvme_admin_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_admin_init_hctx() argument
408 nvme_init_hctx(struct blk_mq_hw_ctx *hctx, void *data, unsigned int hctx_idx) nvme_init_hctx() argument
419 nvme_pci_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) nvme_pci_init_request() argument
/kernel/linux/linux-5.10/include/linux/
H A Dblk-mq.h464 unsigned int hctx_idx);
/kernel/linux/linux-5.10/drivers/mtd/ubi/
H A Dblock.c332 struct request *req, unsigned int hctx_idx, in ubiblock_init_request()
331 ubiblock_init_request(struct blk_mq_tag_set *set, struct request *req, unsigned int hctx_idx, unsigned int numa_node) ubiblock_init_request() argument
/kernel/linux/linux-5.10/drivers/md/
H A Ddm-rq.c466 unsigned int hctx_idx, unsigned int numa_node) in dm_mq_init_request()
465 dm_mq_init_request(struct blk_mq_tag_set *set, struct request *rq, unsigned int hctx_idx, unsigned int numa_node) dm_mq_init_request() argument

Completed in 52 milliseconds

12