Commit de22c98d authored by Jaylyn Ren's avatar Jaylyn Ren Committed by Tomasz Zawadzki
Browse files

lib/vhost: add inline function blk_task_inc_task_cnt() and blk_task_dec_task_cnt()



Signed-off-by: default avatarJaylyn Ren <Jaylyn.Ren@arm.com>
Change-Id: I9900ddac89da00991227d98a41909aa48526f956
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/18176


Reviewed-by: default avatarTomasz Zawadzki <tomasz.zawadzki@intel.com>
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
Community-CI: Mellanox Build Bot
parent 9dad1237
Loading
Loading
Loading
Loading
+17 −5
Original line number Diff line number Diff line
@@ -119,11 +119,23 @@ to_blk_session(struct spdk_vhost_session *vsession)
	return (struct spdk_vhost_blk_session *)vsession;
}

static void
blk_task_finish(struct spdk_vhost_user_blk_task *task)
static inline void
blk_task_inc_task_cnt(struct spdk_vhost_user_blk_task *task)
{
	task->bvsession->vsession.task_cnt++;
}

static inline void
blk_task_dec_task_cnt(struct spdk_vhost_user_blk_task *task)
{
	assert(task->bvsession->vsession.task_cnt > 0);
	task->bvsession->vsession.task_cnt--;
}

static void
blk_task_finish(struct spdk_vhost_user_blk_task *task)
{
	blk_task_dec_task_cnt(task);
	task->used = false;
}

@@ -654,7 +666,7 @@ process_blk_task(struct spdk_vhost_virtqueue *vq, uint16_t req_idx)
		return;
	}

	task->bvsession->vsession.task_cnt++;
	blk_task_inc_task_cnt(task);

	blk_task_init(task);

@@ -719,7 +731,7 @@ process_packed_blk_task(struct spdk_vhost_virtqueue *vq, uint16_t req_idx)
					   req_idx, (req_idx + num_descs - 1) % vq->vring.size,
					   &task->inflight_head);

	task->bvsession->vsession.task_cnt++;
	blk_task_inc_task_cnt(task);

	blk_task_init(task);

@@ -780,7 +792,7 @@ process_packed_inflight_blk_task(struct spdk_vhost_virtqueue *vq,
	/* It's for cleaning inflight entries */
	task->inflight_head = req_idx;

	task->bvsession->vsession.task_cnt++;
	blk_task_inc_task_cnt(task);

	blk_task_init(task);