ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

vhost: inline spdk_vhost_event_async_send_foreach_continue

Browse Source 
Despite its name, this function is defined as static
and is only used in one place, so inline it.

Change-Id: I4e217b3baae9b735761f5497f06b681a118860e9
Signed-off-by: Darek Stojaczyk <dariusz.stojaczyk@intel.com>
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/459162
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
This commit is contained in:
Darek Stojaczyk 2019-06-24 12:30:54 +02:00
parent 98af6aba4d
commit 4de67bbf6d
1 changed files with 15 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
lib/vhost/vhost.c
View File

@ -1020,30 +1020,6 @@ spdk_vhost_session_send_event(struct vhost_poll_group *pg,
return g_dpdk_response; return g_dpdk_response;
} }
static int
spdk_vhost_event_async_send_foreach_continue(struct spdk_vhost_session *vsession,
spdk_vhost_session_fn cb_fn, void *arg)
{
struct spdk_vhost_dev *vdev = vsession->vdev;
struct spdk_vhost_session_fn_ctx *ev_ctx;
ev_ctx = calloc(1, sizeof(*ev_ctx));
if (ev_ctx == NULL) {
SPDK_ERRLOG("Failed to alloc vhost event.\n");
assert(false);
return -ENOMEM;
}
ev_ctx->vdev = vdev;
ev_ctx->vsession_id = vsession->id;
ev_ctx->cb_fn = cb_fn;
ev_ctx->user_ctx = arg;
spdk_thread_send_msg(vsession->poll_group->thread,
spdk_vhost_event_async_foreach_fn, ev_ctx);
return 0;
}
static void static void
_stop_session(struct spdk_vhost_session *vsession) _stop_session(struct spdk_vhost_session *vsession)
{ {
@ -1362,6 +1338,7 @@ spdk_vhost_external_event_foreach_continue(struct spdk_vhost_dev *vdev,
struct spdk_vhost_session *vsession, struct spdk_vhost_session *vsession,
spdk_vhost_session_fn fn, void *arg) spdk_vhost_session_fn fn, void *arg)
{ {
struct spdk_vhost_session_fn_ctx *ev_ctx;
int rc; int rc;
if (vsession == NULL) { if (vsession == NULL) {
@ -1382,7 +1359,20 @@ spdk_vhost_external_event_foreach_continue(struct spdk_vhost_dev *vdev,
} }
} }
spdk_vhost_event_async_send_foreach_continue(vsession, fn, arg); ev_ctx = calloc(1, sizeof(*ev_ctx));
if (ev_ctx == NULL) {
SPDK_ERRLOG("Failed to alloc vhost event.\n");
assert(false);
return;
}
ev_ctx->vdev = vdev;
ev_ctx->vsession_id = vsession->id;
ev_ctx->cb_fn = fn;
ev_ctx->user_ctx = arg;
spdk_thread_send_msg(vsession->poll_group->thread,
spdk_vhost_event_async_foreach_fn, ev_ctx);
return; return;
out_finish_foreach: out_finish_foreach: