summaryrefslogtreecommitdiffstats
path: root/drivers/md/dm-vdo/data-vio.c
diff options
context:
space:
mode:
authorMike Snitzer <snitzer@kernel.org>2024-02-13 13:35:28 -0600
committerMike Snitzer <snitzer@kernel.org>2024-03-04 15:07:57 -0500
commit66214ed0001eaea245b5d9f01b128aa82d6963a8 (patch)
treeecfc3b461162e49d1776d24d37573544d44b254a /drivers/md/dm-vdo/data-vio.c
parent41c58a36e2c0496abebb1cb3100b38e32f49f80f (diff)
downloadlinux-stable-66214ed0001eaea245b5d9f01b128aa82d6963a8.tar.gz
linux-stable-66214ed0001eaea245b5d9f01b128aa82d6963a8.tar.bz2
linux-stable-66214ed0001eaea245b5d9f01b128aa82d6963a8.zip
dm vdo funnel-queue: change from uds_ to vdo_ namespace
Also return VDO_SUCCESS from vdo_make_funnel_queue. Signed-off-by: Mike Snitzer <snitzer@kernel.org> Signed-off-by: Chung Chung <cchung@redhat.com> Signed-off-by: Matthew Sakai <msakai@redhat.com>
Diffstat (limited to 'drivers/md/dm-vdo/data-vio.c')
-rw-r--r--drivers/md/dm-vdo/data-vio.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/drivers/md/dm-vdo/data-vio.c b/drivers/md/dm-vdo/data-vio.c
index 51c49fad1b8b..2b0d42c77e05 100644
--- a/drivers/md/dm-vdo/data-vio.c
+++ b/drivers/md/dm-vdo/data-vio.c
@@ -718,7 +718,7 @@ static void process_release_callback(struct vdo_completion *completion)
for (processed = 0; processed < DATA_VIO_RELEASE_BATCH_SIZE; processed++) {
struct data_vio *data_vio;
- struct funnel_queue_entry *entry = uds_funnel_queue_poll(pool->queue);
+ struct funnel_queue_entry *entry = vdo_funnel_queue_poll(pool->queue);
if (entry == NULL)
break;
@@ -748,7 +748,7 @@ static void process_release_callback(struct vdo_completion *completion)
/* Pairs with the barrier in schedule_releases(). */
smp_mb();
- reschedule = !uds_is_funnel_queue_empty(pool->queue);
+ reschedule = !vdo_is_funnel_queue_empty(pool->queue);
drained = (!reschedule &&
vdo_is_state_draining(&pool->state) &&
check_for_drain_complete_locked(pool));
@@ -865,8 +865,8 @@ int make_data_vio_pool(struct vdo *vdo, data_vio_count_t pool_size,
process_release_callback, vdo->thread_config.cpu_thread,
NULL);
- result = uds_make_funnel_queue(&pool->queue);
- if (result != UDS_SUCCESS) {
+ result = vdo_make_funnel_queue(&pool->queue);
+ if (result != VDO_SUCCESS) {
free_data_vio_pool(vdo_forget(pool));
return result;
}
@@ -924,7 +924,7 @@ void free_data_vio_pool(struct data_vio_pool *pool)
destroy_data_vio(data_vio);
}
- uds_free_funnel_queue(vdo_forget(pool->queue));
+ vdo_free_funnel_queue(vdo_forget(pool->queue));
vdo_free(pool);
}
@@ -1283,7 +1283,7 @@ static void finish_cleanup(struct data_vio *data_vio)
(completion->result != VDO_SUCCESS)) {
struct data_vio_pool *pool = completion->vdo->data_vio_pool;
- uds_funnel_queue_put(pool->queue, &completion->work_queue_entry_link);
+ vdo_funnel_queue_put(pool->queue, &completion->work_queue_entry_link);
schedule_releases(pool);
return;
}