123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185 |
- /*
- * This file is part of the zlog Library.
- *
- * Copyright (C) 2011 by Hardy Simpson <HardySimpson1984@gmail.com>
- *
- * Licensed under the LGPL v2.1, see the file COPYING in base directory.
- */
- #include <pthread.h>
- #include <errno.h>
- #include "zc_defs.h"
- #include "event.h"
- #include "buf.h"
- #include "thread.h"
- #include "mdc.h"
- void zlog_thread_profile(zlog_thread_t * a_thread, int flag)
- {
- zc_assert(a_thread,);
- zc_profile(flag, "--thread[%p][%p][%p][%p,%p,%p,%p,%p]--",
- a_thread,
- a_thread->mdc,
- a_thread->event,
- a_thread->pre_path_buf,
- a_thread->path_buf,
- a_thread->archive_path_buf,
- a_thread->pre_msg_buf,
- a_thread->msg_buf);
- zlog_mdc_profile(a_thread->mdc, flag);
- zlog_event_profile(a_thread->event, flag);
- zlog_buf_profile(a_thread->pre_path_buf, flag);
- zlog_buf_profile(a_thread->path_buf, flag);
- zlog_buf_profile(a_thread->archive_path_buf, flag);
- zlog_buf_profile(a_thread->pre_msg_buf, flag);
- zlog_buf_profile(a_thread->msg_buf, flag);
- return;
- }
- /*******************************************************************************/
- void zlog_thread_del(zlog_thread_t * a_thread)
- {
- zc_assert(a_thread,);
- if (a_thread->mdc)
- zlog_mdc_del(a_thread->mdc);
- if (a_thread->event)
- zlog_event_del(a_thread->event);
- if (a_thread->pre_path_buf)
- zlog_buf_del(a_thread->pre_path_buf);
- if (a_thread->path_buf)
- zlog_buf_del(a_thread->path_buf);
- if (a_thread->archive_path_buf)
- zlog_buf_del(a_thread->archive_path_buf);
- if (a_thread->pre_msg_buf)
- zlog_buf_del(a_thread->pre_msg_buf);
- if (a_thread->msg_buf)
- zlog_buf_del(a_thread->msg_buf);
- zc_debug("zlog_thread_del[%p]", a_thread);
- free(a_thread);
- return;
- }
- zlog_thread_t *zlog_thread_new(int init_version, size_t buf_size_min, size_t buf_size_max, int time_cache_count)
- {
- zlog_thread_t *a_thread;
- a_thread = calloc(1, sizeof(zlog_thread_t));
- if (!a_thread) {
- zc_error("calloc fail, errno[%d]", errno);
- return NULL;
- }
- a_thread->init_version = init_version;
- a_thread->mdc = zlog_mdc_new();
- if (!a_thread->mdc) {
- zc_error("zlog_mdc_new fail");
- goto err;
- }
- a_thread->event = zlog_event_new(time_cache_count);
- if (!a_thread->event) {
- zc_error("zlog_event_new fail");
- goto err;
- }
- a_thread->pre_path_buf = zlog_buf_new(MAXLEN_PATH + 1, MAXLEN_PATH + 1, NULL);
- if (!a_thread->pre_path_buf) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- a_thread->path_buf = zlog_buf_new(MAXLEN_PATH + 1, MAXLEN_PATH + 1, NULL);
- if (!a_thread->path_buf) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- a_thread->archive_path_buf = zlog_buf_new(MAXLEN_PATH + 1, MAXLEN_PATH + 1, NULL);
- if (!a_thread->archive_path_buf) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- a_thread->pre_msg_buf = zlog_buf_new(buf_size_min, buf_size_max, "..." FILE_NEWLINE);
- if (!a_thread->pre_msg_buf) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- a_thread->msg_buf = zlog_buf_new(buf_size_min, buf_size_max, "..." FILE_NEWLINE);
- if (!a_thread->msg_buf) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- //zlog_thread_profile(a_thread, ZC_DEBUG);
- return a_thread;
- err:
- zlog_thread_del(a_thread);
- return NULL;
- }
- /*******************************************************************************/
- int zlog_thread_rebuild_msg_buf(zlog_thread_t * a_thread, size_t buf_size_min, size_t buf_size_max)
- {
- zlog_buf_t *pre_msg_buf_new = NULL;
- zlog_buf_t *msg_buf_new = NULL;
- zc_assert(a_thread, -1);
- if ( (a_thread->msg_buf->size_min == buf_size_min)
- && (a_thread->msg_buf->size_max == buf_size_max)) {
- zc_debug("buf size not changed, no need rebuild");
- return 0;
- }
- pre_msg_buf_new = zlog_buf_new(buf_size_min, buf_size_max, "..." FILE_NEWLINE);
- if (!pre_msg_buf_new) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- msg_buf_new = zlog_buf_new(buf_size_min, buf_size_max, "..." FILE_NEWLINE);
- if (!msg_buf_new) {
- zc_error("zlog_buf_new fail");
- goto err;
- }
- zlog_buf_del(a_thread->pre_msg_buf);
- a_thread->pre_msg_buf = pre_msg_buf_new;
- zlog_buf_del(a_thread->msg_buf);
- a_thread->msg_buf = msg_buf_new;
- return 0;
- err:
- if (pre_msg_buf_new) zlog_buf_del(pre_msg_buf_new);
- if (msg_buf_new) zlog_buf_del(msg_buf_new);
- return -1;
- }
- int zlog_thread_rebuild_event(zlog_thread_t * a_thread, int time_cache_count)
- {
- zlog_event_t *event_new = NULL;
- zc_assert(a_thread, -1);
- event_new = zlog_event_new(time_cache_count);
- if (!event_new) {
- zc_error("zlog_event_new fail");
- goto err;
- }
- zlog_event_del(a_thread->event);
- a_thread->event = event_new;
- return 0;
- err:
- if (event_new) zlog_event_del(event_new);
- return -1;
- }
- /*******************************************************************************/
|