github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

parallelize: Use mngt_queue only as a fallback

Browse Source 
Signed-off-by: Robert Baldyga <robert.baldyga@huawei.com>
Signed-off-by: Michal Mielewczyk <michal.mielewczyk@huawei.com>
This commit is contained in:
Robert Baldyga 2023-06-26 23:50:12 +02:00 committed by Michal Mielewczyk
parent 83d5642547
commit 5c714cb3de
1 changed files with 25 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/utils/utils_parallelize.c
View File

@ -55,6 +55,7 @@ int ocf_parallelize_create(ocf_parallelize_t *parallelize,
ocf_parallelize_finish_t finish) ocf_parallelize_finish_t finish)
{ {
ocf_parallelize_t tmp_parallelize; ocf_parallelize_t tmp_parallelize;
struct list_head *iter;
ocf_queue_t queue; ocf_queue_t queue;
size_t prl_size; size_t prl_size;
unsigned queue_count = 0; unsigned queue_count = 0;
@ -65,6 +66,9 @@ int ocf_parallelize_create(ocf_parallelize_t *parallelize,
if (shards_cnt == 0) if (shards_cnt == 0)
shards_cnt = queue_count; shards_cnt = queue_count;
if (queue_count == 0)
shards_cnt = 1;
prl_size = sizeof(*tmp_parallelize) + prl_size = sizeof(*tmp_parallelize) +
shards_cnt * sizeof(*tmp_parallelize->reqs); shards_cnt * sizeof(*tmp_parallelize->reqs);
@ -86,23 +90,28 @@ int ocf_parallelize_create(ocf_parallelize_t *parallelize,
env_atomic_set(&tmp_parallelize->remaining, shards_cnt); env_atomic_set(&tmp_parallelize->remaining, shards_cnt);
env_atomic_set(&tmp_parallelize->error, 0); env_atomic_set(&tmp_parallelize->error, 0);
for (i = 0; i < shards_cnt;) {
list_for_each_entry(queue, &cache->io_queues, list) { iter = cache->io_queues.next;
if (i == shards_cnt) for (i = 0; i < shards_cnt; i++) {
break; if (queue_count > 0) {
tmp_parallelize->reqs[i] = ocf_req_new(queue, queue = list_entry(iter, struct ocf_queue, list);
NULL, 0, 0, 0); iter = iter->next;
if (!tmp_parallelize->reqs[i]) { if (iter == &cache->io_queues)
result = -OCF_ERR_NO_MEM; iter = iter->next;
goto err_reqs; } else {
} queue = cache->mngt_queue;
tmp_parallelize->reqs[i]->info.internal = true;
tmp_parallelize->reqs[i]->engine_handler =
_ocf_parallelize_hndl;
tmp_parallelize->reqs[i]->byte_position = i;
tmp_parallelize->reqs[i]->priv = tmp_parallelize;
i++;
} }
tmp_parallelize->reqs[i] = ocf_req_new(queue,
NULL, 0, 0, 0);
if (!tmp_parallelize->reqs[i]) {
result = -OCF_ERR_NO_MEM;
goto err_reqs;
}
tmp_parallelize->reqs[i]->info.internal = true;
tmp_parallelize->reqs[i]->engine_handler =
_ocf_parallelize_hndl;
tmp_parallelize->reqs[i]->byte_position = i;
tmp_parallelize->reqs[i]->priv = tmp_parallelize;
} }
*parallelize = tmp_parallelize; *parallelize = tmp_parallelize;