Line data Source code
1 : /* SPDX-License-Identifier: BSD-3-Clause
2 : * Copyright (C) 2016 Intel Corporation.
3 : * All rights reserved.
4 : */
5 :
6 : #include "spdk/stdinc.h"
7 : #include "spdk/util.h"
8 :
9 : #include "spdk/log.h"
10 :
11 : static const char *const spdk_level_names[] = {
12 : [SPDK_LOG_ERROR] = "ERROR",
13 : [SPDK_LOG_WARN] = "WARNING",
14 : [SPDK_LOG_NOTICE] = "NOTICE",
15 : [SPDK_LOG_INFO] = "INFO",
16 : [SPDK_LOG_DEBUG] = "DEBUG",
17 : };
18 :
19 : #define MAX_TMPBUF 1024
20 :
21 : static struct spdk_log_opts g_log_opts = {
22 : .log = NULL,
23 : .open = NULL,
24 : .close = NULL,
25 : .user_ctx = NULL,
26 : };
27 : static bool g_log_timestamps = true;
28 :
29 : enum spdk_log_level g_spdk_log_level;
30 : enum spdk_log_level g_spdk_log_print_level;
31 :
32 : void
33 5 : spdk_log_set_level(enum spdk_log_level level)
34 : {
35 5 : assert(level >= SPDK_LOG_DISABLED);
36 5 : assert(level <= SPDK_LOG_DEBUG);
37 5 : g_spdk_log_level = level;
38 5 : }
39 :
40 : enum spdk_log_level
41 5 : spdk_log_get_level(void) {
42 5 : return g_spdk_log_level;
43 : }
44 :
45 : void
46 5 : spdk_log_set_print_level(enum spdk_log_level level)
47 : {
48 5 : assert(level >= SPDK_LOG_DISABLED);
49 5 : assert(level <= SPDK_LOG_DEBUG);
50 5 : g_spdk_log_print_level = level;
51 5 : }
52 :
53 : enum spdk_log_level
54 5 : spdk_log_get_print_level(void) {
55 5 : return g_spdk_log_print_level;
56 : }
57 :
58 : static void
59 1 : log_open(void *ctx)
60 : {
61 1 : openlog("spdk", LOG_PID, LOG_LOCAL7);
62 1 : }
63 :
64 : static void
65 1 : log_close(void *ctx)
66 : {
67 1 : closelog();
68 1 : }
69 :
70 : void
71 2 : spdk_log_open(spdk_log_cb *log)
72 : {
73 2 : if (log) {
74 1 : struct spdk_log_opts opts = {.log = log};
75 1 : opts.size = SPDK_SIZEOF(&opts, log);
76 1 : spdk_log_open_ext(&opts);
77 1 : } else {
78 1 : spdk_log_open_ext(NULL);
79 : }
80 2 : }
81 :
82 : void
83 3 : spdk_log_open_ext(struct spdk_log_opts *opts)
84 : {
85 3 : if (!opts) {
86 1 : g_log_opts.open = log_open;
87 1 : g_log_opts.close = log_close;
88 1 : goto out;
89 : }
90 :
91 2 : g_log_opts.log = SPDK_GET_FIELD(opts, log, NULL);
92 2 : g_log_opts.open = SPDK_GET_FIELD(opts, open, NULL);
93 2 : g_log_opts.close = SPDK_GET_FIELD(opts, close, NULL);
94 2 : g_log_opts.user_ctx = SPDK_GET_FIELD(opts, user_ctx, NULL);
95 :
96 : out:
97 3 : if (g_log_opts.open) {
98 2 : g_log_opts.open(g_log_opts.user_ctx);
99 2 : }
100 3 : }
101 :
102 : void
103 3 : spdk_log_close(void)
104 : {
105 3 : if (g_log_opts.close) {
106 2 : g_log_opts.close(g_log_opts.user_ctx);
107 2 : }
108 3 : memset(&g_log_opts, 0, sizeof(g_log_opts));
109 3 : }
110 :
111 : void
112 0 : spdk_log_enable_timestamps(bool value)
113 : {
114 0 : g_log_timestamps = value;
115 0 : }
116 :
117 : static void
118 1339 : get_timestamp_prefix(char *buf, int buf_size)
119 : {
120 : struct tm *info;
121 : char date[24];
122 : struct timespec ts;
123 : long usec;
124 :
125 1339 : if (!g_log_timestamps) {
126 0 : buf[0] = '\0';
127 0 : return;
128 : }
129 :
130 1339 : clock_gettime(CLOCK_REALTIME, &ts);
131 1339 : info = localtime(&ts.tv_sec);
132 1339 : usec = ts.tv_nsec / 1000;
133 1339 : if (info == NULL) {
134 0 : snprintf(buf, buf_size, "[%s.%06ld] ", "unknown date", usec);
135 0 : return;
136 : }
137 :
138 1339 : strftime(date, sizeof(date), "%Y-%m-%d %H:%M:%S", info);
139 1339 : snprintf(buf, buf_size, "[%s.%06ld] ", date, usec);
140 1339 : }
141 :
142 : void
143 2465 : spdk_log(enum spdk_log_level level, const char *file, const int line, const char *func,
144 : const char *format, ...)
145 : {
146 : va_list ap;
147 :
148 2465 : va_start(ap, format);
149 2465 : spdk_vlog(level, file, line, func, format, ap);
150 2465 : va_end(ap);
151 2465 : }
152 :
153 : int
154 1339 : spdk_log_to_syslog_level(enum spdk_log_level level)
155 : {
156 1339 : switch (level) {
157 : case SPDK_LOG_DEBUG:
158 : case SPDK_LOG_INFO:
159 1 : return LOG_INFO;
160 : case SPDK_LOG_NOTICE:
161 0 : return LOG_NOTICE;
162 : case SPDK_LOG_WARN:
163 1 : return LOG_WARNING;
164 : case SPDK_LOG_ERROR:
165 1337 : return LOG_ERR;
166 : case SPDK_LOG_DISABLED:
167 0 : return -1;
168 : default:
169 0 : break;
170 : }
171 :
172 0 : return LOG_INFO;
173 1339 : }
174 :
175 : void
176 2465 : spdk_vlog(enum spdk_log_level level, const char *file, const int line, const char *func,
177 : const char *format, va_list ap)
178 : {
179 2465 : int severity = LOG_INFO;
180 2465 : char *buf, _buf[MAX_TMPBUF], *ext_buf = NULL;
181 : char timestamp[64];
182 : va_list ap_copy;
183 : int rc;
184 :
185 2465 : if (g_log_opts.log) {
186 6 : g_log_opts.log(level, file, line, func, format, ap);
187 6 : return;
188 : }
189 :
190 2459 : if (level > g_spdk_log_print_level && level > g_spdk_log_level) {
191 1120 : return;
192 : }
193 :
194 1339 : severity = spdk_log_to_syslog_level(level);
195 1339 : if (severity < 0) {
196 0 : return;
197 : }
198 :
199 1339 : buf = _buf;
200 :
201 1339 : va_copy(ap_copy, ap);
202 1339 : rc = vsnprintf(_buf, sizeof(_buf), format, ap);
203 1339 : if (rc > MAX_TMPBUF) {
204 : /* The output including the terminating was more than MAX_TMPBUF bytes.
205 : * Try allocating memory large enough to hold the output.
206 : */
207 0 : rc = vasprintf(&ext_buf, format, ap_copy);
208 0 : if (rc < 0) {
209 : /* Failed to allocate memory. Allow output to be truncated. */
210 0 : } else {
211 0 : buf = ext_buf;
212 : }
213 0 : }
214 1339 : va_end(ap_copy);
215 :
216 1339 : if (level <= g_spdk_log_print_level) {
217 1339 : get_timestamp_prefix(timestamp, sizeof(timestamp));
218 1339 : if (file) {
219 1339 : fprintf(stderr, "%s%s:%4d:%s: *%s*: %s", timestamp, file, line, func, spdk_level_names[level], buf);
220 1339 : } else {
221 0 : fprintf(stderr, "%s%s", timestamp, buf);
222 : }
223 1339 : }
224 :
225 1339 : if (level <= g_spdk_log_level) {
226 1339 : if (file) {
227 1339 : syslog(severity, "%s:%4d:%s: *%s*: %s", file, line, func, spdk_level_names[level], buf);
228 1339 : } else {
229 0 : syslog(severity, "%s", buf);
230 : }
231 1339 : }
232 :
233 1339 : free(ext_buf);
234 2465 : }
235 :
236 : void
237 0 : spdk_vflog(FILE *fp, const char *file, const int line, const char *func,
238 : const char *format, va_list ap)
239 : {
240 : char buf[MAX_TMPBUF];
241 : char timestamp[64];
242 :
243 0 : vsnprintf(buf, sizeof(buf), format, ap);
244 :
245 0 : get_timestamp_prefix(timestamp, sizeof(timestamp));
246 :
247 0 : if (file) {
248 0 : fprintf(fp, "%s%s:%4d:%s: %s", timestamp, file, line, func, buf);
249 0 : } else {
250 0 : fprintf(fp, "%s%s", timestamp, buf);
251 : }
252 :
253 0 : fflush(fp);
254 0 : }
255 :
256 : void
257 0 : spdk_flog(FILE *fp, const char *file, const int line, const char *func,
258 : const char *format, ...)
259 : {
260 : va_list ap;
261 :
262 0 : va_start(ap, format);
263 0 : spdk_vflog(fp, file, line, func, format, ap);
264 0 : va_end(ap);
265 0 : }
266 :
267 : static void
268 3 : fdump(FILE *fp, const char *label, const uint8_t *buf, size_t len)
269 : {
270 : char tmpbuf[MAX_TMPBUF];
271 : char buf16[16 + 1];
272 : size_t total;
273 : unsigned int idx;
274 :
275 3 : fprintf(fp, "%s\n", label);
276 :
277 3 : memset(buf16, 0, sizeof buf16);
278 3 : total = 0;
279 43 : for (idx = 0; idx < len; idx++) {
280 40 : if (idx != 0 && idx % 16 == 0) {
281 2 : snprintf(tmpbuf + total, sizeof tmpbuf - total,
282 1 : " %s", buf16);
283 1 : memset(buf16, 0, sizeof buf16);
284 1 : fprintf(fp, "%s\n", tmpbuf);
285 1 : total = 0;
286 1 : }
287 40 : if (idx % 16 == 0) {
288 8 : total += snprintf(tmpbuf + total, sizeof tmpbuf - total,
289 4 : "%08x ", idx);
290 4 : }
291 40 : if (idx % 8 == 0) {
292 6 : total += snprintf(tmpbuf + total, sizeof tmpbuf - total,
293 : "%s", " ");
294 6 : }
295 80 : total += snprintf(tmpbuf + total, sizeof tmpbuf - total,
296 40 : "%2.2x ", buf[idx] & 0xff);
297 40 : buf16[idx % 16] = isprint(buf[idx]) ? buf[idx] : '.';
298 40 : }
299 27 : for (; idx % 16 != 0; idx++) {
300 24 : if (idx == 8) {
301 1 : total += snprintf(tmpbuf + total, sizeof tmpbuf - total,
302 : " ");
303 1 : }
304 :
305 24 : total += snprintf(tmpbuf + total, sizeof tmpbuf - total, " ");
306 24 : }
307 3 : snprintf(tmpbuf + total, sizeof tmpbuf - total, " %s", buf16);
308 3 : fprintf(fp, "%s\n", tmpbuf);
309 3 : fflush(fp);
310 3 : }
311 :
312 : void
313 3 : spdk_log_dump(FILE *fp, const char *label, const void *buf, size_t len)
314 : {
315 3 : fdump(fp, label, buf, len);
316 3 : }
|
