feature:根据文件大小分割日志
This commit is contained in:
15
README.md
15
README.md
@@ -70,15 +70,18 @@ int main() {
|
|||||||
Logger *logger = log->getLogger("testLogger", LOG_DEBUG);
|
Logger *logger = log->getLogger("testLogger", LOG_DEBUG);
|
||||||
|
|
||||||
logger->info("This is an info message");
|
logger->info("This is an info message");
|
||||||
logger->error("你好,这是一个错误消息%s", "123");
|
logger->error("This is an error message%s", "123");
|
||||||
logger->fatal("This is an fatal message");
|
logger->fatal("This is an fatal message");
|
||||||
logger->debug("This is a debug message");
|
logger->debug("This is a debug message");
|
||||||
logger->warning("This is a warning message%s", "123");
|
logger->warning("This is a warning message%s", "123");
|
||||||
|
|
||||||
char *test1[] = {"123", "你好"}; // 要拦截的字符串
|
char *test1[] = {"123", "tt"};
|
||||||
// 添加拦截器,将拦截到的日志重定向到拦截器的专属处理器中
|
|
||||||
log_Interceptor *tint =
|
log_Interceptor *tint = loggingSubStringInterceptor(
|
||||||
loggingSubStringInterceptor(test1, 2, LOG_DEBUG, loggingFileHandler("被拦截"));
|
test1,
|
||||||
|
2,
|
||||||
|
LOG_DEBUG,
|
||||||
|
loggingFileHandler("test_interceptor", 1024 * 1024));
|
||||||
|
|
||||||
logger->addInterceptor(tint);
|
logger->addInterceptor(tint);
|
||||||
|
|
||||||
@@ -87,7 +90,7 @@ int main() {
|
|||||||
printf("\n");
|
printf("\n");
|
||||||
|
|
||||||
logger->info("This is an info message");
|
logger->info("This is an info message");
|
||||||
logger->error("你好,这是一个错误消息%s", "123");
|
logger->error("This is an error message%s", "123");
|
||||||
logger->fatal("This is an fatal message");
|
logger->fatal("This is an fatal message");
|
||||||
logger->debug("This is a debug message");
|
logger->debug("This is a debug message");
|
||||||
logger->warning("This is a warning message%s", "123");
|
logger->warning("This is a warning message%s", "123");
|
||||||
|
|||||||
@@ -8,6 +8,9 @@
|
|||||||
#include "logging/logging-handler.h"
|
#include "logging/logging-handler.h"
|
||||||
#include "logging/logging-interceptor.h"
|
#include "logging/logging-interceptor.h"
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif
|
||||||
|
|
||||||
typedef struct Logger {
|
typedef struct Logger {
|
||||||
log_level level;
|
log_level level;
|
||||||
@@ -34,4 +37,8 @@ typedef struct Logging {
|
|||||||
|
|
||||||
Logging *newLogging();
|
Logging *newLogging();
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
#endif // __LOGGING_H__
|
#endif // __LOGGING_H__
|
||||||
@@ -1,6 +1,10 @@
|
|||||||
#ifndef __LOGGING_CORE_H__
|
#ifndef __LOGGING_CORE_H__
|
||||||
#define __LOGGING_CORE_H__
|
#define __LOGGING_CORE_H__
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif
|
||||||
|
|
||||||
typedef enum {
|
typedef enum {
|
||||||
LOG_FATAL,
|
LOG_FATAL,
|
||||||
LOG_ERROR,
|
LOG_ERROR,
|
||||||
@@ -14,4 +18,8 @@ typedef enum {
|
|||||||
L_OK,
|
L_OK,
|
||||||
} log_status;
|
} log_status;
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
#endif // __LOGGING_CORE_H__
|
#endif // __LOGGING_CORE_H__
|
||||||
|
|||||||
@@ -3,6 +3,10 @@
|
|||||||
|
|
||||||
#include <stdbool.h>
|
#include <stdbool.h>
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif
|
||||||
|
|
||||||
typedef struct log_Handler {
|
typedef struct log_Handler {
|
||||||
void *stream;
|
void *stream;
|
||||||
bool apply_color;
|
bool apply_color;
|
||||||
@@ -10,7 +14,11 @@ typedef struct log_Handler {
|
|||||||
void (*output)(struct log_Handler *handler, const char *message);
|
void (*output)(struct log_Handler *handler, const char *message);
|
||||||
} log_Handler;
|
} log_Handler;
|
||||||
|
|
||||||
log_Handler *loggingFileHandler(const char *name);
|
log_Handler *loggingFileHandler(const char *name, unsigned int max_size);
|
||||||
log_Handler *loggingConsoleHandler();
|
log_Handler *loggingConsoleHandler();
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
#endif //__LOGGING_HANDLER_H__
|
#endif //__LOGGING_HANDLER_H__
|
||||||
@@ -4,6 +4,10 @@
|
|||||||
#include "logging-core.h"
|
#include "logging-core.h"
|
||||||
#include "logging-handler.h"
|
#include "logging-handler.h"
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif
|
||||||
|
|
||||||
typedef struct log_Interceptor {
|
typedef struct log_Interceptor {
|
||||||
log_level level;
|
log_level level;
|
||||||
log_Handler *handler;
|
log_Handler *handler;
|
||||||
@@ -23,4 +27,8 @@ log_Interceptor *loggingSubStringInterceptor(char *keywords[],
|
|||||||
log_level level,
|
log_level level,
|
||||||
log_Handler *handler);
|
log_Handler *handler);
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
#endif // __LOGGING_INTERCEPTOR_H__
|
#endif // __LOGGING_INTERCEPTOR_H__
|
||||||
@@ -3,6 +3,7 @@ project(logging)
|
|||||||
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SRC)
|
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SRC)
|
||||||
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/handler SRC)
|
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/handler SRC)
|
||||||
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/interceptor SRC)
|
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/interceptor SRC)
|
||||||
|
aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/utils SRC)
|
||||||
|
|
||||||
if (SHARED)
|
if (SHARED)
|
||||||
add_library(${PROJECT_NAME} SHARED ${SRC})
|
add_library(${PROJECT_NAME} SHARED ${SRC})
|
||||||
|
|||||||
@@ -1,28 +1,73 @@
|
|||||||
#include "logging/logging-handler.h"
|
#include "logging/logging-handler.h"
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
#define Handler_FILE_EX_PRT(fp) \
|
||||||
|
((log_Handler_file_ex_t *)(fp + sizeof(log_Handler)))
|
||||||
|
|
||||||
|
typedef struct log_Handler_file_ex_s {
|
||||||
|
unsigned int file_size;
|
||||||
|
unsigned int file_size_max;
|
||||||
|
unsigned int suffix;
|
||||||
|
char *file_name;
|
||||||
|
} log_Handler_file_ex_t;
|
||||||
|
|
||||||
|
static unsigned int getFileSize(FILE *fp) {
|
||||||
|
fseek(fp, 0L, SEEK_END);
|
||||||
|
return ftell(fp);
|
||||||
|
}
|
||||||
|
|
||||||
static void __freeFileHandler(log_Handler *handler) {
|
static void __freeFileHandler(log_Handler *handler) {
|
||||||
fclose(handler->stream);
|
fclose(handler->stream);
|
||||||
|
free(Handler_FILE_EX_PRT(handler)->file_name);
|
||||||
free(handler);
|
free(handler);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static void changeFile(log_Handler *handler) {
|
||||||
|
log_Handler_file_ex_t *handler_ex = Handler_FILE_EX_PRT(handler);
|
||||||
|
fclose(handler->stream);
|
||||||
|
char new_file_name[30];
|
||||||
|
sprintf(new_file_name, "%s_%d.log", handler_ex->file_name, ++handler_ex->suffix);
|
||||||
|
handler->stream = fopen(new_file_name, "at");
|
||||||
|
handler_ex->file_size = getFileSize(handler->stream);
|
||||||
|
}
|
||||||
|
|
||||||
static void outputFileHandler(log_Handler *handler, const char *message) {
|
static void outputFileHandler(log_Handler *handler, const char *message) {
|
||||||
fputs(message, handler->stream);
|
fputs(message, handler->stream);
|
||||||
|
log_Handler_file_ex_t *handler_ex = Handler_FILE_EX_PRT(handler);
|
||||||
|
handler_ex->file_size += strlen(message);
|
||||||
|
if (handler_ex->file_size > handler_ex->file_size_max)
|
||||||
|
changeFile(handler);
|
||||||
}
|
}
|
||||||
|
|
||||||
log_Handler *loggingFileHandler(const char *name) {
|
log_Handler *loggingFileHandler(const char *name, unsigned int max_size) {
|
||||||
char new_file_name[100];
|
char new_file_name[30];
|
||||||
sprintf(new_file_name, "%s.log", name);
|
int suffix = 0;
|
||||||
|
unsigned int file_size;
|
||||||
|
FILE *fp;
|
||||||
|
|
||||||
FILE *fp = fopen(new_file_name, "at");
|
do {
|
||||||
|
sprintf(new_file_name, "%s_%d.log", name, suffix++);
|
||||||
|
fp = fopen(new_file_name, "at");
|
||||||
|
file_size = getFileSize(fp);
|
||||||
|
} while (file_size > max_size);
|
||||||
|
|
||||||
log_Handler *handler = (log_Handler *)malloc(sizeof(log_Handler));
|
/// 分配log_Handler与记录文件大小的空间
|
||||||
|
log_Handler *handler = (log_Handler *)malloc(sizeof(log_Handler) +
|
||||||
|
sizeof(log_Handler_file_ex_t));
|
||||||
|
|
||||||
handler->stream = fp;
|
log_Handler_file_ex_t *handler_ex = Handler_FILE_EX_PRT(handler);
|
||||||
handler->apply_color = false;
|
handler_ex->file_size_max = max_size;
|
||||||
handler->_free = __freeFileHandler;
|
handler_ex->file_size = file_size;
|
||||||
handler->output = outputFileHandler;
|
handler_ex->suffix = suffix;
|
||||||
|
handler_ex->file_name = malloc(strlen(new_file_name) + 1);
|
||||||
|
strcpy(handler_ex->file_name, name);
|
||||||
|
|
||||||
|
handler->stream = fp;
|
||||||
|
handler->apply_color = false;
|
||||||
|
handler->_free = __freeFileHandler;
|
||||||
|
handler->output = outputFileHandler;
|
||||||
|
|
||||||
return handler;
|
return handler;
|
||||||
}
|
}
|
||||||
@@ -1,5 +1,6 @@
|
|||||||
#include "logging.h"
|
#include "logging.h"
|
||||||
#include "logging/logging-handler.h"
|
#include "logging/logging-handler.h"
|
||||||
|
#include "utils/logging-utils.h"
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
@@ -17,14 +18,10 @@
|
|||||||
|
|
||||||
Logger *G_LOGGER = NULL;
|
Logger *G_LOGGER = NULL;
|
||||||
|
|
||||||
static void getTimeStr(char *timeStr) {
|
/**
|
||||||
time_t t = time(NULL);
|
* @brief 为日志添加一个handler
|
||||||
struct tm *p = localtime(&t);
|
* @param handler 处理器对象
|
||||||
char _timeStr[20];
|
*/
|
||||||
strftime(_timeStr, sizeof(_timeStr), "%Y-%m-%d %H:%M:%S", p);
|
|
||||||
strcpy(timeStr, _timeStr);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void addHandler(log_Handler *handler) {
|
static void addHandler(log_Handler *handler) {
|
||||||
if (G_LOGGER == NULL) {
|
if (G_LOGGER == NULL) {
|
||||||
return;
|
return;
|
||||||
@@ -53,6 +50,14 @@ void addInterceptor(log_Interceptor *Interceptor) {
|
|||||||
G_LOGGER->interceptor = Interceptor;
|
G_LOGGER->interceptor = Interceptor;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 内部日志打印处理核心函数
|
||||||
|
* @param level 日志等级
|
||||||
|
* @param color 应用的颜色
|
||||||
|
* @param message 日志内容
|
||||||
|
* @param ... 格式化参数列表
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
static void
|
static void
|
||||||
_builtin_log(char *level, const char *color, const char *message, ...) {
|
_builtin_log(char *level, const char *color, const char *message, ...) {
|
||||||
if (G_LOGGER == NULL) {
|
if (G_LOGGER == NULL) {
|
||||||
@@ -77,7 +82,7 @@ _builtin_log(char *level, const char *color, const char *message, ...) {
|
|||||||
|
|
||||||
if (handler->apply_color)
|
if (handler->apply_color)
|
||||||
sprintf(logStr,
|
sprintf(logStr,
|
||||||
"%s: %s %s%s%s %s\n",
|
"[%s]: %s %s%s%s %s\n",
|
||||||
G_LOGGER->name,
|
G_LOGGER->name,
|
||||||
timeStr,
|
timeStr,
|
||||||
color,
|
color,
|
||||||
@@ -86,7 +91,7 @@ _builtin_log(char *level, const char *color, const char *message, ...) {
|
|||||||
message);
|
message);
|
||||||
else
|
else
|
||||||
sprintf(
|
sprintf(
|
||||||
logStr, "%s: %s %s %s\n", G_LOGGER->name, timeStr, level, message);
|
logStr, "[%s]: %s %s %s\n", G_LOGGER->name, timeStr, level, message);
|
||||||
|
|
||||||
handler->output(handler, logStr);
|
handler->output(handler, logStr);
|
||||||
}
|
}
|
||||||
|
|||||||
15
src/utils/logging-utils.c
Normal file
15
src/utils/logging-utils.c
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
#include "logging-utils.h"
|
||||||
|
#include <time.h>
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 获取当前时间字符串
|
||||||
|
* @param timeStr 存储时间字符串缓冲区指针
|
||||||
|
*/
|
||||||
|
void getTimeStr(char *timeStr) {
|
||||||
|
time_t t = time(NULL);
|
||||||
|
struct tm *p = localtime(&t);
|
||||||
|
char _timeStr[20];
|
||||||
|
strftime(_timeStr, sizeof(_timeStr), "%Y-%m-%d %H:%M:%S", p);
|
||||||
|
strcpy(timeStr, _timeStr);
|
||||||
|
}
|
||||||
5
src/utils/logging-utils.h
Normal file
5
src/utils/logging-utils.h
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
#ifndef __LOGGING_UTILS_H__
|
||||||
|
#define __LOGGING_UTILS_H__
|
||||||
|
|
||||||
|
void getTimeStr(char *timeStr);
|
||||||
|
#endif // __LOGGING_UTILS_H__
|
||||||
@@ -11,10 +11,13 @@ int main() {
|
|||||||
logger->debug("This is a debug message");
|
logger->debug("This is a debug message");
|
||||||
logger->warning("This is a warning message%s", "123");
|
logger->warning("This is a warning message%s", "123");
|
||||||
|
|
||||||
char *test1[] = {"123", "tt"};
|
char *test1[] = {"123", "tt"};
|
||||||
|
|
||||||
log_Interceptor *tint =
|
log_Interceptor *tint = loggingSubStringInterceptor(
|
||||||
loggingSubStringInterceptor(test1, 2, LOG_DEBUG, loggingFileHandler("test_interceptor"));
|
test1,
|
||||||
|
2,
|
||||||
|
LOG_DEBUG,
|
||||||
|
loggingFileHandler("test_interceptor", 1024 * 1024));
|
||||||
|
|
||||||
logger->addInterceptor(tint);
|
logger->addInterceptor(tint);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user