Skip to content

Commit b53a4d3

Browse files
committed
move mercury logging setup after margo init
1 parent 9726494 commit b53a4d3

File tree

1 file changed

+35
-26
lines changed

1 file changed

+35
-26
lines changed

server/src/margo_server.c

Lines changed: 35 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -418,32 +418,6 @@ int margo_server_rpc_init(void)
418418
}
419419
}
420420

421-
#if defined(HG_VERSION_MAJOR) && (HG_VERSION_MAJOR > 1)
422-
/* redirect mercury log to ours, using current log level */
423-
const char* mercury_log_level = NULL;
424-
switch (unifyfs_log_level) {
425-
case LOG_DBG:
426-
mercury_log_level = "debug";
427-
break;
428-
case LOG_ERR:
429-
mercury_log_level = "error";
430-
break;
431-
case LOG_WARN:
432-
mercury_log_level = "warning";
433-
break;
434-
default:
435-
break;
436-
}
437-
if (NULL != mercury_log_level) {
438-
HG_Set_log_level(mercury_log_level);
439-
}
440-
if (NULL != unifyfs_log_stream) {
441-
hg_log_set_stream_debug(unifyfs_log_stream);
442-
hg_log_set_stream_error(unifyfs_log_stream);
443-
hg_log_set_stream_warning(unifyfs_log_stream);
444-
}
445-
#endif
446-
447421
margo_instance_id mid;
448422
mid = setup_local_target();
449423
if (mid == MARGO_INSTANCE_NULL) {
@@ -485,6 +459,41 @@ int margo_server_rpc_init(void)
485459
}
486460
}
487461

462+
#if defined(HG_VERSION_MAJOR) && (HG_VERSION_MAJOR > 1)
463+
/* redirect mercury logging to ours */
464+
if (NULL != unifyfs_log_stream) {
465+
hg_log_set_stream_debug(unifyfs_log_stream);
466+
hg_log_set_stream_error(unifyfs_log_stream);
467+
hg_log_set_stream_warning(unifyfs_log_stream);
468+
}
469+
470+
/* set mercury log output using current log level */
471+
const char* mercury_log_level = NULL;
472+
const char* mercury_log_subsys = NULL;
473+
switch (unifyfs_log_level) {
474+
case LOG_DBG:
475+
mercury_log_level = "debug";
476+
mercury_log_subsys = "hg,addr,bulk,na,proc,rpc"; // kitchen sink
477+
break;
478+
case LOG_ERR:
479+
mercury_log_level = "error";
480+
mercury_log_subsys = "hg,rpc";
481+
break;
482+
case LOG_WARN:
483+
mercury_log_level = "warning";
484+
mercury_log_subsys = "hg,rpc";
485+
break;
486+
default:
487+
break;
488+
}
489+
if (NULL != mercury_log_level) {
490+
HG_Set_log_level(mercury_log_level);
491+
if (NULL != mercury_log_subsys) {
492+
HG_Set_log_subsys(mercury_log_subsys);
493+
}
494+
}
495+
#endif
496+
488497
return rc;
489498
}
490499

0 commit comments

Comments
 (0)