motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-09 10:34:58 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

migration/multifd: Rename threadinfo.c functions

Browse source 
We're about to add more functions to this file so make it use the same
coding style as the rest of the code.

Signed-off-by: Fabiano Rosas <farosas@suse.de>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Philippe Mathieu-Daudé <philmd@linaro.org>
Reviewed-by: Peter Xu <peterx@redhat.com>
Message-Id: <20230607161306.31425-2-farosas@suse.de>
Signed-off-by: Juan Quintela <quintela@redhat.com>
This commit is contained in:
Fabiano Rosas 2023-06-07 13:13:04 -03:00 • committed by Juan Quintela
parent 6cb2011fed
commit 788fa68041
4 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

4
migration/migration.c
View file

@ -2953,7 +2953,7 @@ static void *migration_thread(void *opaque)
MigThrError thr_error; MigThrError thr_error;
bool urgent = false; bool urgent = false;
thread = MigrationThreadAdd("live_migration", qemu_get_thread_id()); thread = migration_threads_add("live_migration", qemu_get_thread_id());
rcu_register_thread(); rcu_register_thread();
@ -3031,7 +3031,7 @@ static void *migration_thread(void *opaque)
migration_iteration_finish(s); migration_iteration_finish(s);
object_unref(OBJECT(s)); object_unref(OBJECT(s));
rcu_unregister_thread(); rcu_unregister_thread();
MigrationThreadDel(thread); migration_threads_remove(thread);
return NULL; return NULL;
} }

4
migration/multifd.c
View file

@ -651,7 +651,7 @@ static void *multifd_send_thread(void *opaque)
int ret = 0; int ret = 0;
bool use_zero_copy_send = migrate_zero_copy_send(); bool use_zero_copy_send = migrate_zero_copy_send();
thread = MigrationThreadAdd(p->name, qemu_get_thread_id()); thread = migration_threads_add(p->name, qemu_get_thread_id());
trace_multifd_send_thread_start(p->id); trace_multifd_send_thread_start(p->id);
rcu_register_thread(); rcu_register_thread();
@ -767,7 +767,7 @@ out:
qemu_mutex_unlock(&p->mutex); qemu_mutex_unlock(&p->mutex);
rcu_unregister_thread(); rcu_unregister_thread();
MigrationThreadDel(thread); migration_threads_remove(thread);
trace_multifd_send_thread_end(p->id, p->num_packets, p->total_normal_pages); trace_multifd_send_thread_end(p->id, p->num_packets, p->total_normal_pages);
return NULL; return NULL;

4
migration/threadinfo.c
View file

@ -14,7 +14,7 @@
static QLIST_HEAD(, MigrationThread) migration_threads; static QLIST_HEAD(, MigrationThread) migration_threads;
MigrationThread *MigrationThreadAdd(const char *name, int thread_id) MigrationThread *migration_threads_add(const char *name, int thread_id)
{ {
MigrationThread *thread = g_new0(MigrationThread, 1); MigrationThread *thread = g_new0(MigrationThread, 1);
thread->name = name; thread->name = name;
@ -25,7 +25,7 @@ MigrationThread *MigrationThreadAdd(const char *name, int thread_id)
return thread; return thread;
} }
void MigrationThreadDel(MigrationThread *thread) void migration_threads_remove(MigrationThread *thread)
{ {
if (thread) { if (thread) {
QLIST_REMOVE(thread, node); QLIST_REMOVE(thread, node);

5
migration/threadinfo.h
View file

@ -23,6 +23,5 @@ struct MigrationThread {
QLIST_ENTRY(MigrationThread) node; QLIST_ENTRY(MigrationThread) node;
}; };
MigrationThread *MigrationThreadAdd(const char *name, int thread_id); MigrationThread *migration_threads_add(const char *name, int thread_id);
void migration_threads_remove(MigrationThread *info);
void MigrationThreadDel(MigrationThread *info);