motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-05 16:53:55 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

hw/rdma: Cosmetic change - move to generic function

Browse source 
To ease maintenance of struct comp_thread move all related code to
dedicated function.

Signed-off-by: Yuval Shaia <yuval.shaia@oracle.com>
Reviewed-by: Marcel Apfelbaum <marcel.apfelbaum@gmail.com>
Message-Id: <20180805153518.2983-11-yuval.shaia@oracle.com>
Signed-off-by: Marcel Apfelbaum <marcel.apfelbaum@gmail.com>
This commit is contained in:
Yuval Shaia 2018-08-05 18:35:15 +03:00 • committed by Marcel Apfelbaum
parent 67b32fe250
commit 292dce627b
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
hw/rdma/rdma_backend.c
View file

@ -146,10 +146,10 @@ static void *comp_handler_thread(void *arg)
return NULL; return NULL;
} }
static void stop_comp_thread(RdmaBackendDev *backend_dev) static void stop_backend_thread(RdmaBackendThread *thread)
{ {
backend_dev->comp_thread.run = false; thread->run = false;
while (backend_dev->comp_thread.is_running) { while (thread->is_running) {
pr_dbg("Waiting for thread to complete\n"); pr_dbg("Waiting for thread to complete\n");
sleep(THR_POLL_TO / SCALE_US / 2); sleep(THR_POLL_TO / SCALE_US / 2);
} }
@ -159,7 +159,7 @@ static void start_comp_thread(RdmaBackendDev *backend_dev)
{ {
char thread_name[THR_NAME_LEN] = {0}; char thread_name[THR_NAME_LEN] = {0};
stop_comp_thread(backend_dev); stop_backend_thread(&backend_dev->comp_thread);
snprintf(thread_name, sizeof(thread_name), "rdma_comp_%s", snprintf(thread_name, sizeof(thread_name), "rdma_comp_%s",
ibv_get_device_name(backend_dev->ib_dev)); ibv_get_device_name(backend_dev->ib_dev));
@ -876,7 +876,7 @@ void rdma_backend_start(RdmaBackendDev *backend_dev)
void rdma_backend_stop(RdmaBackendDev *backend_dev) void rdma_backend_stop(RdmaBackendDev *backend_dev)
{ {
pr_dbg("Stopping rdma_backend\n"); pr_dbg("Stopping rdma_backend\n");
stop_comp_thread(backend_dev); stop_backend_thread(&backend_dev->comp_thread);
} }
void rdma_backend_fini(RdmaBackendDev *backend_dev) void rdma_backend_fini(RdmaBackendDev *backend_dev)