266 lines
		
	
	
		
			6.3 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			266 lines
		
	
	
		
			6.3 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*
 | |
|  * Copyright (c) 2006-2018, RT-Thread Development Team
 | |
|  *
 | |
|  * SPDX-License-Identifier: Apache-2.0
 | |
|  *
 | |
|  * Change Logs:
 | |
|  * Date           Author       Notes
 | |
|  * 2018-09-07     armink       the first version
 | |
|  */
 | |
| 
 | |
| #include <stdarg.h>
 | |
| #include <ulog.h>
 | |
| #include <rthw.h>
 | |
| #include "syslog.h"
 | |
| 
 | |
| #ifdef ULOG_OUTPUT_FLOAT
 | |
| #include <stdio.h>
 | |
| #endif
 | |
| 
 | |
| /*
 | |
|  * reference:
 | |
|  * http://pubs.opengroup.org/onlinepubs/7908799/xsh/syslog.h.html
 | |
|  * https://www.gnu.org/software/libc/manual/html_node/Submitting-Syslog-Messages.html
 | |
|  * http://man7.org/linux/man-pages/man3/syslog.3.html
 | |
|  */
 | |
| 
 | |
| #ifdef ULOG_USING_SYSLOG
 | |
| 
 | |
| #include <sys/time.h>
 | |
| 
 | |
| #ifndef ULOG_SYSLOG_IDENT_MAX_LEN
 | |
| #define ULOG_SYSLOG_IDENT_MAX_LEN      ULOG_FILTER_TAG_MAX_LEN
 | |
| #endif
 | |
| 
 | |
| static char local_ident[ULOG_SYSLOG_IDENT_MAX_LEN + 1];
 | |
| static int local_facility = LOG_USER;
 | |
| static int local_option = LOG_USER;
 | |
| static rt_bool_t is_open = RT_FALSE;
 | |
| 
 | |
| /**
 | |
|  * open connection to syslog
 | |
|  *
 | |
|  * @param ident is an arbitrary identification string which future syslog invocations will prefix to each message.
 | |
|  * @param option is not using on ulog.
 | |
|  * @param facility is the default facility code for this connection.
 | |
|  */
 | |
| void openlog(const char *ident, int option, int facility)
 | |
| {
 | |
|     rt_base_t level;
 | |
| 
 | |
|     ulog_init();
 | |
| 
 | |
|     level = rt_hw_interrupt_disable();
 | |
| 
 | |
|     rt_memset(local_ident, 0, sizeof(local_ident));
 | |
|     if (ident)
 | |
|     {
 | |
|         rt_strncpy(local_ident, ident, ULOG_SYSLOG_IDENT_MAX_LEN);
 | |
|     }
 | |
|     else
 | |
|     {
 | |
|         rt_strncpy(local_ident, "rtt", ULOG_SYSLOG_IDENT_MAX_LEN);
 | |
|     }
 | |
| 
 | |
|     local_option = option;
 | |
| 
 | |
|     if (facility)
 | |
|     {
 | |
|         local_facility = facility;
 | |
|     }
 | |
|     else
 | |
|     {
 | |
|         /* default facility is LOG_USER */
 | |
|         local_facility = LOG_USER;
 | |
|     }
 | |
|     /* output all level log */
 | |
|     setlogmask(LOG_UPTO(LOG_DEBUG));
 | |
| 
 | |
|     is_open = RT_TRUE;
 | |
| 
 | |
|     rt_hw_interrupt_enable(level);
 | |
| 
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * This is functionally identical to syslog.
 | |
|  *
 | |
|  * @param priority log priority, can be generated by the macro LOG_MAKEPRI
 | |
|  * @param format log format
 | |
|  * @param args log arguments
 | |
|  */
 | |
| void vsyslog(int priority, const char *format, va_list args)
 | |
| {
 | |
|     if (LOG_FAC(priority) == 0)
 | |
|     {
 | |
|         /* using local facility */
 | |
|         priority |= local_facility;
 | |
|     }
 | |
| 
 | |
|     ulog_voutput(priority, local_ident, RT_TRUE, format, args);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * generates a log message
 | |
|  *
 | |
|  * @param priority log priority, can be generated by the macro LOG_MAKEPRI
 | |
|  * @param format log format, like printf()
 | |
|  */
 | |
| void syslog(int priority, const char *format, ...)
 | |
| {
 | |
|     va_list args;
 | |
| 
 | |
|     if (!is_open)
 | |
|     {
 | |
|         openlog(0, 0, 0);
 | |
|     }
 | |
|     /* args point to the first variable parameter */
 | |
|     va_start(args, format);
 | |
| 
 | |
|     vsyslog(priority, format, args);
 | |
| 
 | |
|     va_end(args);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * close the syslog
 | |
|  */
 | |
| void closelog(void)
 | |
| {
 | |
|     ulog_deinit();
 | |
| 
 | |
|     is_open = RT_FALSE;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * set log priority mask
 | |
|  *
 | |
|  * @param mask The log priority mask which generate by macro LOG_MASK and LOG_UPTO.
 | |
|  *
 | |
|  * @return This function returns the previous log priority mask.
 | |
|  */
 | |
| int setlogmask(int mask)
 | |
| {
 | |
|     static int old_mask = 0;
 | |
|     int return_mask = old_mask;
 | |
| 
 | |
|     ulog_tag_lvl_filter_set(local_ident, mask);
 | |
| 
 | |
|     old_mask = mask;
 | |
| 
 | |
|     return return_mask;
 | |
| }
 | |
| 
 | |
| static const char *get_month_str(uint8_t month)
 | |
| {
 | |
|     switch(month)
 | |
|     {
 | |
|     case 1: return "Jan";
 | |
|     case 2: return "Feb";
 | |
|     case 3: return "Mar";
 | |
|     case 4: return "Apr";
 | |
|     case 5: return "May";
 | |
|     case 6: return "June";
 | |
|     case 7: return "July";
 | |
|     case 8: return "Aug";
 | |
|     case 9: return "Sept";
 | |
|     case 10: return "Oct";
 | |
|     case 11: return "Nov";
 | |
|     case 12: return "Dec";
 | |
|     default: return "Unknown";
 | |
|     }
 | |
| }
 | |
| 
 | |
| RT_WEAK rt_size_t syslog_formater(char *log_buf, int level, const char *tag, rt_bool_t newline, const char *format, va_list args)
 | |
| {
 | |
|     extern size_t ulog_strcpy(size_t cur_len, char *dst, const char *src);
 | |
| 
 | |
|     rt_size_t log_len = 0, newline_len = rt_strlen(ULOG_NEWLINE_SIGN);
 | |
|     int fmt_result;
 | |
| 
 | |
|     RT_ASSERT(log_buf);
 | |
|     RT_ASSERT(LOG_PRI(level) <= LOG_DEBUG);
 | |
|     RT_ASSERT(tag);
 | |
|     RT_ASSERT(format);
 | |
| 
 | |
|     /* add time and priority (level) info */
 | |
|     {
 | |
|         time_t now = time(RT_NULL);
 | |
|         struct tm *tm, tm_tmp;
 | |
| 
 | |
|         tm = gmtime_r(&now, &tm_tmp);
 | |
| 
 | |
| #ifdef ULOG_OUTPUT_LEVEL
 | |
|         rt_snprintf(log_buf + log_len, ULOG_LINE_BUF_SIZE - log_len, "<%d>%s%3d %02d:%02d:%02d", level,
 | |
|                 get_month_str(tm->tm_mon + 1), tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec, rt_tick_get() % 1000);
 | |
| #else
 | |
|         rt_snprintf(log_buf + log_len, ULOG_LINE_BUF_SIZE - log_len, "%s%3d %02d:%02d:%02d",
 | |
|                 get_month_str(tm->tm_mon + 1), tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec, rt_tick_get() % 1000);
 | |
| #endif /* ULOG_OUTPUT_LEVEL */
 | |
| 
 | |
|         log_len += rt_strlen(log_buf + log_len);
 | |
|     }
 | |
| 
 | |
| #ifdef ULOG_OUTPUT_TAG
 | |
|     /* add identification (tag) info */
 | |
|     {
 | |
|         log_len += ulog_strcpy(log_len, log_buf + log_len, " ");
 | |
|         log_len += ulog_strcpy(log_len, log_buf + log_len, tag);
 | |
|     }
 | |
| #endif /* ULOG_OUTPUT_TAG */
 | |
| 
 | |
| #ifdef ULOG_OUTPUT_THREAD_NAME
 | |
|     /* add thread info */
 | |
|     {
 | |
|         log_len += ulog_strcpy(log_len, log_buf + log_len, " ");
 | |
|         /* is not in interrupt context */
 | |
|         if (rt_interrupt_get_nest() == 0)
 | |
|         {
 | |
|             log_len += ulog_strcpy(log_len, log_buf + log_len, rt_thread_self()->name);
 | |
|         }
 | |
|         else
 | |
|         {
 | |
|             log_len += ulog_strcpy(log_len, log_buf + log_len, "ISR");
 | |
|         }
 | |
|     }
 | |
| #endif /* ULOG_OUTPUT_THREAD_NAME */
 | |
| 
 | |
|     log_len += ulog_strcpy(log_len, log_buf + log_len, ": ");
 | |
| 
 | |
| #ifdef ULOG_OUTPUT_FLOAT
 | |
|     fmt_result = vsnprintf(log_buf + log_len, ULOG_LINE_BUF_SIZE - log_len, format, args);
 | |
| #else
 | |
|     fmt_result = rt_vsnprintf(log_buf + log_len, ULOG_LINE_BUF_SIZE - log_len, format, args);
 | |
| #endif /* ULOG_OUTPUT_FLOAT */
 | |
| 
 | |
|     /* calculate log length */
 | |
|     if ((log_len + fmt_result <= ULOG_LINE_BUF_SIZE) && (fmt_result > -1))
 | |
|     {
 | |
|         log_len += fmt_result;
 | |
|     }
 | |
|     else
 | |
|     {
 | |
|         /* using max length */
 | |
|         log_len = ULOG_LINE_BUF_SIZE;
 | |
|     }
 | |
| 
 | |
|     /* overflow check and reserve some space for newline sign */
 | |
|     if (log_len + newline_len > ULOG_LINE_BUF_SIZE)
 | |
|     {
 | |
|         /* using max length */
 | |
|         log_len = ULOG_LINE_BUF_SIZE;
 | |
|         /* reserve some space for newline sign */
 | |
|         log_len -= newline_len;
 | |
|     }
 | |
| 
 | |
|     /* package newline sign */
 | |
|     if (newline)
 | |
|     {
 | |
|         log_len += ulog_strcpy(log_len, log_buf + log_len, ULOG_NEWLINE_SIGN);
 | |
|     }
 | |
| 
 | |
|     return log_len;
 | |
| }
 | |
| 
 | |
| #endif /* ULOG_USING_SYSLOG */
 |