haiwen/libsearpc
1
0
Fork 0
mirror of https://github.com/haiwen/libsearpc.git synced 2025-05-09 23:56:19 +00:00
Code Issues Releases Wiki Activity

Add log to stdout ()

Browse Source 
Co-authored-by: 杨赫然 <heran.yang@seafile.com>
This commit is contained in:
feiniks 2024-10-24 11:08:23 +08:00 committed by GitHub
parent c917575246
commit 7f275255f0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 15 additions and 2 deletions

17
lib/searpc-server.c
View File

@ -41,6 +41,7 @@ static FILE *slow_log_fp = NULL;
static gint64 slow_threshold;
static GList *filtered_funcs;
static pthread_mutex_t slow_log_lock;
static gboolean log_to_stdout = FALSE;
#endif
static void
@ -205,7 +206,11 @@ searpc_server_init_with_slow_log (RegisterMarshalFunc register_func,
gint64 slow_threshold_in,
GList *filtered_funcs_in)
{
if (slow_log_path) {
const char *log_to_stdout_env = g_getenv("SEAFILE_LOG_TO_STDOUT");
if (g_strcmp0(log_to_stdout_env, "true") == 0) {
slow_log_fp = stdout;
log_to_stdout = TRUE;
} else if (slow_log_path) {
slow_log_fp = fopen (slow_log_path, "a+");
if (!slow_log_fp) {
g_warning ("Failed to open RPC slow log file %s: %s\n", slow_log_path, strerror(errno));
@ -227,6 +232,10 @@ searpc_server_reopen_slow_log (const char *slow_log_path)
{
FILE *fp, *oldfp;
if (log_to_stdout) {
return 0;
}
if ((fp = fopen (slow_log_path, "a+")) == NULL) {
g_warning ("Failed to open RPC slow log file %s\n", slow_log_path);
return -1;
@ -340,7 +349,11 @@ print_slow_log_if_necessary (const char *svc_name, const char *func, gsize len,
pthread_mutex_lock (&slow_log_lock);
fprintf (slow_log_fp, "%s - %s - %.*s - %.3f\n",
if (log_to_stdout) {
fprintf (slow_log_fp, "[seafile-slow-rpc] ");
}
fprintf (slow_log_fp, "[%s] - %s - %.*s - %.3f\n",
time_buf, svc_name, (int)len, func, intv_in_sec);
fflush (slow_log_fp);