mirrors/qemu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

util/log: Rename QemuLogFile to RCUCloseFILE

Browse Source 
s/QemuLogFile/RCUCloseFILE/
s/qemu_logfile_free/rcu_close_file/

Emphasize that this is only a carrier for passing a pointer
to call_rcu for closing, and not the real logfile.

Reviewed-by: Alex Bennée <alex.bennee@linaro.org>
Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org>
Signed-off-by: Richard Henderson <richard.henderson@linaro.org>
Message-Id: <20220417183019.755276-38-richard.henderson@linaro.org>
This commit is contained in:
Richard Henderson 2022-04-17 11:30:17 -07:00
parent 92b24cb77f
commit d5f55fff34
1 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
util/log.c
View File

@ -29,15 +29,15 @@
#include "qemu/rcu.h" #include "qemu/rcu.h"
typedef struct QemuLogFile { typedef struct RCUCloseFILE {
struct rcu_head rcu; struct rcu_head rcu;
FILE *fd; FILE *fd;
} QemuLogFile; } RCUCloseFILE;
/* Mutex covering the other global_* variables. */ /* Mutex covering the other global_* variables. */
static QemuMutex global_mutex; static QemuMutex global_mutex;
static char *global_filename; static char *global_filename;
static QemuLogFile *global_file; static RCUCloseFILE *global_file;
int qemu_loglevel; int qemu_loglevel;
static int log_append = 0; static int log_append = 0;
@ -52,7 +52,7 @@ bool qemu_log_enabled(void)
/* Returns true if qemu_log() will write somewhere other than stderr. */ /* Returns true if qemu_log() will write somewhere other than stderr. */
bool qemu_log_separate(void) bool qemu_log_separate(void)
{ {
QemuLogFile *logfile; RCUCloseFILE *logfile;
bool res = false; bool res = false;
rcu_read_lock(); rcu_read_lock();
@ -68,7 +68,7 @@ bool qemu_log_separate(void)
FILE *qemu_log_trylock(void) FILE *qemu_log_trylock(void)
{ {
QemuLogFile *logfile; RCUCloseFILE *logfile;
rcu_read_lock(); rcu_read_lock();
logfile = qatomic_rcu_read(&global_file); logfile = qatomic_rcu_read(&global_file);
@ -108,14 +108,12 @@ static void __attribute__((__constructor__)) startup(void)
qemu_mutex_init(&global_mutex); qemu_mutex_init(&global_mutex);
} }
static void qemu_logfile_free(QemuLogFile *logfile) static void rcu_close_file(RCUCloseFILE *r)
{ {
g_assert(logfile); if (r->fd != stderr) {
fclose(r->fd);
if (logfile->fd != stderr) {
fclose(logfile->fd);
} }
g_free(logfile); g_free(r);
} }
/* enable or disable low levels log */ /* enable or disable low levels log */
@ -124,7 +122,7 @@ static bool qemu_set_log_internal(const char *filename, bool changed_name,
{ {
bool need_to_open_file; bool need_to_open_file;
bool daemonized; bool daemonized;
QemuLogFile *logfile; RCUCloseFILE *logfile;
QEMU_LOCK_GUARD(&global_mutex); QEMU_LOCK_GUARD(&global_mutex);
logfile = global_file; logfile = global_file;
@ -178,7 +176,7 @@ static bool qemu_set_log_internal(const char *filename, bool changed_name,
if (logfile && (!need_to_open_file || changed_name)) { if (logfile && (!need_to_open_file || changed_name)) {
qatomic_rcu_set(&global_file, NULL); qatomic_rcu_set(&global_file, NULL);
call_rcu(logfile, qemu_logfile_free, rcu); call_rcu(logfile, rcu_close_file, rcu);
logfile = NULL; logfile = NULL;
} }
@ -196,7 +194,7 @@ static bool qemu_set_log_internal(const char *filename, bool changed_name,
if (daemonized) { if (daemonized) {
dup2(fileno(fd), STDERR_FILENO); dup2(fileno(fd), STDERR_FILENO);
fclose(fd); fclose(fd);
/* This will skip closing logfile in qemu_logfile_free. */ /* This will skip closing logfile in rcu_close_file. */
fd = stderr; fd = stderr;
} }
} else { } else {
@ -207,7 +205,7 @@ static bool qemu_set_log_internal(const char *filename, bool changed_name,
log_append = 1; log_append = 1;
logfile = g_new0(QemuLogFile, 1); logfile = g_new0(RCUCloseFILE, 1);
logfile->fd = fd; logfile->fd = fd;
qatomic_rcu_set(&global_file, logfile); qatomic_rcu_set(&global_file, logfile);
} }