1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
// balboa
// Copyright (c) 2018, 2019 DCSO GmbH
#include <inttypes.h>
#include <pthread.h>
#include <stdio.h>
#include <sys/time.h>
#include <time.h>
#include <trace.h>
// try to be https://tools.ietf.org/html/rfc5424 conform
static trace_t* theTrace = NULL;
void theTrace_set(trace_t* trace) {
theTrace = trace;
}
trace_t* theTrace_get(void) {
return (theTrace);
}
static void trace_lock(trace_t* trace) {
(void)trace;
pthread_mutex_lock(&trace->_lock);
}
static void trace_release(trace_t* trace) {
(void)trace;
// fflush(stdout);
pthread_mutex_unlock(&trace->_lock);
}
static void trace_output_rfc5424(
trace_t* trace, int priority, const char* fmt, va_list ap) {
time_t now;
time(&now);
struct tm tm;
localtime_r(&now, &tm);
char b[128];
size_t len = strftime(b, sizeof(b), "%FT%T%z", &tm);
fprintf(
trace->config.stream,
"<%d>1 %.*s %s %s %d - - ",
16 * 8 + priority,
(int)len,
b,
trace->config.host,
trace->config.app,
trace->config.procid);
vfprintf(trace->config.stream, fmt, ap);
}
static void trace_output_systemd(
trace_t* trace, int priority, const char* fmt, va_list ap) {
fprintf(trace->config.stream, "<%d> ", priority);
vfprintf(trace->config.stream, fmt, ap);
}
static void trace_inject(trace_t* trace, const char* fmt, va_list ap) {
vfprintf(trace->config.stream, fmt, ap);
}
static void trace_flush(trace_t* trace) {
(void)trace;
fflush(stdout);
}
static void trace_init(trace_t* trace, const trace_config_t* config) {
trace->config = *config;
atomic_store(&trace->verbosity, config->verbosity);
if(config->rfc5424) { trace->output = trace_output_rfc5424; }
pthread_mutex_init(&trace->_lock, NULL);
}
static trace_t __theTrace_stdout = {.verbosity = ATOMIC_VAR_INIT(0),
.config = {0},
.release = trace_release,
.init = trace_init,
.lock = trace_lock,
.output = trace_output_systemd,
.inject = trace_inject,
.flush = trace_flush};
static trace_t* const theTrace_stdout = &__theTrace_stdout;
void theTrace_stream_use(const trace_config_t* config) {
theTrace_set(theTrace_stdout);
theTrace_init(config);
}
|
