Lines Matching refs:nthreads
502 unsigned max_nr_ios_per_thread = nr_ios / dev->nthreads; in ublk_thread_init()
503 max_nr_ios_per_thread += !!(nr_ios % dev->nthreads); in ublk_thread_init()
675 for (i = t->idx; i < nr_ios; i += t->dev->nthreads) { in ublk_submit_fetch_commands()
922 tinfo = calloc(sizeof(struct ublk_thread_info), dev->nthreads); in ublk_start_daemon()
950 for (i = 0; i < dev->nthreads; i++) { in ublk_start_daemon()
963 if (dev->nthreads == dinfo->nr_hw_queues) in ublk_start_daemon()
970 for (i = 0; i < dev->nthreads; i++) in ublk_start_daemon()
994 for (i = 0; i < dev->nthreads; i++) in ublk_start_daemon()
1104 unsigned nthreads = ctx->nthreads; in __cmd_dev_add() local
1131 if (!nthreads) in __cmd_dev_add()
1132 nthreads = nr_queues; in __cmd_dev_add()
1134 if (nthreads > UBLK_MAX_THREADS) { in __cmd_dev_add()
1136 __func__, nthreads, UBLK_MAX_THREADS); in __cmd_dev_add()
1141 if (nthreads != nr_queues && !ctx->per_io_tasks) { in __cmd_dev_add()
1144 __func__, nthreads, nr_queues); in __cmd_dev_add()
1177 dev->nthreads = nthreads; in __cmd_dev_add()
1613 ctx.nthreads = strtol(optarg, NULL, 10); in main()