46 #include <qb/qbdefs.h>
47 #include <qb/qbutil.h>
64 {
"alert", LOG_ALERT },
66 {
"debug", LOG_DEBUG },
67 {
"emerg", LOG_EMERG },
71 {
"notice", LOG_NOTICE },
72 {
"warning", LOG_WARNING },
76 #define MAX_FILES_PER_SUBSYS 32
77 #ifdef HAVE_SMALL_MEMORY_FOOTPRINT
78 #define IPC_LOGSYS_SIZE 8192*64
80 #define IPC_LOGSYS_SIZE 8192*1024
102 #define LOGSYS_LOGGER_INIT_DONE 0
103 #define LOGSYS_LOGGER_NEEDS_INIT 1
109 static pthread_mutex_t logsys_config_mutex = PTHREAD_MUTEX_INITIALIZER;
111 static int32_t _logsys_config_mode_set_unlocked(int32_t subsysid, uint32_t new_mode);
112 static void _logsys_config_apply_per_file(int32_t s,
const char *filename);
113 static void _logsys_config_apply_per_subsys(int32_t s);
114 static void _logsys_subsys_filename_add (int32_t s,
const char *filename);
115 static void logsys_file_format_get(
char* file_format,
int buf_len);
117 static char *format_buffer=NULL;
119 static int logsys_thread_started = 0;
121 static int logsys_blackbox_enabled = 1;
123 static int _logsys_config_subsys_get_unlocked (
const char *
subsys)
145 static int logsys_config_file_set_unlocked (
147 const char **error_string,
150 static char error_string_response[512];
152 char file_format[128];
154 if (logsys_loggers[subsysid].
target_id > 0) {
156 for (f = 0; f < logsys_loggers[subsysid].
file_idx; f++) {
157 qb_log_filter_ctl(logsys_loggers[subsysid].
target_id,
158 QB_LOG_FILTER_REMOVE,
160 logsys_loggers[subsysid].
files[f],
165 logsys_loggers[subsysid].
dirty = QB_TRUE;
170 if (logsys_loggers[subsysid].
target_id > 0 &&
171 logsys_loggers[subsysid].
logfile != NULL &&
172 strcmp(file, logsys_loggers[subsysid].
logfile) == 0) {
176 if (strlen(file) >= PATH_MAX) {
177 snprintf (error_string_response,
178 sizeof(error_string_response),
179 "%s: logfile name exceed maximum system filename length",
180 logsys_loggers[subsysid].
subsys);
181 *error_string = error_string_response;
185 if (logsys_loggers[subsysid].
logfile != NULL) {
186 free(logsys_loggers[subsysid].
logfile);
187 logsys_loggers[subsysid].
logfile = NULL;
190 logsys_loggers[subsysid].
logfile = strdup(file);
192 if (logsys_loggers[subsysid].
logfile == NULL) {
193 snprintf (error_string_response,
194 sizeof(error_string_response),
195 "Unable to allocate memory for logfile '%s'",
197 *error_string = error_string_response;
202 if ((logsys_loggers[i].
logfile != NULL) &&
203 (strcmp (logsys_loggers[i].
logfile, file) == 0) &&
213 if (logsys_loggers[subsysid].
target_id > 0) {
214 int num_using_current = 0;
216 if (logsys_loggers[subsysid].
target_id ==
221 if (num_using_current == 1) {
223 qb_log_file_close(logsys_loggers[subsysid].
target_id);
227 logsys_loggers[subsysid].
target_id = qb_log_file_open(file);
228 if (logsys_loggers[subsysid].
target_id < 0) {
229 int err = -logsys_loggers[subsysid].
target_id;
231 const char *error_ptr;
232 error_ptr = qb_strerror_r(err, error_str,
sizeof(error_str));
234 free(logsys_loggers[subsysid].
logfile);
235 logsys_loggers[subsysid].
logfile = NULL;
236 snprintf (error_string_response,
237 sizeof(error_string_response),
238 "Can't open logfile '%s' for reason: %s (%d)",
239 file, error_ptr, err);
240 *error_string = error_string_response;
243 logsys_file_format_get(file_format, 128);
244 qb_log_format_set(logsys_loggers[subsysid].
target_id, file_format);
246 qb_log_ctl(logsys_loggers[subsysid].
target_id,
249 if (logsys_thread_started) {
250 qb_log_ctl(logsys_loggers[subsysid].
target_id, QB_LOG_CONF_THREADED, QB_TRUE);
256 static void logsys_subsys_init (
271 sizeof (logsys_loggers[subsysid].
subsys));
272 logsys_loggers[subsysid].
subsys[
273 sizeof (logsys_loggers[subsysid].
subsys) - 1] =
'\0';
274 logsys_loggers[subsysid].
file_idx = 0;
277 static const char *_logsys_tags_stringify(uint32_t tags)
279 if (tags == QB_LOG_TAG_LIBQB_MSG) {
282 return logsys_loggers[tags].
subsys;
291 free(logsys_loggers[i].
logfile);
292 for (f = 0; f < logsys_loggers[i].
file_idx; f++) {
293 free(logsys_loggers[i].
files[f]);
305 const char *mainsystem,
314 if ((mainsystem == NULL) ||
323 "log_file.c,log_dcs.c,log_thread.c,ipc_shm.c,ipcs.c,ipc_us.c,loop.c,"
324 "loop_poll_epoll.c,loop_job.c,loop_poll_poll.c,loop_poll_kqueue.c,"
325 "loop_timerlist.c,loop_poll.c,ringbuffer.c,ringbuffer_helper.c,trie.c,"
326 "map.c,skiplist.c,rpl_sem.c,hdb.c,unix.c,hashtable.c,strlcpy.c,ipc_socket.c,"
327 "strchrnul.c,ipc_setup.c,strlcat.c");
341 _logsys_subsys_filename_add (i,
"logsys.c");
345 pthread_mutex_lock (&logsys_config_mutex);
347 snprintf(logsys_loggers[i].
subsys,
359 qb_log_ctl(QB_LOG_STDERR, QB_LOG_CONF_ENABLED, QB_TRUE);
361 qb_log_ctl(QB_LOG_STDERR, QB_LOG_CONF_ENABLED, QB_FALSE);
364 qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_ENABLED, QB_TRUE);
366 qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_ENABLED, QB_FALSE);
368 qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_PRIORITY_BUMP, LOG_INFO - LOG_DEBUG);
370 qb_log_filter_ctl(QB_LOG_BLACKBOX, QB_LOG_FILTER_ADD,
371 QB_LOG_FILTER_FILE,
"*", LOG_TRACE);
373 qb_log_ctl(QB_LOG_BLACKBOX, QB_LOG_CONF_THREADED, QB_FALSE);
379 qb_log_ctl(QB_LOG_BLACKBOX, QB_LOG_CONF_ENABLED, QB_FALSE);
385 qb_log_tags_stringify_fn_set(_logsys_tags_stringify);
391 if ((strcmp (logsys_loggers[i].
subsys,
"") != 0) &&
395 strncpy (tempsubsys, logsys_loggers[i].
subsys,
396 sizeof (tempsubsys));
397 tempsubsys[
sizeof (tempsubsys) - 1] =
'\0';
398 logsys_subsys_init(tempsubsys, i);
400 _logsys_config_mode_set_unlocked(i, logsys_loggers[i].
mode);
401 _logsys_config_apply_per_subsys(i);
405 pthread_mutex_unlock (&logsys_config_mutex);
411 static void _logsys_subsys_filename_add (int32_t s,
const char *filename)
415 if (filename == NULL) {
419 assert(logsys_loggers[s].
file_idx >= 0);
421 for (i = 0; i < logsys_loggers[s].
file_idx; i++) {
422 if (strcmp(logsys_loggers[s].
files[i], filename) == 0) {
426 logsys_loggers[s].
files[logsys_loggers[s].
file_idx++] = strdup(filename);
429 _logsys_config_apply_per_file(s, filename);
442 pthread_mutex_lock (&logsys_config_mutex);
444 i = _logsys_config_subsys_get_unlocked (
subsys);
446 _logsys_subsys_filename_add(i, filename);
447 pthread_mutex_unlock (&logsys_config_mutex);
452 if (strcmp (logsys_loggers[i].
subsys,
"") == 0) {
453 logsys_subsys_init(
subsys, i);
454 _logsys_subsys_filename_add(i, filename);
463 pthread_mutex_unlock (&logsys_config_mutex);
471 pthread_mutex_lock (&logsys_config_mutex);
473 i = _logsys_config_subsys_get_unlocked (
subsys);
475 pthread_mutex_unlock (&logsys_config_mutex);
480 static int32_t _logsys_config_mode_set_unlocked(int32_t subsysid, uint32_t new_mode)
482 if ( logsys_loggers[subsysid].
mode == new_mode) {
485 if (logsys_loggers[subsysid].
target_id > 0) {
486 qb_log_ctl(logsys_loggers[subsysid].
target_id,
492 qb_log_ctl(QB_LOG_STDERR,
495 qb_log_ctl(QB_LOG_SYSLOG,
499 logsys_loggers[subsysid].
mode = new_mode;
507 pthread_mutex_lock (&logsys_config_mutex);
509 i = _logsys_config_subsys_get_unlocked (
subsys);
511 i = _logsys_config_mode_set_unlocked(i,
mode);
515 _logsys_config_mode_set_unlocked(i,
mode);
520 pthread_mutex_unlock (&logsys_config_mutex);
534 return logsys_loggers[i].
mode;
539 const char **error_string,
545 pthread_mutex_lock (&logsys_config_mutex);
548 i = _logsys_config_subsys_get_unlocked (
subsys);
552 res = logsys_config_file_set_unlocked(i, error_string, file);
556 res = logsys_config_file_set_unlocked(i, error_string, file);
563 pthread_mutex_unlock (&logsys_config_mutex);
568 logsys_file_format_get(
char* file_format,
int buf_len)
570 char *format_buffer_start;
573 file_format[0] =
'\0';
575 format_buffer_start = format_buffer;
577 if ((str_pos = strstr(format_buffer,
"%t"))) {
578 strcpy(file_format,
"%t ");
579 format_buffer_start = str_pos + 2;
582 if ((str_pos = strstr(format_buffer,
"%T"))) {
583 strcpy(file_format,
"%T ");
584 format_buffer_start = str_pos + 2;
587 strcat(file_format,
"[%P] %H %N");
588 strncat(file_format, format_buffer_start, buf_len - strlen(file_format));
597 char syslog_format[128];
598 char file_format[128];
602 format_buffer = NULL;
605 format_buffer = strdup(format ? format :
"%7p [%6g] %b");
606 if (format_buffer == NULL) {
610 qb_log_format_set(QB_LOG_STDERR, format_buffer);
612 logsys_file_format_get(file_format, 128);
615 qb_log_format_set(logsys_loggers[i].
target_id, file_format);
624 memset(syslog_format,
'\0',
sizeof(syslog_format));
625 for (c = 0; c < strlen(format_buffer); c++) {
626 if (format_buffer[c] ==
'%') {
628 for (c++; c < strlen(format_buffer); c++) {
629 if (isdigit(format_buffer[c])) {
632 if (format_buffer[c] ==
't' ||
633 format_buffer[c] ==
'p' ||
634 format_buffer[c] ==
'T') {
642 syslog_format[w] = format_buffer[c];
645 qb_log_format_set(QB_LOG_SYSLOG, syslog_format);
652 return format_buffer;
657 unsigned int facility)
659 return qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_FACILITY, facility);
664 unsigned int priority)
668 pthread_mutex_lock (&logsys_config_mutex);
670 i = _logsys_config_subsys_get_unlocked (
subsys);
673 logsys_loggers[i].
dirty = QB_TRUE;
680 logsys_loggers[i].
dirty = QB_TRUE;
684 pthread_mutex_unlock (&logsys_config_mutex);
691 unsigned int priority)
695 pthread_mutex_lock (&logsys_config_mutex);
697 i = _logsys_config_subsys_get_unlocked (
subsys);
700 logsys_loggers[i].
dirty = QB_TRUE;
706 logsys_loggers[i].
dirty = QB_TRUE;
710 pthread_mutex_unlock (&logsys_config_mutex);
716 static void _logsys_config_apply_per_file(int32_t s,
const char *filename)
721 qb_log_filter_ctl(s, QB_LOG_TAG_SET, QB_LOG_FILTER_FILE,
722 filename, LOG_TRACE);
724 qb_log_filter_ctl(QB_LOG_SYSLOG, QB_LOG_FILTER_REMOVE,
725 QB_LOG_FILTER_FILE, filename, LOG_TRACE);
726 qb_log_filter_ctl(QB_LOG_STDERR, QB_LOG_FILTER_REMOVE,
727 QB_LOG_FILTER_FILE, filename, LOG_TRACE);
729 qb_log_filter_ctl(logsys_loggers[s].
target_id,
730 QB_LOG_FILTER_REMOVE,
731 QB_LOG_FILTER_FILE, filename, LOG_TRACE);
735 switch (logsys_loggers[s].
debug) {
748 qb_log_filter_ctl(QB_LOG_SYSLOG, QB_LOG_FILTER_ADD,
749 QB_LOG_FILTER_FILE, filename,
751 qb_log_filter_ctl(QB_LOG_STDERR, QB_LOG_FILTER_ADD,
752 QB_LOG_FILTER_FILE, filename,
755 qb_log_filter_ctl(logsys_loggers[s].
target_id,
757 QB_LOG_FILTER_FILE, filename,
762 static void _logsys_config_apply_per_subsys(int32_t s)
765 for (f = 0; f < logsys_loggers[s].
file_idx; f++) {
766 _logsys_config_apply_per_file(s, logsys_loggers[s].
files[f]);
773 logsys_loggers[s].
dirty = QB_FALSE;
776 static void _logsys_config_apply_blackbox(
void) {
777 int blackbox_enable_res;
779 blackbox_enable_res = qb_log_ctl(QB_LOG_BLACKBOX, QB_LOG_CONF_ENABLED, logsys_blackbox_enabled);
781 if (blackbox_enable_res < 0) {
783 "Unable to initialize log flight recorder. "\
784 "The most common cause of this error is " \
785 "not enough space on /dev/shm. Corosync will continue work, " \
786 "but blackbox will not be available");
794 _logsys_config_apply_blackbox();
797 if (strcmp(logsys_loggers[s].
subsys,
"") == 0) {
800 _logsys_config_apply_per_subsys(s);
810 pthread_mutex_lock (&logsys_config_mutex);
812 i = _logsys_config_subsys_get_unlocked (
subsys);
814 logsys_loggers[i].
dirty = QB_TRUE;
821 logsys_loggers[i].
dirty = QB_TRUE;
825 pthread_mutex_unlock (&logsys_config_mutex);
834 for (i = 0; prioritynames[i].
c_name != NULL; i++) {
835 if (strcasecmp(name, prioritynames[i].c_name) == 0) {
836 return (prioritynames[i].c_val);
847 err = qb_log_thread_start();
852 qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_THREADED, QB_TRUE);
855 qb_log_ctl(logsys_loggers[i].
target_id, QB_LOG_CONF_THREADED, QB_TRUE);
859 logsys_thread_started = 1;
867 pthread_mutex_lock (&logsys_config_mutex);
869 logsys_blackbox_enabled = enable;
871 pthread_mutex_unlock (&logsys_config_mutex);
881 (void)qb_log_ctl(QB_LOG_BLACKBOX, QB_LOG_CONF_ENABLED, QB_FALSE);
887 _logsys_config_apply_blackbox();
894 #ifdef HAVE_QB_LOG_FILE_REOPEN
896 int num_using_current;
901 pthread_mutex_lock (&logsys_config_mutex);
904 if (logsys_loggers[i].
target_id <= 0 || logsys_loggers[i].
logfile == NULL) {
908 num_using_current = 0;
909 for (j = 0; j <= i; j++) {
914 if (num_using_current == 1) {
918 rc = qb_log_file_reopen(logsys_loggers[i].
target_id, NULL);
921 "Unable to reopen log file %s", logsys_loggers[i].
logfile);
927 pthread_mutex_unlock (&logsys_config_mutex);
cs_error_t qb_to_cs_error(int result)
qb_to_cs_error
cs_error_t
The cs_error_t enum.
unsigned int logsys_config_mode_get(const char *subsys)
logsys_config_mode_get
int logsys_config_mode_set(const char *subsys, unsigned int mode)
logsys_config_mode_set
void logsys_blackbox_set(int enable)
void logsys_blackbox_prefork(void)
void logsys_system_fini(void)
logsys_system_fini
int logsys_config_file_set(const char *subsys, const char **error_string, const char *file)
to close a logfile, just invoke this function with a NULL file or if you want to change logfile,...
int logsys_config_syslog_priority_set(const char *subsys, unsigned int priority)
logsys_config_syslog_priority_set
char * logsys_format_get(void)
logsys_format_get
void logsys_config_apply(void)
logsys_config_apply
int logsys_priority_id_get(const char *name)
logsys_priority_id_get
#define LOGSYS_LOGGER_INIT_DONE
int logsys_config_logfile_priority_set(const char *subsys, unsigned int priority)
logsys_config_logfile_priority_set
int logsys_thread_start(void)
logsys_thread_start
int logsys_config_debug_set(const char *subsys, unsigned int debug)
enabling debug, disable message priority filtering.
int _logsys_config_subsys_get(const char *subsys)
_logsys_config_subsys_get
int _logsys_subsys_create(const char *subsys, const char *filename)
_logsys_subsys_create
int logsys_config_syslog_facility_set(const char *subsys, unsigned int facility)
per system/subsystem settings.
cs_error_t logsys_reopen_log_files(void)
#define MAX_FILES_PER_SUBSYS
void logsys_blackbox_postfork(void)
int _logsys_system_setup(const char *mainsystem, unsigned int mode, int syslog_facility, int syslog_priority)
_logsys_system_setup
int logsys_format_set(const char *format)
configuration bits that can only be done for the whole system
#define LOGSYS_LOGGER_NEEDS_INIT
#define LOGSYS_MAX_SUBSYS_NAMELEN
#define LOGSYS_MODE_OUTPUT_STDERR
#define LOGSYS_DEBUG_TRACE
#define LOGSYS_PERROR(err_num, level, fmt, args...)
The LOGSYS_PERROR macro.
#define LOGSYS_LEVEL_WARNING
#define LOGSYS_MAX_PERROR_MSG_LEN
#define LOGSYS_MODE_OUTPUT_FILE
#define LOGSYS_MODE_OUTPUT_SYSLOG
#define LOGSYS_MAX_SUBSYS_COUNT
char * files[MAX_FILES_PER_SUBSYS]
char subsys[LOGSYS_MAX_SUBSYS_NAMELEN]