log.c revision 1.3 1 1.2 christos /* $NetBSD: log.c,v 1.3 2019/01/09 16:55:14 christos Exp $ */
2 1.1 christos
3 1.1 christos /*
4 1.1 christos * Copyright (C) Internet Systems Consortium, Inc. ("ISC")
5 1.1 christos *
6 1.1 christos * This Source Code Form is subject to the terms of the Mozilla Public
7 1.1 christos * License, v. 2.0. If a copy of the MPL was not distributed with this
8 1.1 christos * file, You can obtain one at http://mozilla.org/MPL/2.0/.
9 1.1 christos *
10 1.1 christos * See the COPYRIGHT file distributed with this work for additional
11 1.1 christos * information regarding copyright ownership.
12 1.1 christos */
13 1.1 christos
14 1.1 christos /*! \file */
15 1.1 christos
16 1.1 christos #include <config.h>
17 1.1 christos
18 1.1 christos #include <errno.h>
19 1.3 christos #include <inttypes.h>
20 1.3 christos #include <stdbool.h>
21 1.1 christos #include <stdlib.h>
22 1.1 christos #include <limits.h>
23 1.1 christos #include <time.h>
24 1.1 christos
25 1.1 christos #include <sys/types.h> /* dev_t FreeBSD 2.1 */
26 1.1 christos
27 1.1 christos #include <isc/dir.h>
28 1.1 christos #include <isc/file.h>
29 1.1 christos #include <isc/log.h>
30 1.1 christos #include <isc/magic.h>
31 1.1 christos #include <isc/mem.h>
32 1.1 christos #include <isc/msgs.h>
33 1.1 christos #include <isc/print.h>
34 1.1 christos #include <isc/stat.h>
35 1.1 christos #include <isc/stdio.h>
36 1.1 christos #include <isc/string.h>
37 1.1 christos #include <isc/time.h>
38 1.1 christos #include <isc/util.h>
39 1.1 christos
40 1.1 christos #define LCTX_MAGIC ISC_MAGIC('L', 'c', 't', 'x')
41 1.1 christos #define VALID_CONTEXT(lctx) ISC_MAGIC_VALID(lctx, LCTX_MAGIC)
42 1.1 christos
43 1.1 christos #define LCFG_MAGIC ISC_MAGIC('L', 'c', 'f', 'g')
44 1.1 christos #define VALID_CONFIG(lcfg) ISC_MAGIC_VALID(lcfg, LCFG_MAGIC)
45 1.1 christos
46 1.1 christos /*
47 1.1 christos * XXXDCL make dynamic?
48 1.1 christos */
49 1.1 christos #define LOG_BUFFER_SIZE (8 * 1024)
50 1.1 christos
51 1.1 christos #ifndef PATH_MAX
52 1.3 christos #define PATH_MAX 1024 /* WIN32 and others don't define this. */
53 1.1 christos #endif
54 1.1 christos
55 1.1 christos /*!
56 1.1 christos * This is the structure that holds each named channel. A simple linked
57 1.1 christos * list chains all of the channels together, so an individual channel is
58 1.1 christos * found by doing strcmp()s with the names down the list. Their should
59 1.1 christos * be no performance penalty from this as it is expected that the number
60 1.1 christos * of named channels will be no more than a dozen or so, and name lookups
61 1.1 christos * from the head of the list are only done when isc_log_usechannel() is
62 1.1 christos * called, which should also be very infrequent.
63 1.1 christos */
64 1.1 christos typedef struct isc_logchannel isc_logchannel_t;
65 1.1 christos
66 1.1 christos struct isc_logchannel {
67 1.1 christos char * name;
68 1.1 christos unsigned int type;
69 1.1 christos int level;
70 1.1 christos unsigned int flags;
71 1.1 christos isc_logdestination_t destination;
72 1.1 christos ISC_LINK(isc_logchannel_t) link;
73 1.1 christos };
74 1.1 christos
75 1.1 christos /*!
76 1.1 christos * The logchannellist structure associates categories and modules with
77 1.1 christos * channels. First the appropriate channellist is found based on the
78 1.1 christos * category, and then each structure in the linked list is checked for
79 1.1 christos * a matching module. It is expected that the number of channels
80 1.1 christos * associated with any given category will be very short, no more than
81 1.1 christos * three or four in the more unusual cases.
82 1.1 christos */
83 1.1 christos typedef struct isc_logchannellist isc_logchannellist_t;
84 1.1 christos
85 1.1 christos struct isc_logchannellist {
86 1.1 christos const isc_logmodule_t * module;
87 1.1 christos isc_logchannel_t * channel;
88 1.1 christos ISC_LINK(isc_logchannellist_t) link;
89 1.1 christos };
90 1.1 christos
91 1.1 christos /*!
92 1.1 christos * This structure is used to remember messages for pruning via
93 1.1 christos * isc_log_[v]write1().
94 1.1 christos */
95 1.1 christos typedef struct isc_logmessage isc_logmessage_t;
96 1.1 christos
97 1.1 christos struct isc_logmessage {
98 1.1 christos char * text;
99 1.1 christos isc_time_t time;
100 1.1 christos ISC_LINK(isc_logmessage_t) link;
101 1.1 christos };
102 1.1 christos
103 1.1 christos /*!
104 1.1 christos * The isc_logconfig structure is used to store the configurable information
105 1.1 christos * about where messages are actually supposed to be sent -- the information
106 1.1 christos * that could changed based on some configuration file, as opposed to the
107 1.1 christos * the category/module specification of isc_log_[v]write[1] that is compiled
108 1.1 christos * into a program, or the debug_level which is dynamic state information.
109 1.1 christos */
110 1.1 christos struct isc_logconfig {
111 1.1 christos unsigned int magic;
112 1.1 christos isc_log_t * lctx;
113 1.1 christos ISC_LIST(isc_logchannel_t) channels;
114 1.1 christos ISC_LIST(isc_logchannellist_t) *channellists;
115 1.1 christos unsigned int channellist_count;
116 1.1 christos unsigned int duplicate_interval;
117 1.1 christos int highest_level;
118 1.1 christos char * tag;
119 1.3 christos bool dynamic;
120 1.1 christos };
121 1.1 christos
122 1.1 christos /*!
123 1.1 christos * This isc_log structure provides the context for the isc_log functions.
124 1.1 christos * The log context locks itself in isc_log_doit, the internal backend to
125 1.1 christos * isc_log_write. The locking is necessary both to provide exclusive access
126 1.1 christos * to the buffer into which the message is formatted and to guard against
127 1.1 christos * competing threads trying to write to the same syslog resource. (On
128 1.1 christos * some systems, such as BSD/OS, stdio is thread safe but syslog is not.)
129 1.1 christos * Unfortunately, the lock cannot guard against a _different_ logging
130 1.1 christos * context in the same program competing for syslog's attention. Thus
131 1.1 christos * There Can Be Only One, but this is not enforced.
132 1.1 christos * XXXDCL enforce it?
133 1.1 christos *
134 1.1 christos * Note that the category and module information is not locked.
135 1.1 christos * This is because in the usual case, only one isc_log_t is ever created
136 1.1 christos * in a program, and the category/module registration happens only once.
137 1.1 christos * XXXDCL it might be wise to add more locking overall.
138 1.1 christos */
139 1.1 christos struct isc_log {
140 1.1 christos /* Not locked. */
141 1.1 christos unsigned int magic;
142 1.1 christos isc_mem_t * mctx;
143 1.1 christos isc_logcategory_t * categories;
144 1.1 christos unsigned int category_count;
145 1.1 christos isc_logmodule_t * modules;
146 1.1 christos unsigned int module_count;
147 1.1 christos int debug_level;
148 1.1 christos isc_mutex_t lock;
149 1.1 christos /* Locked by isc_log lock. */
150 1.1 christos isc_logconfig_t * logconfig;
151 1.1 christos char buffer[LOG_BUFFER_SIZE];
152 1.1 christos ISC_LIST(isc_logmessage_t) messages;
153 1.1 christos };
154 1.1 christos
155 1.1 christos /*!
156 1.1 christos * Used when ISC_LOG_PRINTLEVEL is enabled for a channel.
157 1.1 christos */
158 1.1 christos static const char *log_level_strings[] = {
159 1.1 christos "debug",
160 1.1 christos "info",
161 1.1 christos "notice",
162 1.1 christos "warning",
163 1.1 christos "error",
164 1.1 christos "critical"
165 1.1 christos };
166 1.1 christos
167 1.1 christos /*!
168 1.1 christos * Used to convert ISC_LOG_* priorities into syslog priorities.
169 1.1 christos * XXXDCL This will need modification for NT.
170 1.1 christos */
171 1.1 christos static const int syslog_map[] = {
172 1.1 christos LOG_DEBUG,
173 1.1 christos LOG_INFO,
174 1.1 christos LOG_NOTICE,
175 1.1 christos LOG_WARNING,
176 1.1 christos LOG_ERR,
177 1.1 christos LOG_CRIT
178 1.1 christos };
179 1.1 christos
180 1.1 christos /*!
181 1.1 christos * When adding new categories, a corresponding ISC_LOGCATEGORY_foo
182 1.1 christos * definition needs to be added to <isc/log.h>.
183 1.1 christos *
184 1.1 christos * The default category is provided so that the internal default can
185 1.1 christos * be overridden. Since the default is always looked up as the first
186 1.1 christos * channellist in the log context, it must come first in isc_categories[].
187 1.1 christos */
188 1.1 christos LIBISC_EXTERNAL_DATA isc_logcategory_t isc_categories[] = {
189 1.1 christos { "default", 0 }, /* "default" must come first. */
190 1.1 christos { "general", 0 },
191 1.1 christos { NULL, 0 }
192 1.1 christos };
193 1.1 christos
194 1.1 christos /*!
195 1.1 christos * See above comment for categories on LIBISC_EXTERNAL_DATA, and apply it to modules.
196 1.1 christos */
197 1.1 christos LIBISC_EXTERNAL_DATA isc_logmodule_t isc_modules[] = {
198 1.1 christos { "socket", 0 },
199 1.1 christos { "time", 0 },
200 1.1 christos { "interface", 0 },
201 1.1 christos { "timer", 0 },
202 1.1 christos { "file", 0 },
203 1.1 christos { "other", 0 },
204 1.1 christos { NULL, 0 }
205 1.1 christos };
206 1.1 christos
207 1.1 christos /*!
208 1.1 christos * This essentially constant structure must be filled in at run time,
209 1.1 christos * because its channel member is pointed to a channel that is created
210 1.1 christos * dynamically with isc_log_createchannel.
211 1.1 christos */
212 1.1 christos static isc_logchannellist_t default_channel;
213 1.1 christos
214 1.1 christos /*!
215 1.1 christos * libisc logs to this context.
216 1.1 christos */
217 1.1 christos LIBISC_EXTERNAL_DATA isc_log_t *isc_lctx = NULL;
218 1.1 christos
219 1.1 christos /*!
220 1.1 christos * Forward declarations.
221 1.1 christos */
222 1.1 christos static isc_result_t
223 1.1 christos assignchannel(isc_logconfig_t *lcfg, unsigned int category_id,
224 1.1 christos const isc_logmodule_t *module, isc_logchannel_t *channel);
225 1.1 christos
226 1.1 christos static isc_result_t
227 1.1 christos sync_channellist(isc_logconfig_t *lcfg);
228 1.1 christos
229 1.1 christos static isc_result_t
230 1.1 christos greatest_version(isc_logfile_t *file, int versions, int *greatest);
231 1.1 christos
232 1.1 christos static void
233 1.1 christos isc_log_doit(isc_log_t *lctx, isc_logcategory_t *category,
234 1.3 christos isc_logmodule_t *module, int level, bool write_once,
235 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
236 1.1 christos const char *format, va_list args)
237 1.1 christos ISC_FORMAT_PRINTF(9, 0);
238 1.1 christos
239 1.1 christos /*@{*/
240 1.1 christos /*!
241 1.1 christos * Convenience macros.
242 1.1 christos */
243 1.1 christos
244 1.1 christos #define FACILITY(channel) (channel->destination.facility)
245 1.1 christos #define FILE_NAME(channel) (channel->destination.file.name)
246 1.1 christos #define FILE_STREAM(channel) (channel->destination.file.stream)
247 1.1 christos #define FILE_VERSIONS(channel) (channel->destination.file.versions)
248 1.1 christos #define FILE_SUFFIX(channel) (channel->destination.file.suffix)
249 1.1 christos #define FILE_MAXSIZE(channel) (channel->destination.file.maximum_size)
250 1.1 christos #define FILE_MAXREACHED(channel) (channel->destination.file.maximum_reached)
251 1.1 christos
252 1.1 christos /*@}*/
253 1.1 christos /****
254 1.1 christos **** Public interfaces.
255 1.1 christos ****/
256 1.1 christos
257 1.1 christos /*
258 1.1 christos * Establish a new logging context, with default channels.
259 1.1 christos */
260 1.1 christos isc_result_t
261 1.1 christos isc_log_create(isc_mem_t *mctx, isc_log_t **lctxp, isc_logconfig_t **lcfgp) {
262 1.1 christos isc_log_t *lctx;
263 1.1 christos isc_logconfig_t *lcfg = NULL;
264 1.1 christos isc_result_t result;
265 1.1 christos
266 1.1 christos REQUIRE(mctx != NULL);
267 1.1 christos REQUIRE(lctxp != NULL && *lctxp == NULL);
268 1.1 christos REQUIRE(lcfgp == NULL || *lcfgp == NULL);
269 1.1 christos
270 1.1 christos lctx = isc_mem_get(mctx, sizeof(*lctx));
271 1.1 christos if (lctx != NULL) {
272 1.1 christos lctx->mctx = NULL;
273 1.1 christos isc_mem_attach(mctx, &lctx->mctx);
274 1.1 christos lctx->categories = NULL;
275 1.1 christos lctx->category_count = 0;
276 1.1 christos lctx->modules = NULL;
277 1.1 christos lctx->module_count = 0;
278 1.1 christos lctx->debug_level = 0;
279 1.1 christos
280 1.1 christos ISC_LIST_INIT(lctx->messages);
281 1.1 christos
282 1.3 christos isc_mutex_init(&lctx->lock);
283 1.1 christos
284 1.1 christos /*
285 1.1 christos * Normally setting the magic number is the last step done
286 1.1 christos * in a creation function, but a valid log context is needed
287 1.1 christos * by isc_log_registercategories and isc_logconfig_create.
288 1.1 christos * If either fails, the lctx is destroyed and not returned
289 1.1 christos * to the caller.
290 1.1 christos */
291 1.1 christos lctx->magic = LCTX_MAGIC;
292 1.1 christos
293 1.1 christos isc_log_registercategories(lctx, isc_categories);
294 1.1 christos isc_log_registermodules(lctx, isc_modules);
295 1.1 christos result = isc_logconfig_create(lctx, &lcfg);
296 1.1 christos
297 1.1 christos } else
298 1.1 christos result = ISC_R_NOMEMORY;
299 1.1 christos
300 1.1 christos if (result == ISC_R_SUCCESS)
301 1.1 christos result = sync_channellist(lcfg);
302 1.1 christos
303 1.1 christos if (result == ISC_R_SUCCESS) {
304 1.1 christos lctx->logconfig = lcfg;
305 1.1 christos
306 1.1 christos *lctxp = lctx;
307 1.1 christos if (lcfgp != NULL)
308 1.1 christos *lcfgp = lcfg;
309 1.1 christos
310 1.1 christos } else {
311 1.1 christos if (lcfg != NULL)
312 1.1 christos isc_logconfig_destroy(&lcfg);
313 1.1 christos if (lctx != NULL)
314 1.1 christos isc_log_destroy(&lctx);
315 1.1 christos }
316 1.1 christos
317 1.1 christos return (result);
318 1.1 christos }
319 1.1 christos
320 1.1 christos isc_result_t
321 1.1 christos isc_logconfig_create(isc_log_t *lctx, isc_logconfig_t **lcfgp) {
322 1.1 christos isc_logconfig_t *lcfg;
323 1.1 christos isc_logdestination_t destination;
324 1.1 christos isc_result_t result = ISC_R_SUCCESS;
325 1.1 christos int level = ISC_LOG_INFO;
326 1.1 christos
327 1.1 christos REQUIRE(lcfgp != NULL && *lcfgp == NULL);
328 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
329 1.1 christos
330 1.1 christos lcfg = isc_mem_get(lctx->mctx, sizeof(*lcfg));
331 1.1 christos
332 1.1 christos if (lcfg != NULL) {
333 1.1 christos lcfg->lctx = lctx;
334 1.1 christos lcfg->channellists = NULL;
335 1.1 christos lcfg->channellist_count = 0;
336 1.1 christos lcfg->duplicate_interval = 0;
337 1.1 christos lcfg->highest_level = level;
338 1.1 christos lcfg->tag = NULL;
339 1.3 christos lcfg->dynamic = false;
340 1.1 christos
341 1.1 christos ISC_LIST_INIT(lcfg->channels);
342 1.1 christos
343 1.1 christos /*
344 1.1 christos * Normally the magic number is the last thing set in the
345 1.1 christos * structure, but isc_log_createchannel() needs a valid
346 1.1 christos * config. If the channel creation fails, the lcfg is not
347 1.1 christos * returned to the caller.
348 1.1 christos */
349 1.1 christos lcfg->magic = LCFG_MAGIC;
350 1.1 christos
351 1.1 christos } else
352 1.1 christos result = ISC_R_NOMEMORY;
353 1.1 christos
354 1.1 christos /*
355 1.1 christos * Create the default channels:
356 1.1 christos * default_syslog, default_stderr, default_debug and null.
357 1.1 christos */
358 1.1 christos if (result == ISC_R_SUCCESS) {
359 1.1 christos destination.facility = LOG_DAEMON;
360 1.1 christos result = isc_log_createchannel(lcfg, "default_syslog",
361 1.1 christos ISC_LOG_TOSYSLOG, level,
362 1.1 christos &destination, 0);
363 1.1 christos }
364 1.1 christos
365 1.1 christos if (result == ISC_R_SUCCESS) {
366 1.1 christos destination.file.stream = stderr;
367 1.1 christos destination.file.name = NULL;
368 1.1 christos destination.file.versions = ISC_LOG_ROLLNEVER;
369 1.1 christos destination.file.suffix = isc_log_rollsuffix_increment;
370 1.1 christos destination.file.maximum_size = 0;
371 1.1 christos result = isc_log_createchannel(lcfg, "default_stderr",
372 1.1 christos ISC_LOG_TOFILEDESC,
373 1.1 christos level,
374 1.1 christos &destination,
375 1.1 christos ISC_LOG_PRINTTIME);
376 1.1 christos }
377 1.1 christos
378 1.1 christos if (result == ISC_R_SUCCESS) {
379 1.1 christos /*
380 1.1 christos * Set the default category's channel to default_stderr,
381 1.1 christos * which is at the head of the channels list because it was
382 1.1 christos * just created.
383 1.1 christos */
384 1.1 christos default_channel.channel = ISC_LIST_HEAD(lcfg->channels);
385 1.1 christos
386 1.1 christos destination.file.stream = stderr;
387 1.1 christos destination.file.name = NULL;
388 1.1 christos destination.file.versions = ISC_LOG_ROLLNEVER;
389 1.1 christos destination.file.suffix = isc_log_rollsuffix_increment;
390 1.1 christos destination.file.maximum_size = 0;
391 1.1 christos result = isc_log_createchannel(lcfg, "default_debug",
392 1.1 christos ISC_LOG_TOFILEDESC,
393 1.1 christos ISC_LOG_DYNAMIC,
394 1.1 christos &destination,
395 1.1 christos ISC_LOG_PRINTTIME);
396 1.1 christos }
397 1.1 christos
398 1.1 christos if (result == ISC_R_SUCCESS)
399 1.1 christos result = isc_log_createchannel(lcfg, "null",
400 1.1 christos ISC_LOG_TONULL,
401 1.1 christos ISC_LOG_DYNAMIC,
402 1.1 christos NULL, 0);
403 1.1 christos
404 1.1 christos if (result == ISC_R_SUCCESS)
405 1.1 christos *lcfgp = lcfg;
406 1.1 christos
407 1.1 christos else
408 1.1 christos if (lcfg != NULL)
409 1.1 christos isc_logconfig_destroy(&lcfg);
410 1.1 christos
411 1.1 christos return (result);
412 1.1 christos }
413 1.1 christos
414 1.1 christos isc_logconfig_t *
415 1.1 christos isc_logconfig_get(isc_log_t *lctx) {
416 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
417 1.1 christos
418 1.1 christos ENSURE(lctx->logconfig != NULL);
419 1.1 christos
420 1.1 christos return (lctx->logconfig);
421 1.1 christos }
422 1.1 christos
423 1.1 christos isc_result_t
424 1.1 christos isc_logconfig_use(isc_log_t *lctx, isc_logconfig_t *lcfg) {
425 1.1 christos isc_logconfig_t *old_cfg;
426 1.1 christos isc_result_t result;
427 1.1 christos
428 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
429 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
430 1.1 christos REQUIRE(lcfg->lctx == lctx);
431 1.1 christos
432 1.1 christos /*
433 1.1 christos * Ensure that lcfg->channellist_count == lctx->category_count.
434 1.1 christos * They won't be equal if isc_log_usechannel has not been called
435 1.1 christos * since any call to isc_log_registercategories.
436 1.1 christos */
437 1.1 christos result = sync_channellist(lcfg);
438 1.1 christos if (result != ISC_R_SUCCESS)
439 1.1 christos return (result);
440 1.1 christos
441 1.1 christos LOCK(&lctx->lock);
442 1.1 christos
443 1.1 christos old_cfg = lctx->logconfig;
444 1.1 christos lctx->logconfig = lcfg;
445 1.1 christos
446 1.1 christos UNLOCK(&lctx->lock);
447 1.1 christos
448 1.1 christos isc_logconfig_destroy(&old_cfg);
449 1.1 christos
450 1.1 christos return (ISC_R_SUCCESS);
451 1.1 christos }
452 1.1 christos
453 1.1 christos void
454 1.1 christos isc_log_destroy(isc_log_t **lctxp) {
455 1.1 christos isc_log_t *lctx;
456 1.1 christos isc_logconfig_t *lcfg;
457 1.1 christos isc_mem_t *mctx;
458 1.1 christos isc_logmessage_t *message;
459 1.1 christos
460 1.1 christos REQUIRE(lctxp != NULL && VALID_CONTEXT(*lctxp));
461 1.1 christos
462 1.1 christos lctx = *lctxp;
463 1.1 christos mctx = lctx->mctx;
464 1.1 christos
465 1.1 christos if (lctx->logconfig != NULL) {
466 1.1 christos lcfg = lctx->logconfig;
467 1.1 christos lctx->logconfig = NULL;
468 1.1 christos isc_logconfig_destroy(&lcfg);
469 1.1 christos }
470 1.1 christos
471 1.3 christos isc_mutex_destroy(&lctx->lock);
472 1.1 christos
473 1.1 christos while ((message = ISC_LIST_HEAD(lctx->messages)) != NULL) {
474 1.1 christos ISC_LIST_UNLINK(lctx->messages, message, link);
475 1.1 christos
476 1.1 christos isc_mem_put(mctx, message,
477 1.1 christos sizeof(*message) + strlen(message->text) + 1);
478 1.1 christos }
479 1.1 christos
480 1.1 christos lctx->buffer[0] = '\0';
481 1.1 christos lctx->debug_level = 0;
482 1.1 christos lctx->categories = NULL;
483 1.1 christos lctx->category_count = 0;
484 1.1 christos lctx->modules = NULL;
485 1.1 christos lctx->module_count = 0;
486 1.1 christos lctx->mctx = NULL;
487 1.1 christos lctx->magic = 0;
488 1.1 christos
489 1.1 christos isc_mem_putanddetach(&mctx, lctx, sizeof(*lctx));
490 1.1 christos
491 1.1 christos *lctxp = NULL;
492 1.1 christos }
493 1.1 christos
494 1.1 christos void
495 1.1 christos isc_logconfig_destroy(isc_logconfig_t **lcfgp) {
496 1.1 christos isc_logconfig_t *lcfg;
497 1.1 christos isc_mem_t *mctx;
498 1.1 christos isc_logchannel_t *channel;
499 1.1 christos isc_logchannellist_t *item;
500 1.1 christos char *filename;
501 1.1 christos unsigned int i;
502 1.1 christos
503 1.1 christos REQUIRE(lcfgp != NULL && VALID_CONFIG(*lcfgp));
504 1.1 christos
505 1.1 christos lcfg = *lcfgp;
506 1.1 christos
507 1.1 christos /*
508 1.1 christos * This function cannot be called with a logconfig that is in
509 1.1 christos * use by a log context.
510 1.1 christos */
511 1.1 christos REQUIRE(lcfg->lctx != NULL && lcfg->lctx->logconfig != lcfg);
512 1.1 christos
513 1.1 christos mctx = lcfg->lctx->mctx;
514 1.1 christos
515 1.1 christos while ((channel = ISC_LIST_HEAD(lcfg->channels)) != NULL) {
516 1.1 christos ISC_LIST_UNLINK(lcfg->channels, channel, link);
517 1.1 christos
518 1.1 christos if (channel->type == ISC_LOG_TOFILE) {
519 1.1 christos /*
520 1.1 christos * The filename for the channel may have ultimately
521 1.1 christos * started its life in user-land as a const string,
522 1.1 christos * but in isc_log_createchannel it gets copied
523 1.1 christos * into writable memory and is not longer truly const.
524 1.1 christos */
525 1.1 christos DE_CONST(FILE_NAME(channel), filename);
526 1.1 christos isc_mem_free(mctx, filename);
527 1.1 christos
528 1.1 christos if (FILE_STREAM(channel) != NULL)
529 1.1 christos (void)fclose(FILE_STREAM(channel));
530 1.1 christos }
531 1.1 christos
532 1.1 christos isc_mem_free(mctx, channel->name);
533 1.1 christos isc_mem_put(mctx, channel, sizeof(*channel));
534 1.1 christos }
535 1.1 christos
536 1.1 christos for (i = 0; i < lcfg->channellist_count; i++)
537 1.1 christos while ((item = ISC_LIST_HEAD(lcfg->channellists[i])) != NULL) {
538 1.1 christos ISC_LIST_UNLINK(lcfg->channellists[i], item, link);
539 1.1 christos isc_mem_put(mctx, item, sizeof(*item));
540 1.1 christos }
541 1.1 christos
542 1.1 christos if (lcfg->channellist_count > 0)
543 1.1 christos isc_mem_put(mctx, lcfg->channellists,
544 1.1 christos lcfg->channellist_count *
545 1.1 christos sizeof(ISC_LIST(isc_logchannellist_t)));
546 1.1 christos
547 1.3 christos lcfg->dynamic = false;
548 1.1 christos if (lcfg->tag != NULL)
549 1.1 christos isc_mem_free(lcfg->lctx->mctx, lcfg->tag);
550 1.1 christos lcfg->tag = NULL;
551 1.1 christos lcfg->highest_level = 0;
552 1.1 christos lcfg->duplicate_interval = 0;
553 1.1 christos lcfg->magic = 0;
554 1.1 christos
555 1.1 christos isc_mem_put(mctx, lcfg, sizeof(*lcfg));
556 1.1 christos
557 1.1 christos *lcfgp = NULL;
558 1.1 christos }
559 1.1 christos
560 1.1 christos void
561 1.1 christos isc_log_registercategories(isc_log_t *lctx, isc_logcategory_t categories[]) {
562 1.1 christos isc_logcategory_t *catp;
563 1.1 christos
564 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
565 1.1 christos REQUIRE(categories != NULL && categories[0].name != NULL);
566 1.1 christos
567 1.1 christos /*
568 1.1 christos * XXXDCL This somewhat sleazy situation of using the last pointer
569 1.1 christos * in one category array to point to the next array exists because
570 1.1 christos * this registration function returns void and I didn't want to have
571 1.1 christos * change everything that used it by making it return an isc_result_t.
572 1.1 christos * It would need to do that if it had to allocate memory to store
573 1.1 christos * pointers to each array passed in.
574 1.1 christos */
575 1.1 christos if (lctx->categories == NULL)
576 1.1 christos lctx->categories = categories;
577 1.1 christos
578 1.1 christos else {
579 1.1 christos /*
580 1.1 christos * Adjust the last (NULL) pointer of the already registered
581 1.1 christos * categories to point to the incoming array.
582 1.1 christos */
583 1.1 christos for (catp = lctx->categories; catp->name != NULL; )
584 1.1 christos if (catp->id == UINT_MAX)
585 1.1 christos /*
586 1.1 christos * The name pointer points to the next array.
587 1.1 christos * Ick.
588 1.1 christos */
589 1.1 christos DE_CONST(catp->name, catp);
590 1.1 christos else
591 1.1 christos catp++;
592 1.1 christos
593 1.1 christos catp->name = (void *)categories;
594 1.1 christos catp->id = UINT_MAX;
595 1.1 christos }
596 1.1 christos
597 1.1 christos /*
598 1.1 christos * Update the id number of the category with its new global id.
599 1.1 christos */
600 1.1 christos for (catp = categories; catp->name != NULL; catp++)
601 1.1 christos catp->id = lctx->category_count++;
602 1.1 christos }
603 1.1 christos
604 1.1 christos isc_logcategory_t *
605 1.1 christos isc_log_categorybyname(isc_log_t *lctx, const char *name) {
606 1.1 christos isc_logcategory_t *catp;
607 1.1 christos
608 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
609 1.1 christos REQUIRE(name != NULL);
610 1.1 christos
611 1.1 christos for (catp = lctx->categories; catp->name != NULL; )
612 1.1 christos if (catp->id == UINT_MAX)
613 1.1 christos /*
614 1.1 christos * catp is neither modified nor returned to the
615 1.1 christos * caller, so removing its const qualifier is ok.
616 1.1 christos */
617 1.1 christos DE_CONST(catp->name, catp);
618 1.1 christos else {
619 1.1 christos if (strcmp(catp->name, name) == 0)
620 1.1 christos return (catp);
621 1.1 christos catp++;
622 1.1 christos }
623 1.1 christos
624 1.1 christos return (NULL);
625 1.1 christos }
626 1.1 christos
627 1.1 christos void
628 1.1 christos isc_log_registermodules(isc_log_t *lctx, isc_logmodule_t modules[]) {
629 1.1 christos isc_logmodule_t *modp;
630 1.1 christos
631 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
632 1.1 christos REQUIRE(modules != NULL && modules[0].name != NULL);
633 1.1 christos
634 1.1 christos /*
635 1.1 christos * XXXDCL This somewhat sleazy situation of using the last pointer
636 1.1 christos * in one category array to point to the next array exists because
637 1.1 christos * this registration function returns void and I didn't want to have
638 1.1 christos * change everything that used it by making it return an isc_result_t.
639 1.1 christos * It would need to do that if it had to allocate memory to store
640 1.1 christos * pointers to each array passed in.
641 1.1 christos */
642 1.1 christos if (lctx->modules == NULL)
643 1.1 christos lctx->modules = modules;
644 1.1 christos
645 1.1 christos else {
646 1.1 christos /*
647 1.1 christos * Adjust the last (NULL) pointer of the already registered
648 1.1 christos * modules to point to the incoming array.
649 1.1 christos */
650 1.1 christos for (modp = lctx->modules; modp->name != NULL; )
651 1.1 christos if (modp->id == UINT_MAX)
652 1.1 christos /*
653 1.1 christos * The name pointer points to the next array.
654 1.1 christos * Ick.
655 1.1 christos */
656 1.1 christos DE_CONST(modp->name, modp);
657 1.1 christos else
658 1.1 christos modp++;
659 1.1 christos
660 1.1 christos modp->name = (void *)modules;
661 1.1 christos modp->id = UINT_MAX;
662 1.1 christos }
663 1.1 christos
664 1.1 christos /*
665 1.1 christos * Update the id number of the module with its new global id.
666 1.1 christos */
667 1.1 christos for (modp = modules; modp->name != NULL; modp++)
668 1.1 christos modp->id = lctx->module_count++;
669 1.1 christos }
670 1.1 christos
671 1.1 christos isc_logmodule_t *
672 1.1 christos isc_log_modulebyname(isc_log_t *lctx, const char *name) {
673 1.1 christos isc_logmodule_t *modp;
674 1.1 christos
675 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
676 1.1 christos REQUIRE(name != NULL);
677 1.1 christos
678 1.1 christos for (modp = lctx->modules; modp->name != NULL; )
679 1.1 christos if (modp->id == UINT_MAX)
680 1.1 christos /*
681 1.1 christos * modp is neither modified nor returned to the
682 1.1 christos * caller, so removing its const qualifier is ok.
683 1.1 christos */
684 1.1 christos DE_CONST(modp->name, modp);
685 1.1 christos else {
686 1.1 christos if (strcmp(modp->name, name) == 0)
687 1.1 christos return (modp);
688 1.1 christos modp++;
689 1.1 christos }
690 1.1 christos
691 1.1 christos return (NULL);
692 1.1 christos }
693 1.1 christos
694 1.1 christos isc_result_t
695 1.1 christos isc_log_createchannel(isc_logconfig_t *lcfg, const char *name,
696 1.1 christos unsigned int type, int level,
697 1.1 christos const isc_logdestination_t *destination,
698 1.1 christos unsigned int flags)
699 1.1 christos {
700 1.1 christos isc_logchannel_t *channel;
701 1.1 christos isc_mem_t *mctx;
702 1.1 christos unsigned int permitted = ISC_LOG_PRINTALL | ISC_LOG_DEBUGONLY |
703 1.1 christos ISC_LOG_BUFFERED | ISC_LOG_ISO8601 |
704 1.1 christos ISC_LOG_UTC;
705 1.1 christos
706 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
707 1.1 christos REQUIRE(name != NULL);
708 1.1 christos REQUIRE(type == ISC_LOG_TOSYSLOG || type == ISC_LOG_TOFILE ||
709 1.1 christos type == ISC_LOG_TOFILEDESC || type == ISC_LOG_TONULL);
710 1.1 christos REQUIRE(destination != NULL || type == ISC_LOG_TONULL);
711 1.1 christos REQUIRE(level >= ISC_LOG_CRITICAL);
712 1.1 christos REQUIRE((flags & ~permitted) == 0);
713 1.1 christos
714 1.1 christos /* XXXDCL find duplicate names? */
715 1.1 christos
716 1.1 christos mctx = lcfg->lctx->mctx;
717 1.1 christos
718 1.1 christos channel = isc_mem_get(mctx, sizeof(*channel));
719 1.1 christos if (channel == NULL)
720 1.1 christos return (ISC_R_NOMEMORY);
721 1.1 christos
722 1.1 christos channel->name = isc_mem_strdup(mctx, name);
723 1.1 christos if (channel->name == NULL) {
724 1.1 christos isc_mem_put(mctx, channel, sizeof(*channel));
725 1.1 christos return (ISC_R_NOMEMORY);
726 1.1 christos }
727 1.1 christos
728 1.1 christos channel->type = type;
729 1.1 christos channel->level = level;
730 1.1 christos channel->flags = flags;
731 1.1 christos ISC_LINK_INIT(channel, link);
732 1.1 christos
733 1.1 christos switch (type) {
734 1.1 christos case ISC_LOG_TOSYSLOG:
735 1.1 christos FACILITY(channel) = destination->facility;
736 1.1 christos break;
737 1.1 christos
738 1.1 christos case ISC_LOG_TOFILE:
739 1.1 christos /*
740 1.1 christos * The file name is copied because greatest_version wants
741 1.1 christos * to scribble on it, so it needs to be definitely in
742 1.1 christos * writable memory.
743 1.1 christos */
744 1.1 christos FILE_NAME(channel) =
745 1.1 christos isc_mem_strdup(mctx, destination->file.name);
746 1.1 christos FILE_STREAM(channel) = NULL;
747 1.1 christos FILE_VERSIONS(channel) = destination->file.versions;
748 1.1 christos FILE_SUFFIX(channel) = destination->file.suffix;
749 1.1 christos FILE_MAXSIZE(channel) = destination->file.maximum_size;
750 1.3 christos FILE_MAXREACHED(channel) = false;
751 1.1 christos break;
752 1.1 christos
753 1.1 christos case ISC_LOG_TOFILEDESC:
754 1.1 christos FILE_NAME(channel) = NULL;
755 1.1 christos FILE_STREAM(channel) = destination->file.stream;
756 1.1 christos FILE_MAXSIZE(channel) = 0;
757 1.1 christos FILE_VERSIONS(channel) = ISC_LOG_ROLLNEVER;
758 1.1 christos FILE_SUFFIX(channel) = isc_log_rollsuffix_increment;
759 1.1 christos break;
760 1.1 christos
761 1.1 christos case ISC_LOG_TONULL:
762 1.1 christos /* Nothing. */
763 1.1 christos break;
764 1.1 christos
765 1.1 christos default:
766 1.1 christos isc_mem_free(mctx, channel->name);
767 1.1 christos isc_mem_put(mctx, channel, sizeof(*channel));
768 1.1 christos return (ISC_R_UNEXPECTED);
769 1.1 christos }
770 1.1 christos
771 1.1 christos ISC_LIST_PREPEND(lcfg->channels, channel, link);
772 1.1 christos
773 1.1 christos /*
774 1.1 christos * If default_stderr was redefined, make the default category
775 1.1 christos * point to the new default_stderr.
776 1.1 christos */
777 1.1 christos if (strcmp(name, "default_stderr") == 0)
778 1.1 christos default_channel.channel = channel;
779 1.1 christos
780 1.1 christos return (ISC_R_SUCCESS);
781 1.1 christos }
782 1.1 christos
783 1.1 christos isc_result_t
784 1.1 christos isc_log_usechannel(isc_logconfig_t *lcfg, const char *name,
785 1.1 christos const isc_logcategory_t *category,
786 1.1 christos const isc_logmodule_t *module)
787 1.1 christos {
788 1.1 christos isc_log_t *lctx;
789 1.1 christos isc_logchannel_t *channel;
790 1.1 christos isc_result_t result = ISC_R_SUCCESS;
791 1.1 christos unsigned int i;
792 1.1 christos
793 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
794 1.1 christos REQUIRE(name != NULL);
795 1.1 christos
796 1.1 christos lctx = lcfg->lctx;
797 1.1 christos
798 1.1 christos REQUIRE(category == NULL || category->id < lctx->category_count);
799 1.1 christos REQUIRE(module == NULL || module->id < lctx->module_count);
800 1.1 christos
801 1.1 christos for (channel = ISC_LIST_HEAD(lcfg->channels); channel != NULL;
802 1.1 christos channel = ISC_LIST_NEXT(channel, link))
803 1.1 christos if (strcmp(name, channel->name) == 0)
804 1.1 christos break;
805 1.1 christos
806 1.1 christos if (channel == NULL)
807 1.1 christos return (ISC_R_NOTFOUND);
808 1.1 christos
809 1.1 christos if (category != NULL)
810 1.1 christos result = assignchannel(lcfg, category->id, module, channel);
811 1.1 christos
812 1.1 christos else
813 1.1 christos /*
814 1.1 christos * Assign to all categories. Note that this includes
815 1.1 christos * the default channel.
816 1.1 christos */
817 1.1 christos for (i = 0; i < lctx->category_count; i++) {
818 1.1 christos result = assignchannel(lcfg, i, module, channel);
819 1.1 christos if (result != ISC_R_SUCCESS)
820 1.1 christos break;
821 1.1 christos }
822 1.1 christos
823 1.1 christos return (result);
824 1.1 christos }
825 1.1 christos
826 1.1 christos void
827 1.1 christos isc_log_write(isc_log_t *lctx, isc_logcategory_t *category,
828 1.1 christos isc_logmodule_t *module, int level, const char *format, ...)
829 1.1 christos {
830 1.1 christos va_list args;
831 1.1 christos
832 1.1 christos /*
833 1.1 christos * Contract checking is done in isc_log_doit().
834 1.1 christos */
835 1.1 christos
836 1.1 christos va_start(args, format);
837 1.3 christos isc_log_doit(lctx, category, module, level, false,
838 1.1 christos NULL, 0, 0, format, args);
839 1.1 christos va_end(args);
840 1.1 christos }
841 1.1 christos
842 1.1 christos void
843 1.1 christos isc_log_vwrite(isc_log_t *lctx, isc_logcategory_t *category,
844 1.1 christos isc_logmodule_t *module, int level,
845 1.1 christos const char *format, va_list args)
846 1.1 christos {
847 1.1 christos /*
848 1.1 christos * Contract checking is done in isc_log_doit().
849 1.1 christos */
850 1.3 christos isc_log_doit(lctx, category, module, level, false,
851 1.1 christos NULL, 0, 0, format, args);
852 1.1 christos }
853 1.1 christos
854 1.1 christos void
855 1.1 christos isc_log_write1(isc_log_t *lctx, isc_logcategory_t *category,
856 1.1 christos isc_logmodule_t *module, int level, const char *format, ...)
857 1.1 christos {
858 1.1 christos va_list args;
859 1.1 christos
860 1.1 christos /*
861 1.1 christos * Contract checking is done in isc_log_doit().
862 1.1 christos */
863 1.1 christos
864 1.1 christos va_start(args, format);
865 1.3 christos isc_log_doit(lctx, category, module, level, true,
866 1.1 christos NULL, 0, 0, format, args);
867 1.1 christos va_end(args);
868 1.1 christos }
869 1.1 christos
870 1.1 christos void
871 1.1 christos isc_log_vwrite1(isc_log_t *lctx, isc_logcategory_t *category,
872 1.1 christos isc_logmodule_t *module, int level,
873 1.1 christos const char *format, va_list args)
874 1.1 christos {
875 1.1 christos /*
876 1.1 christos * Contract checking is done in isc_log_doit().
877 1.1 christos */
878 1.3 christos isc_log_doit(lctx, category, module, level, true,
879 1.1 christos NULL, 0, 0, format, args);
880 1.1 christos }
881 1.1 christos
882 1.1 christos void
883 1.1 christos isc_log_iwrite(isc_log_t *lctx, isc_logcategory_t *category,
884 1.1 christos isc_logmodule_t *module, int level,
885 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
886 1.1 christos const char *format, ...)
887 1.1 christos {
888 1.1 christos va_list args;
889 1.1 christos
890 1.1 christos /*
891 1.1 christos * Contract checking is done in isc_log_doit().
892 1.1 christos */
893 1.1 christos
894 1.1 christos va_start(args, format);
895 1.3 christos isc_log_doit(lctx, category, module, level, false,
896 1.1 christos msgcat, msgset, msg, format, args);
897 1.1 christos va_end(args);
898 1.1 christos }
899 1.1 christos
900 1.1 christos void
901 1.1 christos isc_log_ivwrite(isc_log_t *lctx, isc_logcategory_t *category,
902 1.1 christos isc_logmodule_t *module, int level,
903 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
904 1.1 christos const char *format, va_list args)
905 1.1 christos {
906 1.1 christos /*
907 1.1 christos * Contract checking is done in isc_log_doit().
908 1.1 christos */
909 1.3 christos isc_log_doit(lctx, category, module, level, false,
910 1.1 christos msgcat, msgset, msg, format, args);
911 1.1 christos }
912 1.1 christos
913 1.1 christos void
914 1.1 christos isc_log_iwrite1(isc_log_t *lctx, isc_logcategory_t *category,
915 1.1 christos isc_logmodule_t *module, int level,
916 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
917 1.1 christos const char *format, ...)
918 1.1 christos {
919 1.1 christos va_list args;
920 1.1 christos
921 1.1 christos /*
922 1.1 christos * Contract checking is done in isc_log_doit().
923 1.1 christos */
924 1.1 christos
925 1.1 christos va_start(args, format);
926 1.3 christos isc_log_doit(lctx, category, module, level, true,
927 1.1 christos msgcat, msgset, msg, format, args);
928 1.1 christos va_end(args);
929 1.1 christos }
930 1.1 christos
931 1.1 christos void
932 1.1 christos isc_log_ivwrite1(isc_log_t *lctx, isc_logcategory_t *category,
933 1.1 christos isc_logmodule_t *module, int level,
934 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
935 1.1 christos const char *format, va_list args)
936 1.1 christos {
937 1.1 christos /*
938 1.1 christos * Contract checking is done in isc_log_doit().
939 1.1 christos */
940 1.3 christos isc_log_doit(lctx, category, module, level, true,
941 1.1 christos msgcat, msgset, msg, format, args);
942 1.1 christos }
943 1.1 christos
944 1.1 christos void
945 1.1 christos isc_log_setcontext(isc_log_t *lctx) {
946 1.1 christos isc_lctx = lctx;
947 1.1 christos }
948 1.1 christos
949 1.1 christos void
950 1.1 christos isc_log_setdebuglevel(isc_log_t *lctx, unsigned int level) {
951 1.1 christos isc_logchannel_t *channel;
952 1.1 christos
953 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
954 1.1 christos
955 1.1 christos LOCK(&lctx->lock);
956 1.1 christos
957 1.1 christos lctx->debug_level = level;
958 1.1 christos /*
959 1.1 christos * Close ISC_LOG_DEBUGONLY channels if level is zero.
960 1.1 christos */
961 1.1 christos if (lctx->debug_level == 0)
962 1.1 christos for (channel = ISC_LIST_HEAD(lctx->logconfig->channels);
963 1.1 christos channel != NULL;
964 1.1 christos channel = ISC_LIST_NEXT(channel, link))
965 1.1 christos if (channel->type == ISC_LOG_TOFILE &&
966 1.1 christos (channel->flags & ISC_LOG_DEBUGONLY) != 0 &&
967 1.1 christos FILE_STREAM(channel) != NULL) {
968 1.1 christos (void)fclose(FILE_STREAM(channel));
969 1.1 christos FILE_STREAM(channel) = NULL;
970 1.1 christos }
971 1.1 christos UNLOCK(&lctx->lock);
972 1.1 christos }
973 1.1 christos
974 1.1 christos unsigned int
975 1.1 christos isc_log_getdebuglevel(isc_log_t *lctx) {
976 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
977 1.1 christos
978 1.1 christos return (lctx->debug_level);
979 1.1 christos }
980 1.1 christos
981 1.1 christos void
982 1.1 christos isc_log_setduplicateinterval(isc_logconfig_t *lcfg, unsigned int interval) {
983 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
984 1.1 christos
985 1.1 christos lcfg->duplicate_interval = interval;
986 1.1 christos }
987 1.1 christos
988 1.1 christos unsigned int
989 1.1 christos isc_log_getduplicateinterval(isc_logconfig_t *lcfg) {
990 1.1 christos REQUIRE(VALID_CONTEXT(lcfg));
991 1.1 christos
992 1.1 christos return (lcfg->duplicate_interval);
993 1.1 christos }
994 1.1 christos
995 1.1 christos isc_result_t
996 1.1 christos isc_log_settag(isc_logconfig_t *lcfg, const char *tag) {
997 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
998 1.1 christos
999 1.1 christos if (tag != NULL && *tag != '\0') {
1000 1.1 christos if (lcfg->tag != NULL)
1001 1.1 christos isc_mem_free(lcfg->lctx->mctx, lcfg->tag);
1002 1.1 christos lcfg->tag = isc_mem_strdup(lcfg->lctx->mctx, tag);
1003 1.1 christos if (lcfg->tag == NULL)
1004 1.1 christos return (ISC_R_NOMEMORY);
1005 1.1 christos
1006 1.1 christos } else {
1007 1.1 christos if (lcfg->tag != NULL)
1008 1.1 christos isc_mem_free(lcfg->lctx->mctx, lcfg->tag);
1009 1.1 christos lcfg->tag = NULL;
1010 1.1 christos }
1011 1.1 christos
1012 1.1 christos return (ISC_R_SUCCESS);
1013 1.1 christos }
1014 1.1 christos
1015 1.1 christos char *
1016 1.1 christos isc_log_gettag(isc_logconfig_t *lcfg) {
1017 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
1018 1.1 christos
1019 1.1 christos return (lcfg->tag);
1020 1.1 christos }
1021 1.1 christos
1022 1.1 christos /* XXXDCL NT -- This interface will assuredly be changing. */
1023 1.1 christos void
1024 1.1 christos isc_log_opensyslog(const char *tag, int options, int facility) {
1025 1.1 christos (void)openlog(tag, options, facility);
1026 1.1 christos }
1027 1.1 christos
1028 1.1 christos void
1029 1.1 christos isc_log_closefilelogs(isc_log_t *lctx) {
1030 1.1 christos isc_logchannel_t *channel;
1031 1.1 christos
1032 1.1 christos REQUIRE(VALID_CONTEXT(lctx));
1033 1.1 christos
1034 1.1 christos LOCK(&lctx->lock);
1035 1.1 christos for (channel = ISC_LIST_HEAD(lctx->logconfig->channels);
1036 1.1 christos channel != NULL;
1037 1.1 christos channel = ISC_LIST_NEXT(channel, link))
1038 1.1 christos
1039 1.1 christos if (channel->type == ISC_LOG_TOFILE &&
1040 1.1 christos FILE_STREAM(channel) != NULL) {
1041 1.1 christos (void)fclose(FILE_STREAM(channel));
1042 1.1 christos FILE_STREAM(channel) = NULL;
1043 1.1 christos }
1044 1.1 christos UNLOCK(&lctx->lock);
1045 1.1 christos }
1046 1.1 christos
1047 1.1 christos /****
1048 1.1 christos **** Internal functions
1049 1.1 christos ****/
1050 1.1 christos
1051 1.1 christos static isc_result_t
1052 1.1 christos assignchannel(isc_logconfig_t *lcfg, unsigned int category_id,
1053 1.1 christos const isc_logmodule_t *module, isc_logchannel_t *channel)
1054 1.1 christos {
1055 1.1 christos isc_logchannellist_t *new_item;
1056 1.1 christos isc_log_t *lctx;
1057 1.1 christos isc_result_t result;
1058 1.1 christos
1059 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
1060 1.1 christos
1061 1.1 christos lctx = lcfg->lctx;
1062 1.1 christos
1063 1.1 christos REQUIRE(category_id < lctx->category_count);
1064 1.1 christos REQUIRE(module == NULL || module->id < lctx->module_count);
1065 1.1 christos REQUIRE(channel != NULL);
1066 1.1 christos
1067 1.1 christos /*
1068 1.1 christos * Ensure lcfg->channellist_count == lctx->category_count.
1069 1.1 christos */
1070 1.1 christos result = sync_channellist(lcfg);
1071 1.1 christos if (result != ISC_R_SUCCESS)
1072 1.1 christos return (result);
1073 1.1 christos
1074 1.1 christos new_item = isc_mem_get(lctx->mctx, sizeof(*new_item));
1075 1.1 christos if (new_item == NULL)
1076 1.1 christos return (ISC_R_NOMEMORY);
1077 1.1 christos
1078 1.1 christos new_item->channel = channel;
1079 1.1 christos new_item->module = module;
1080 1.1 christos ISC_LIST_INITANDPREPEND(lcfg->channellists[category_id],
1081 1.1 christos new_item, link);
1082 1.1 christos
1083 1.1 christos /*
1084 1.1 christos * Remember the highest logging level set by any channel in the
1085 1.1 christos * logging config, so isc_log_doit() can quickly return if the
1086 1.1 christos * message is too high to be logged by any channel.
1087 1.1 christos */
1088 1.1 christos if (channel->type != ISC_LOG_TONULL) {
1089 1.1 christos if (lcfg->highest_level < channel->level)
1090 1.1 christos lcfg->highest_level = channel->level;
1091 1.1 christos if (channel->level == ISC_LOG_DYNAMIC)
1092 1.3 christos lcfg->dynamic = true;
1093 1.1 christos }
1094 1.1 christos
1095 1.1 christos return (ISC_R_SUCCESS);
1096 1.1 christos }
1097 1.1 christos
1098 1.1 christos /*
1099 1.1 christos * This would ideally be part of isc_log_registercategories(), except then
1100 1.1 christos * that function would have to return isc_result_t instead of void.
1101 1.1 christos */
1102 1.1 christos static isc_result_t
1103 1.1 christos sync_channellist(isc_logconfig_t *lcfg) {
1104 1.1 christos unsigned int bytes;
1105 1.1 christos isc_log_t *lctx;
1106 1.1 christos void *lists;
1107 1.1 christos
1108 1.1 christos REQUIRE(VALID_CONFIG(lcfg));
1109 1.1 christos
1110 1.1 christos lctx = lcfg->lctx;
1111 1.1 christos
1112 1.1 christos REQUIRE(lctx->category_count != 0);
1113 1.1 christos
1114 1.1 christos if (lctx->category_count == lcfg->channellist_count)
1115 1.1 christos return (ISC_R_SUCCESS);
1116 1.1 christos
1117 1.1 christos bytes = lctx->category_count * sizeof(ISC_LIST(isc_logchannellist_t));
1118 1.1 christos
1119 1.1 christos lists = isc_mem_get(lctx->mctx, bytes);
1120 1.1 christos
1121 1.1 christos if (lists == NULL)
1122 1.1 christos return (ISC_R_NOMEMORY);
1123 1.1 christos
1124 1.1 christos memset(lists, 0, bytes);
1125 1.1 christos
1126 1.1 christos if (lcfg->channellist_count != 0) {
1127 1.1 christos bytes = lcfg->channellist_count *
1128 1.1 christos sizeof(ISC_LIST(isc_logchannellist_t));
1129 1.1 christos memmove(lists, lcfg->channellists, bytes);
1130 1.1 christos isc_mem_put(lctx->mctx, lcfg->channellists, bytes);
1131 1.1 christos }
1132 1.1 christos
1133 1.1 christos lcfg->channellists = lists;
1134 1.1 christos lcfg->channellist_count = lctx->category_count;
1135 1.1 christos
1136 1.1 christos return (ISC_R_SUCCESS);
1137 1.1 christos }
1138 1.1 christos
1139 1.1 christos static isc_result_t
1140 1.1 christos greatest_version(isc_logfile_t *file, int versions, int *greatestp) {
1141 1.1 christos char *bname, *digit_end;
1142 1.1 christos const char *dirname;
1143 1.1 christos int version, greatest = -1;
1144 1.1 christos size_t bnamelen;
1145 1.1 christos isc_dir_t dir;
1146 1.1 christos isc_result_t result;
1147 1.1 christos char sep = '/';
1148 1.1 christos #ifdef _WIN32
1149 1.1 christos char *bname2;
1150 1.1 christos #endif
1151 1.1 christos
1152 1.1 christos /*
1153 1.1 christos * It is safe to DE_CONST the file.name because it was copied
1154 1.1 christos * with isc_mem_strdup().
1155 1.1 christos */
1156 1.1 christos bname = strrchr(file->name, sep);
1157 1.1 christos #ifdef _WIN32
1158 1.1 christos bname2 = strrchr(file->name, '\\');
1159 1.1 christos if ((bname != NULL && bname2 != NULL && bname2 > bname) ||
1160 1.1 christos (bname == NULL && bname2 != NULL)) {
1161 1.1 christos bname = bname2;
1162 1.1 christos sep = '\\';
1163 1.1 christos }
1164 1.1 christos #endif
1165 1.1 christos if (bname != NULL) {
1166 1.1 christos *bname++ = '\0';
1167 1.1 christos dirname = file->name;
1168 1.1 christos } else {
1169 1.1 christos DE_CONST(file->name, bname);
1170 1.1 christos dirname = ".";
1171 1.1 christos }
1172 1.1 christos bnamelen = strlen(bname);
1173 1.1 christos
1174 1.1 christos isc_dir_init(&dir);
1175 1.1 christos result = isc_dir_open(&dir, dirname);
1176 1.1 christos
1177 1.1 christos /*
1178 1.1 christos * Replace the file separator if it was taken out.
1179 1.1 christos */
1180 1.1 christos if (bname != file->name)
1181 1.1 christos *(bname - 1) = sep;
1182 1.1 christos
1183 1.1 christos /*
1184 1.1 christos * Return if the directory open failed.
1185 1.1 christos */
1186 1.1 christos if (result != ISC_R_SUCCESS)
1187 1.1 christos return (result);
1188 1.1 christos
1189 1.1 christos while (isc_dir_read(&dir) == ISC_R_SUCCESS) {
1190 1.1 christos if (dir.entry.length > bnamelen &&
1191 1.1 christos strncmp(dir.entry.name, bname, bnamelen) == 0 &&
1192 1.1 christos dir.entry.name[bnamelen] == '.')
1193 1.1 christos {
1194 1.1 christos version = strtol(&dir.entry.name[bnamelen + 1],
1195 1.1 christos &digit_end, 10);
1196 1.1 christos /*
1197 1.1 christos * Remove any backup files that exceed versions.
1198 1.1 christos */
1199 1.1 christos if (*digit_end == '\0' && version >= versions) {
1200 1.1 christos result = isc_file_remove(dir.entry.name);
1201 1.1 christos if (result != ISC_R_SUCCESS &&
1202 1.1 christos result != ISC_R_FILENOTFOUND)
1203 1.1 christos syslog(LOG_ERR, "unable to remove "
1204 1.1 christos "log file '%s': %s",
1205 1.1 christos dir.entry.name,
1206 1.1 christos isc_result_totext(result));
1207 1.1 christos } else if (*digit_end == '\0' && version > greatest)
1208 1.1 christos greatest = version;
1209 1.1 christos }
1210 1.1 christos }
1211 1.1 christos isc_dir_close(&dir);
1212 1.1 christos
1213 1.1 christos *greatestp = greatest;
1214 1.1 christos
1215 1.1 christos return (ISC_R_SUCCESS);
1216 1.1 christos }
1217 1.1 christos
1218 1.1 christos static isc_result_t
1219 1.1 christos remove_old_tsversions(isc_logfile_t *file, int versions) {
1220 1.1 christos isc_result_t result;
1221 1.1 christos char *bname, *digit_end;
1222 1.1 christos const char *dirname;
1223 1.3 christos int64_t version, last = INT64_MAX;
1224 1.3 christos int64_t to_keep[ISC_LOG_MAX_VERSIONS];
1225 1.1 christos size_t bnamelen;
1226 1.1 christos isc_dir_t dir;
1227 1.1 christos char sep = '/';
1228 1.1 christos #ifdef _WIN32
1229 1.1 christos char *bname2;
1230 1.1 christos #endif
1231 1.1 christos /*
1232 1.1 christos * It is safe to DE_CONST the file.name because it was copied
1233 1.1 christos * with isc_mem_strdup().
1234 1.1 christos */
1235 1.1 christos bname = strrchr(file->name, sep);
1236 1.1 christos #ifdef _WIN32
1237 1.1 christos bname2 = strrchr(file->name, '\\');
1238 1.1 christos if ((bname != NULL && bname2 != NULL && bname2 > bname) ||
1239 1.1 christos (bname == NULL && bname2 != NULL)) {
1240 1.1 christos bname = bname2;
1241 1.1 christos sep = '\\';
1242 1.1 christos }
1243 1.1 christos #endif
1244 1.1 christos if (bname != NULL) {
1245 1.1 christos *bname++ = '\0';
1246 1.1 christos dirname = file->name;
1247 1.1 christos } else {
1248 1.1 christos DE_CONST(file->name, bname);
1249 1.1 christos dirname = ".";
1250 1.1 christos }
1251 1.1 christos bnamelen = strlen(bname);
1252 1.1 christos
1253 1.1 christos isc_dir_init(&dir);
1254 1.1 christos result = isc_dir_open(&dir, dirname);
1255 1.1 christos
1256 1.1 christos /*
1257 1.1 christos * Replace the file separator if it was taken out.
1258 1.1 christos */
1259 1.1 christos if (bname != file->name) {
1260 1.1 christos *(bname - 1) = sep;
1261 1.1 christos }
1262 1.1 christos
1263 1.1 christos /*
1264 1.1 christos * Return if the directory open failed.
1265 1.1 christos */
1266 1.1 christos if (result != ISC_R_SUCCESS)
1267 1.1 christos return (result);
1268 1.1 christos
1269 1.1 christos if (versions > 0) {
1270 1.1 christos /*
1271 1.1 christos * First we fill 'to_keep' structure using insertion sort
1272 1.1 christos */
1273 1.1 christos memset(to_keep, 0, versions * sizeof(long long));
1274 1.1 christos while (isc_dir_read(&dir) == ISC_R_SUCCESS) {
1275 1.1 christos if (dir.entry.length > bnamelen &&
1276 1.1 christos strncmp(dir.entry.name, bname, bnamelen) == 0 &&
1277 1.1 christos dir.entry.name[bnamelen] == '.')
1278 1.1 christos {
1279 1.1 christos char *ename = &dir.entry.name[bnamelen + 1];
1280 1.3 christos version = strtoull(ename, &digit_end, 10);
1281 1.1 christos if (*digit_end == '\0') {
1282 1.1 christos int i = 0;
1283 1.1 christos while (i < versions &&
1284 1.1 christos version < to_keep[i])
1285 1.1 christos {
1286 1.1 christos i++;
1287 1.1 christos }
1288 1.1 christos if (i < versions) {
1289 1.1 christos memmove(&to_keep[i + 1],
1290 1.1 christos &to_keep[i],
1291 1.1 christos sizeof(long long) *
1292 1.1 christos versions - i - 1);
1293 1.1 christos to_keep[i] = version;
1294 1.1 christos }
1295 1.1 christos }
1296 1.1 christos }
1297 1.1 christos }
1298 1.1 christos
1299 1.1 christos /*
1300 1.1 christos * to_keep[versions - 1] is the last one we want to keep
1301 1.1 christos */
1302 1.1 christos last = to_keep[versions - 1];
1303 1.1 christos isc_dir_reset(&dir);
1304 1.1 christos }
1305 1.1 christos
1306 1.1 christos /*
1307 1.1 christos * Then we remove all files that we don't want to_keep
1308 1.1 christos */
1309 1.1 christos while (isc_dir_read(&dir) == ISC_R_SUCCESS) {
1310 1.1 christos if (dir.entry.length > bnamelen &&
1311 1.1 christos strncmp(dir.entry.name, bname, bnamelen) == 0 &&
1312 1.1 christos dir.entry.name[bnamelen] == '.')
1313 1.1 christos {
1314 1.1 christos char *ename = &dir.entry.name[bnamelen + 1];
1315 1.3 christos version = strtoull(ename, &digit_end, 10);
1316 1.1 christos /*
1317 1.1 christos * Remove any backup files that exceed versions.
1318 1.1 christos */
1319 1.1 christos if (*digit_end == '\0' && version < last) {
1320 1.1 christos result = isc_file_remove(dir.entry.name);
1321 1.1 christos if (result != ISC_R_SUCCESS &&
1322 1.1 christos result != ISC_R_FILENOTFOUND)
1323 1.1 christos syslog(LOG_ERR, "unable to remove "
1324 1.1 christos "log file '%s': %s",
1325 1.1 christos dir.entry.name,
1326 1.1 christos isc_result_totext(result));
1327 1.1 christos }
1328 1.1 christos }
1329 1.1 christos }
1330 1.1 christos
1331 1.1 christos isc_dir_close(&dir);
1332 1.1 christos
1333 1.1 christos return (ISC_R_SUCCESS);
1334 1.1 christos }
1335 1.1 christos
1336 1.1 christos static isc_result_t
1337 1.1 christos roll_increment(isc_logfile_t *file) {
1338 1.1 christos int i, n, greatest;
1339 1.1 christos char current[PATH_MAX + 1];
1340 1.1 christos char newpath[PATH_MAX + 1];
1341 1.1 christos const char *path;
1342 1.1 christos isc_result_t result = ISC_R_SUCCESS;
1343 1.1 christos
1344 1.1 christos REQUIRE(file != NULL);
1345 1.1 christos REQUIRE(file->versions != 0);
1346 1.1 christos
1347 1.1 christos path = file->name;
1348 1.1 christos
1349 1.1 christos if (file->versions == ISC_LOG_ROLLINFINITE) {
1350 1.1 christos /*
1351 1.1 christos * Find the first missing entry in the log file sequence.
1352 1.1 christos */
1353 1.1 christos for (greatest = 0; greatest < INT_MAX; greatest++) {
1354 1.1 christos n = snprintf(current, sizeof(current),
1355 1.1 christos "%s.%u", path, (unsigned)greatest) ;
1356 1.1 christos if (n >= (int)sizeof(current) || n < 0 ||
1357 1.1 christos !isc_file_exists(current))
1358 1.1 christos {
1359 1.1 christos break;
1360 1.1 christos }
1361 1.1 christos }
1362 1.1 christos } else {
1363 1.1 christos /*
1364 1.1 christos * Get the largest existing version and remove any
1365 1.1 christos * version greater than the permitted version.
1366 1.1 christos */
1367 1.1 christos result = greatest_version(file, file->versions, &greatest);
1368 1.1 christos if (result != ISC_R_SUCCESS) {
1369 1.1 christos return (result);
1370 1.1 christos }
1371 1.1 christos
1372 1.1 christos /*
1373 1.1 christos * Increment if greatest is not the actual maximum value.
1374 1.1 christos */
1375 1.1 christos if (greatest < file->versions - 1) {
1376 1.1 christos greatest++;
1377 1.1 christos }
1378 1.1 christos }
1379 1.1 christos
1380 1.1 christos for (i = greatest; i > 0; i--) {
1381 1.1 christos result = ISC_R_SUCCESS;
1382 1.1 christos n = snprintf(current, sizeof(current), "%s.%u", path,
1383 1.1 christos (unsigned)(i - 1));
1384 1.1 christos if (n >= (int)sizeof(current) || n < 0) {
1385 1.1 christos result = ISC_R_NOSPACE;
1386 1.1 christos }
1387 1.1 christos if (result == ISC_R_SUCCESS) {
1388 1.1 christos n = snprintf(newpath, sizeof(newpath), "%s.%u",
1389 1.1 christos path, (unsigned)i);
1390 1.1 christos if (n >= (int)sizeof(newpath) || n < 0) {
1391 1.1 christos result = ISC_R_NOSPACE;
1392 1.1 christos }
1393 1.1 christos }
1394 1.1 christos if (result == ISC_R_SUCCESS) {
1395 1.1 christos result = isc_file_rename(current, newpath);
1396 1.1 christos }
1397 1.1 christos if (result != ISC_R_SUCCESS && result != ISC_R_FILENOTFOUND) {
1398 1.1 christos syslog(LOG_ERR,
1399 1.1 christos "unable to rename log file '%s.%u' to "
1400 1.1 christos "'%s.%u': %s", path, i - 1, path, i,
1401 1.1 christos isc_result_totext(result));
1402 1.1 christos }
1403 1.1 christos }
1404 1.1 christos
1405 1.1 christos n = snprintf(newpath, sizeof(newpath), "%s.0", path);
1406 1.1 christos if (n >= (int)sizeof(newpath) || n < 0) {
1407 1.1 christos result = ISC_R_NOSPACE;
1408 1.1 christos } else {
1409 1.1 christos result = isc_file_rename(path, newpath);
1410 1.1 christos }
1411 1.1 christos if (result != ISC_R_SUCCESS && result != ISC_R_FILENOTFOUND) {
1412 1.1 christos syslog(LOG_ERR,
1413 1.1 christos "unable to rename log file '%s' to '%s.0': %s",
1414 1.1 christos path, path, isc_result_totext(result));
1415 1.1 christos }
1416 1.1 christos
1417 1.1 christos return (ISC_R_SUCCESS);
1418 1.1 christos }
1419 1.1 christos
1420 1.1 christos static isc_result_t
1421 1.1 christos roll_timestamp(isc_logfile_t *file) {
1422 1.1 christos int n;
1423 1.1 christos char newts[PATH_MAX + 1];
1424 1.1 christos char newpath[PATH_MAX + 1];
1425 1.1 christos const char *path;
1426 1.1 christos isc_time_t now;
1427 1.1 christos isc_result_t result = ISC_R_SUCCESS;
1428 1.1 christos
1429 1.1 christos REQUIRE(file != NULL);
1430 1.1 christos REQUIRE(file->versions != 0);
1431 1.1 christos
1432 1.1 christos path = file->name;
1433 1.1 christos
1434 1.1 christos /*
1435 1.1 christos * First find all the logfiles and remove the oldest ones
1436 1.1 christos * Save one fewer than file->versions because we'll be renaming
1437 1.1 christos * the existing file to a timestamped version after this.
1438 1.1 christos */
1439 1.1 christos if (file->versions != ISC_LOG_ROLLINFINITE) {
1440 1.1 christos remove_old_tsversions(file, file->versions - 1);
1441 1.1 christos }
1442 1.1 christos
1443 1.1 christos /* Then just rename the current logfile */
1444 1.1 christos isc_time_now(&now);
1445 1.1 christos isc_time_formatshorttimestamp(&now, newts, PATH_MAX + 1);
1446 1.1 christos n = snprintf(newpath, sizeof(newpath), "%s.%s", path, newts);
1447 1.1 christos if (n >= (int)sizeof(newpath) || n < 0) {
1448 1.1 christos result = ISC_R_NOSPACE;
1449 1.1 christos } else {
1450 1.1 christos result = isc_file_rename(path, newpath);
1451 1.1 christos }
1452 1.1 christos if (result != ISC_R_SUCCESS && result != ISC_R_FILENOTFOUND) {
1453 1.1 christos syslog(LOG_ERR,
1454 1.1 christos "unable to rename log file '%s' to '%s.0': %s",
1455 1.1 christos path, path, isc_result_totext(result));
1456 1.1 christos }
1457 1.1 christos
1458 1.1 christos return (ISC_R_SUCCESS);
1459 1.1 christos }
1460 1.1 christos
1461 1.1 christos
1462 1.1 christos isc_result_t
1463 1.1 christos isc_logfile_roll(isc_logfile_t *file) {
1464 1.1 christos isc_result_t result;
1465 1.1 christos
1466 1.1 christos REQUIRE(file != NULL);
1467 1.1 christos
1468 1.1 christos /*
1469 1.1 christos * Do nothing (not even excess version trimming) if ISC_LOG_ROLLNEVER
1470 1.1 christos * is specified. Apparently complete external control over the log
1471 1.1 christos * files is desired.
1472 1.1 christos */
1473 1.1 christos if (file->versions == ISC_LOG_ROLLNEVER) {
1474 1.1 christos return (ISC_R_SUCCESS);
1475 1.1 christos } else if (file->versions == 0) {
1476 1.1 christos result = isc_file_remove(file->name);
1477 1.1 christos if (result != ISC_R_SUCCESS &&
1478 1.1 christos result != ISC_R_FILENOTFOUND)
1479 1.1 christos syslog(LOG_ERR, "unable to remove log file '%s': %s",
1480 1.1 christos file->name, isc_result_totext(result));
1481 1.1 christos return (ISC_R_SUCCESS);
1482 1.1 christos }
1483 1.1 christos
1484 1.1 christos switch (file->suffix) {
1485 1.1 christos case isc_log_rollsuffix_increment:
1486 1.1 christos return (roll_increment(file));
1487 1.1 christos case isc_log_rollsuffix_timestamp:
1488 1.1 christos return (roll_timestamp(file));
1489 1.1 christos default:
1490 1.1 christos return (ISC_R_UNEXPECTED);
1491 1.1 christos }
1492 1.1 christos }
1493 1.1 christos
1494 1.1 christos static isc_result_t
1495 1.1 christos isc_log_open(isc_logchannel_t *channel) {
1496 1.1 christos struct stat statbuf;
1497 1.3 christos bool regular_file;
1498 1.3 christos bool roll = false;
1499 1.1 christos isc_result_t result = ISC_R_SUCCESS;
1500 1.1 christos const char *path;
1501 1.1 christos
1502 1.1 christos REQUIRE(channel->type == ISC_LOG_TOFILE);
1503 1.1 christos REQUIRE(FILE_STREAM(channel) == NULL);
1504 1.1 christos
1505 1.1 christos path = FILE_NAME(channel);
1506 1.1 christos
1507 1.1 christos REQUIRE(path != NULL && *path != '\0');
1508 1.1 christos
1509 1.1 christos /*
1510 1.1 christos * Determine type of file; only regular files will be
1511 1.1 christos * version renamed, and only if the base file exists
1512 1.1 christos * and either has no size limit or has reached its size limit.
1513 1.1 christos */
1514 1.1 christos if (stat(path, &statbuf) == 0) {
1515 1.3 christos regular_file = S_ISREG(statbuf.st_mode) ? true : false;
1516 1.1 christos /* XXXDCL if not regular_file complain? */
1517 1.1 christos if ((FILE_MAXSIZE(channel) == 0 &&
1518 1.1 christos FILE_VERSIONS(channel) != ISC_LOG_ROLLNEVER) ||
1519 1.1 christos (FILE_MAXSIZE(channel) > 0 &&
1520 1.1 christos statbuf.st_size >= FILE_MAXSIZE(channel)))
1521 1.1 christos roll = regular_file;
1522 1.1 christos } else if (errno == ENOENT) {
1523 1.3 christos regular_file = true;
1524 1.1 christos POST(regular_file);
1525 1.1 christos } else
1526 1.1 christos result = ISC_R_INVALIDFILE;
1527 1.1 christos
1528 1.1 christos /*
1529 1.1 christos * Version control.
1530 1.1 christos */
1531 1.1 christos if (result == ISC_R_SUCCESS && roll) {
1532 1.1 christos if (FILE_VERSIONS(channel) == ISC_LOG_ROLLNEVER)
1533 1.1 christos return (ISC_R_MAXSIZE);
1534 1.1 christos result = isc_logfile_roll(&channel->destination.file);
1535 1.1 christos if (result != ISC_R_SUCCESS) {
1536 1.1 christos if ((channel->flags & ISC_LOG_OPENERR) == 0) {
1537 1.1 christos syslog(LOG_ERR,
1538 1.1 christos "isc_log_open: isc_logfile_roll '%s' "
1539 1.1 christos "failed: %s",
1540 1.1 christos FILE_NAME(channel),
1541 1.1 christos isc_result_totext(result));
1542 1.1 christos channel->flags |= ISC_LOG_OPENERR;
1543 1.1 christos }
1544 1.1 christos return (result);
1545 1.1 christos }
1546 1.1 christos }
1547 1.1 christos
1548 1.1 christos result = isc_stdio_open(path, "a", &FILE_STREAM(channel));
1549 1.1 christos
1550 1.1 christos return (result);
1551 1.1 christos }
1552 1.1 christos
1553 1.3 christos bool
1554 1.1 christos isc_log_wouldlog(isc_log_t *lctx, int level) {
1555 1.1 christos /*
1556 1.1 christos * Try to avoid locking the mutex for messages which can't
1557 1.1 christos * possibly be logged to any channels -- primarily debugging
1558 1.1 christos * messages that the debug level is not high enough to print.
1559 1.1 christos *
1560 1.1 christos * If the level is (mathematically) less than or equal to the
1561 1.1 christos * highest_level, or if there is a dynamic channel and the level is
1562 1.1 christos * less than or equal to the debug level, the main loop must be
1563 1.1 christos * entered to see if the message should really be output.
1564 1.1 christos *
1565 1.1 christos * NOTE: this is UNLOCKED access to the logconfig. However,
1566 1.1 christos * the worst thing that can happen is that a bad decision is made
1567 1.1 christos * about returning without logging, and that's not a big concern,
1568 1.1 christos * because that's a risk anyway if the logconfig is being
1569 1.1 christos * dynamically changed.
1570 1.1 christos */
1571 1.1 christos
1572 1.1 christos if (lctx == NULL || lctx->logconfig == NULL)
1573 1.3 christos return (false);
1574 1.1 christos
1575 1.3 christos return (level <= lctx->logconfig->highest_level ||
1576 1.3 christos (lctx->logconfig->dynamic && level <= lctx->debug_level));
1577 1.1 christos }
1578 1.1 christos
1579 1.1 christos static void
1580 1.1 christos isc_log_doit(isc_log_t *lctx, isc_logcategory_t *category,
1581 1.3 christos isc_logmodule_t *module, int level, bool write_once,
1582 1.1 christos isc_msgcat_t *msgcat, int msgset, int msg,
1583 1.1 christos const char *format, va_list args)
1584 1.1 christos {
1585 1.1 christos int syslog_level;
1586 1.1 christos const char *time_string;
1587 1.1 christos char local_time[64];
1588 1.1 christos char iso8601z_string[64];
1589 1.1 christos char iso8601l_string[64];
1590 1.1 christos char level_string[24];
1591 1.1 christos const char *iformat;
1592 1.1 christos struct stat statbuf;
1593 1.3 christos bool matched = false;
1594 1.3 christos bool printtime, iso8601, utc, printtag, printcolon;
1595 1.3 christos bool printcategory, printmodule, printlevel, buffered;
1596 1.1 christos isc_logconfig_t *lcfg;
1597 1.1 christos isc_logchannel_t *channel;
1598 1.1 christos isc_logchannellist_t *category_channels;
1599 1.1 christos isc_result_t result;
1600 1.1 christos
1601 1.1 christos REQUIRE(lctx == NULL || VALID_CONTEXT(lctx));
1602 1.1 christos REQUIRE(category != NULL);
1603 1.1 christos REQUIRE(module != NULL);
1604 1.1 christos REQUIRE(level != ISC_LOG_DYNAMIC);
1605 1.1 christos REQUIRE(format != NULL);
1606 1.1 christos
1607 1.1 christos /*
1608 1.1 christos * Programs can use libraries that use this logging code without
1609 1.1 christos * wanting to do any logging, thus the log context is allowed to
1610 1.1 christos * be non-existent.
1611 1.1 christos */
1612 1.1 christos if (lctx == NULL)
1613 1.1 christos return;
1614 1.1 christos
1615 1.1 christos REQUIRE(category->id < lctx->category_count);
1616 1.1 christos REQUIRE(module->id < lctx->module_count);
1617 1.1 christos
1618 1.1 christos if (! isc_log_wouldlog(lctx, level))
1619 1.1 christos return;
1620 1.1 christos
1621 1.1 christos if (msgcat != NULL)
1622 1.1 christos iformat = isc_msgcat_get(msgcat, msgset, msg, format);
1623 1.1 christos else
1624 1.1 christos iformat = format;
1625 1.1 christos
1626 1.1 christos local_time[0] = '\0';
1627 1.1 christos iso8601l_string[0] = '\0';
1628 1.1 christos iso8601z_string[0] = '\0';
1629 1.1 christos level_string[0] = '\0';
1630 1.1 christos
1631 1.1 christos LOCK(&lctx->lock);
1632 1.1 christos
1633 1.1 christos lctx->buffer[0] = '\0';
1634 1.1 christos
1635 1.1 christos lcfg = lctx->logconfig;
1636 1.1 christos
1637 1.1 christos category_channels = ISC_LIST_HEAD(lcfg->channellists[category->id]);
1638 1.1 christos
1639 1.1 christos /*
1640 1.1 christos * XXXDCL add duplicate filtering? (To not write multiple times to
1641 1.1 christos * the same source via various channels).
1642 1.1 christos */
1643 1.1 christos do {
1644 1.1 christos /*
1645 1.1 christos * If the channel list end was reached and a match was made,
1646 1.1 christos * everything is finished.
1647 1.1 christos */
1648 1.1 christos if (category_channels == NULL && matched)
1649 1.1 christos break;
1650 1.1 christos
1651 1.1 christos if (category_channels == NULL && ! matched &&
1652 1.1 christos category_channels != ISC_LIST_HEAD(lcfg->channellists[0]))
1653 1.1 christos /*
1654 1.1 christos * No category/module pair was explicitly configured.
1655 1.1 christos * Try the category named "default".
1656 1.1 christos */
1657 1.1 christos category_channels =
1658 1.1 christos ISC_LIST_HEAD(lcfg->channellists[0]);
1659 1.1 christos
1660 1.1 christos if (category_channels == NULL && ! matched)
1661 1.1 christos /*
1662 1.1 christos * No matching module was explicitly configured
1663 1.1 christos * for the category named "default". Use the internal
1664 1.1 christos * default channel.
1665 1.1 christos */
1666 1.1 christos category_channels = &default_channel;
1667 1.1 christos
1668 1.1 christos if (category_channels->module != NULL &&
1669 1.1 christos category_channels->module != module) {
1670 1.1 christos category_channels = ISC_LIST_NEXT(category_channels,
1671 1.1 christos link);
1672 1.1 christos continue;
1673 1.1 christos }
1674 1.1 christos
1675 1.3 christos matched = true;
1676 1.1 christos
1677 1.1 christos channel = category_channels->channel;
1678 1.1 christos category_channels = ISC_LIST_NEXT(category_channels, link);
1679 1.1 christos
1680 1.1 christos if (((channel->flags & ISC_LOG_DEBUGONLY) != 0) &&
1681 1.1 christos lctx->debug_level == 0)
1682 1.1 christos continue;
1683 1.1 christos
1684 1.1 christos if (channel->level == ISC_LOG_DYNAMIC) {
1685 1.1 christos if (lctx->debug_level < level)
1686 1.1 christos continue;
1687 1.1 christos } else if (channel->level < level)
1688 1.1 christos continue;
1689 1.1 christos
1690 1.1 christos if ((channel->flags & ISC_LOG_PRINTTIME) != 0 &&
1691 1.1 christos local_time[0] == '\0')
1692 1.1 christos {
1693 1.1 christos isc_time_t isctime;
1694 1.1 christos
1695 1.1 christos TIME_NOW(&isctime);
1696 1.1 christos
1697 1.1 christos isc_time_formattimestamp(&isctime,
1698 1.1 christos local_time,
1699 1.1 christos sizeof(local_time));
1700 1.1 christos isc_time_formatISO8601ms(&isctime,
1701 1.1 christos iso8601z_string,
1702 1.1 christos sizeof(iso8601z_string));
1703 1.1 christos isc_time_formatISO8601Lms(&isctime,
1704 1.1 christos iso8601l_string,
1705 1.1 christos sizeof(iso8601l_string));
1706 1.1 christos }
1707 1.1 christos
1708 1.1 christos if ((channel->flags & ISC_LOG_PRINTLEVEL) != 0 &&
1709 1.1 christos level_string[0] == '\0') {
1710 1.1 christos if (level < ISC_LOG_CRITICAL)
1711 1.1 christos snprintf(level_string, sizeof(level_string),
1712 1.1 christos isc_msgcat_get(isc_msgcat,
1713 1.1 christos ISC_MSGSET_LOG,
1714 1.1 christos ISC_MSG_LEVEL,
1715 1.1 christos "level %d: "),
1716 1.1 christos level);
1717 1.1 christos else if (level > ISC_LOG_DYNAMIC)
1718 1.1 christos snprintf(level_string, sizeof(level_string),
1719 1.1 christos "%s %d: ", log_level_strings[0],
1720 1.1 christos level);
1721 1.1 christos else
1722 1.1 christos snprintf(level_string, sizeof(level_string),
1723 1.1 christos "%s: ", log_level_strings[-level]);
1724 1.1 christos }
1725 1.1 christos
1726 1.1 christos /*
1727 1.1 christos * Only format the message once.
1728 1.1 christos */
1729 1.1 christos if (lctx->buffer[0] == '\0') {
1730 1.1 christos (void)vsnprintf(lctx->buffer, sizeof(lctx->buffer),
1731 1.1 christos iformat, args);
1732 1.1 christos
1733 1.1 christos /*
1734 1.1 christos * Check for duplicates.
1735 1.1 christos */
1736 1.1 christos if (write_once) {
1737 1.1 christos isc_logmessage_t *message, *next;
1738 1.1 christos isc_time_t oldest;
1739 1.1 christos isc_interval_t interval;
1740 1.1 christos size_t size;
1741 1.1 christos
1742 1.1 christos isc_interval_set(&interval,
1743 1.1 christos lcfg->duplicate_interval, 0);
1744 1.1 christos
1745 1.1 christos /*
1746 1.1 christos * 'oldest' is the age of the oldest messages
1747 1.1 christos * which fall within the duplicate_interval
1748 1.1 christos * range.
1749 1.1 christos */
1750 1.1 christos TIME_NOW(&oldest);
1751 1.1 christos if (isc_time_subtract(&oldest, &interval,
1752 1.1 christos &oldest)
1753 1.1 christos != ISC_R_SUCCESS)
1754 1.1 christos /*
1755 1.1 christos * Can't effectively do the checking
1756 1.1 christos * without having a valid time.
1757 1.1 christos */
1758 1.1 christos message = NULL;
1759 1.1 christos else
1760 1.1 christos message = ISC_LIST_HEAD(lctx->messages);
1761 1.1 christos
1762 1.1 christos while (message != NULL) {
1763 1.1 christos if (isc_time_compare(&message->time,
1764 1.1 christos &oldest) < 0) {
1765 1.1 christos /*
1766 1.1 christos * This message is older
1767 1.1 christos * than the duplicate_interval,
1768 1.1 christos * so it should be dropped from
1769 1.1 christos * the history.
1770 1.1 christos *
1771 1.1 christos * Setting the interval to be
1772 1.1 christos * to be longer will obviously
1773 1.1 christos * not cause the expired
1774 1.1 christos * message to spring back into
1775 1.1 christos * existence.
1776 1.1 christos */
1777 1.1 christos next = ISC_LIST_NEXT(message,
1778 1.1 christos link);
1779 1.1 christos
1780 1.1 christos ISC_LIST_UNLINK(lctx->messages,
1781 1.1 christos message, link);
1782 1.1 christos
1783 1.1 christos isc_mem_put(lctx->mctx,
1784 1.1 christos message,
1785 1.1 christos sizeof(*message) + 1 +
1786 1.1 christos strlen(message->text));
1787 1.1 christos
1788 1.1 christos message = next;
1789 1.1 christos continue;
1790 1.1 christos }
1791 1.1 christos
1792 1.1 christos /*
1793 1.1 christos * This message is in the duplicate
1794 1.1 christos * filtering interval ...
1795 1.1 christos */
1796 1.1 christos if (strcmp(lctx->buffer, message->text)
1797 1.1 christos == 0) {
1798 1.1 christos /*
1799 1.1 christos * ... and it is a duplicate.
1800 1.1 christos * Unlock the mutex and
1801 1.1 christos * get the hell out of Dodge.
1802 1.1 christos */
1803 1.1 christos UNLOCK(&lctx->lock);
1804 1.1 christos return;
1805 1.1 christos }
1806 1.1 christos
1807 1.1 christos message = ISC_LIST_NEXT(message, link);
1808 1.1 christos }
1809 1.1 christos
1810 1.1 christos /*
1811 1.1 christos * It wasn't in the duplicate interval,
1812 1.1 christos * so add it to the message list.
1813 1.1 christos */
1814 1.1 christos size = sizeof(isc_logmessage_t) +
1815 1.1 christos strlen(lctx->buffer) + 1;
1816 1.1 christos message = isc_mem_get(lctx->mctx, size);
1817 1.1 christos if (message != NULL) {
1818 1.1 christos /*
1819 1.1 christos * Put the text immediately after
1820 1.1 christos * the struct. The strcpy is safe.
1821 1.1 christos */
1822 1.1 christos message->text = (char *)(message + 1);
1823 1.1 christos size -= sizeof(isc_logmessage_t);
1824 1.1 christos strlcpy(message->text, lctx->buffer,
1825 1.1 christos size);
1826 1.1 christos
1827 1.1 christos TIME_NOW(&message->time);
1828 1.1 christos
1829 1.1 christos ISC_LINK_INIT(message, link);
1830 1.1 christos ISC_LIST_APPEND(lctx->messages,
1831 1.1 christos message, link);
1832 1.1 christos }
1833 1.1 christos }
1834 1.1 christos }
1835 1.1 christos
1836 1.3 christos utc = ((channel->flags & ISC_LOG_UTC) != 0);
1837 1.3 christos iso8601 = ((channel->flags & ISC_LOG_ISO8601) != 0);
1838 1.3 christos printtime = ((channel->flags & ISC_LOG_PRINTTIME) != 0);
1839 1.3 christos printtag = ((channel->flags &
1840 1.3 christos (ISC_LOG_PRINTTAG|ISC_LOG_PRINTPREFIX)) != 0 &&
1841 1.3 christos lcfg->tag != NULL);
1842 1.3 christos printcolon = ((channel->flags & ISC_LOG_PRINTTAG) != 0 &&
1843 1.3 christos lcfg->tag != NULL);
1844 1.3 christos printcategory = ((channel->flags & ISC_LOG_PRINTCATEGORY) != 0);
1845 1.3 christos printmodule = ((channel->flags & ISC_LOG_PRINTMODULE) != 0);
1846 1.3 christos printlevel = ((channel->flags & ISC_LOG_PRINTLEVEL) != 0);
1847 1.3 christos buffered = ((channel->flags & ISC_LOG_BUFFERED) != 0);
1848 1.1 christos
1849 1.1 christos if (printtime) {
1850 1.1 christos if (iso8601) {
1851 1.1 christos if (utc) {
1852 1.1 christos time_string = iso8601z_string;
1853 1.1 christos } else {
1854 1.1 christos time_string = iso8601l_string;
1855 1.1 christos }
1856 1.1 christos } else {
1857 1.1 christos time_string = local_time;
1858 1.1 christos }
1859 1.1 christos } else
1860 1.1 christos time_string = "";
1861 1.1 christos
1862 1.1 christos switch (channel->type) {
1863 1.1 christos case ISC_LOG_TOFILE:
1864 1.1 christos if (FILE_MAXREACHED(channel)) {
1865 1.1 christos /*
1866 1.1 christos * If the file can be rolled, OR
1867 1.1 christos * If the file no longer exists, OR
1868 1.1 christos * If the file is less than the maximum size,
1869 1.1 christos * (such as if it had been renamed and
1870 1.1 christos * a new one touched, or it was truncated
1871 1.1 christos * in place)
1872 1.1 christos * ... then close it to trigger reopening.
1873 1.1 christos */
1874 1.1 christos if (FILE_VERSIONS(channel) !=
1875 1.1 christos ISC_LOG_ROLLNEVER ||
1876 1.1 christos (stat(FILE_NAME(channel), &statbuf) != 0 &&
1877 1.1 christos errno == ENOENT) ||
1878 1.1 christos statbuf.st_size < FILE_MAXSIZE(channel)) {
1879 1.1 christos (void)fclose(FILE_STREAM(channel));
1880 1.1 christos FILE_STREAM(channel) = NULL;
1881 1.3 christos FILE_MAXREACHED(channel) = false;
1882 1.1 christos } else
1883 1.1 christos /*
1884 1.1 christos * Eh, skip it.
1885 1.1 christos */
1886 1.1 christos break;
1887 1.1 christos }
1888 1.1 christos
1889 1.1 christos if (FILE_STREAM(channel) == NULL) {
1890 1.1 christos result = isc_log_open(channel);
1891 1.1 christos if (result != ISC_R_SUCCESS &&
1892 1.1 christos result != ISC_R_MAXSIZE &&
1893 1.1 christos (channel->flags & ISC_LOG_OPENERR) == 0) {
1894 1.1 christos syslog(LOG_ERR,
1895 1.1 christos "isc_log_open '%s' failed: %s",
1896 1.1 christos FILE_NAME(channel),
1897 1.1 christos isc_result_totext(result));
1898 1.1 christos channel->flags |= ISC_LOG_OPENERR;
1899 1.1 christos }
1900 1.1 christos if (result != ISC_R_SUCCESS)
1901 1.1 christos break;
1902 1.1 christos channel->flags &= ~ISC_LOG_OPENERR;
1903 1.1 christos }
1904 1.1 christos /* FALLTHROUGH */
1905 1.1 christos
1906 1.1 christos case ISC_LOG_TOFILEDESC:
1907 1.1 christos fprintf(FILE_STREAM(channel),
1908 1.1 christos "%s%s%s%s%s%s%s%s%s%s\n",
1909 1.1 christos printtime ? time_string : "",
1910 1.1 christos printtime ? " " : "",
1911 1.1 christos printtag ? lcfg->tag : "",
1912 1.1 christos printcolon ? ": " : "",
1913 1.1 christos printcategory ? category->name : "",
1914 1.1 christos printcategory ? ": " : "",
1915 1.1 christos printmodule ? (module != NULL ? module->name
1916 1.1 christos : "no_module")
1917 1.1 christos : "",
1918 1.1 christos printmodule ? ": " : "",
1919 1.1 christos printlevel ? level_string : "",
1920 1.1 christos lctx->buffer);
1921 1.1 christos
1922 1.1 christos if (!buffered)
1923 1.1 christos fflush(FILE_STREAM(channel));
1924 1.1 christos
1925 1.1 christos /*
1926 1.1 christos * If the file now exceeds its maximum size
1927 1.1 christos * threshold, note it so that it will not be logged
1928 1.1 christos * to any more.
1929 1.1 christos */
1930 1.1 christos if (FILE_MAXSIZE(channel) > 0) {
1931 1.1 christos INSIST(channel->type == ISC_LOG_TOFILE);
1932 1.1 christos
1933 1.1 christos /* XXXDCL NT fstat/fileno */
1934 1.1 christos /* XXXDCL complain if fstat fails? */
1935 1.1 christos if (fstat(fileno(FILE_STREAM(channel)),
1936 1.1 christos &statbuf) >= 0 &&
1937 1.1 christos statbuf.st_size > FILE_MAXSIZE(channel))
1938 1.3 christos FILE_MAXREACHED(channel) = true;
1939 1.1 christos }
1940 1.1 christos
1941 1.1 christos break;
1942 1.1 christos
1943 1.1 christos case ISC_LOG_TOSYSLOG:
1944 1.1 christos if (level > 0)
1945 1.1 christos syslog_level = LOG_DEBUG;
1946 1.1 christos else if (level < ISC_LOG_CRITICAL)
1947 1.1 christos syslog_level = LOG_CRIT;
1948 1.1 christos else
1949 1.1 christos syslog_level = syslog_map[-level];
1950 1.1 christos
1951 1.1 christos (void)syslog(FACILITY(channel) | syslog_level,
1952 1.1 christos "%s%s%s%s%s%s%s%s%s%s",
1953 1.1 christos printtime ? time_string : "",
1954 1.1 christos printtime ? " " : "",
1955 1.1 christos printtag ? lcfg->tag : "",
1956 1.1 christos printcolon ? ": " : "",
1957 1.1 christos printcategory ? category->name : "",
1958 1.1 christos printcategory ? ": " : "",
1959 1.1 christos printmodule ? (module != NULL
1960 1.1 christos ? module->name
1961 1.1 christos : "no_module")
1962 1.1 christos : "",
1963 1.1 christos printmodule ? ": " : "",
1964 1.1 christos printlevel ? level_string : "",
1965 1.1 christos lctx->buffer);
1966 1.1 christos break;
1967 1.1 christos
1968 1.1 christos case ISC_LOG_TONULL:
1969 1.1 christos break;
1970 1.1 christos
1971 1.1 christos }
1972 1.1 christos
1973 1.1 christos } while (1);
1974 1.1 christos
1975 1.1 christos UNLOCK(&lctx->lock);
1976 1.1 christos }
1977