ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/lib/AnyEvent/Log.pm
(Generate patch)

Comparing AnyEvent/lib/AnyEvent/Log.pm (file contents):
Revision 1.15 by root, Sat Aug 20 02:16:59 2011 UTC vs.
Revision 1.62 by root, Sat Sep 28 11:12:56 2013 UTC

2 2
3AnyEvent::Log - simple logging "framework" 3AnyEvent::Log - simple logging "framework"
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 # simple use 7Simple uses:
8
8 use AnyEvent; 9 use AnyEvent;
9 10
10 AE::log debug => "hit my knee"; 11 AE::log fatal => "No config found, cannot continue!"; # never returns
11 AE::log warn => "it's a bit too hot"; 12 AE::log alert => "The battery died!";
12 AE::log error => "the flag was false!"; 13 AE::log crit => "The battery temperature is too hot!";
13 AE::log fatal => "the bit toggled! run!"; 14 AE::log error => "Division by zero attempted.";
15 AE::log warn => "Couldn't delete the file.";
16 AE::log note => "Wanted to create config, but config already exists.";
17 AE::log info => "File soandso successfully deleted.";
18 AE::log debug => "the function returned 3";
19 AE::log trace => "going to call function abc";
14 20
15 # "complex" use 21Log level overview:
22
23 LVL NAME SYSLOG PERL NOTE
24 1 fatal emerg exit system unusable, aborts program!
25 2 alert failure in primary system
26 3 critical crit failure in backup system
27 4 error err die non-urgent program errors, a bug
28 5 warn warning possible problem, not necessarily error
29 6 note notice unusual conditions
30 7 info normal messages, no action required
31 8 debug debugging messages for development
32 9 trace copious tracing output
33
34"Complex" uses (for speed sensitive code, e.g. trace/debug messages):
35
16 use AnyEvent::Log; 36 use AnyEvent::Log;
17 37
18 my $tracer = AnyEvent::Log::logger trace => \$my $trace; 38 my $tracer = AnyEvent::Log::logger trace => \$my $trace;
19 39
20 $tracer->("i am here") if $trace; 40 $tracer->("i am here") if $trace;
21 $tracer->(sub { "lots of data: " . Dumper $self }) if $trace; 41 $tracer->(sub { "lots of data: " . Dumper $self }) if $trace;
22 42
23 # configuration 43Configuration (also look at the EXAMPLES section):
24 44
25 # set logging for this package to maximum 45 # set logging for the current package to errors and higher only
26 AnyEvent::Log::ctx->level ("all"); 46 AnyEvent::Log::ctx->level ("error");
27 47
28 # set logging globally to anything below debug 48 # set logging level to suppress anything below "notice"
29 (AnyEvent::Log::ctx "")->level ("notice"); 49 $AnyEvent::Log::FILTER->level ("notice");
30 50
31 # see also EXAMPLES, below 51 # send all critical and higher priority messages to syslog,
32 52 # regardless of (most) other settings
33 # disable logging for package "AnyEvent" and all packages below it 53 $AnyEvent::Log::COLLECT->attach (new AnyEvent::Log::Ctx
34 AnyEvent->AnyEvent::Log::ctx->level (0); 54 level => "critical",
35 55 log_to_syslog => "user",
36 # log everything below debug to a file, for the whole program 56 );
37 my $ctx = AnyEvent::Log::ctx;
38 $ctx->log_cb (sub { print FILE shift; 0 });
39 (AnyEvent::Log::ctx "")->add ($ctx);
40 57
41=head1 DESCRIPTION 58=head1 DESCRIPTION
42 59
43This module implements a relatively simple "logging framework". It doesn't 60This module implements a relatively simple "logging framework". It doesn't
44attempt to be "the" logging solution or even "a" logging solution for 61attempt to be "the" logging solution or even "a" logging solution for
45AnyEvent - AnyEvent simply creates logging messages internally, and this 62AnyEvent - AnyEvent simply creates logging messages internally, and this
46module more or less exposes the mechanism, with some extra spiff to allow 63module more or less exposes the mechanism, with some extra spiff to allow
47using it from other modules as well. 64using it from other modules as well.
48 65
49Remember that the default verbosity level is C<0>, so nothing will be 66Remember that the default verbosity level is C<4> (C<error>), so only
50logged, unless you set C<PERL_ANYEVENT_VERBOSE> to a higher number before 67errors and more important messages will be logged, unless you set
51starting your program, or change the logging level at runtime with 68C<PERL_ANYEVENT_VERBOSE> to a higher number before starting your program
52something like: 69(C<AE_VERBOSE=5> is recommended during development), or change the logging
70level at runtime with something like:
53 71
54 use AnyEvent; 72 use AnyEvent::Log;
55 (AnyEvent::Log::ctx "")->level ("info"); 73 $AnyEvent::Log::FILTER->level ("info");
56 74
57The design goal behind this module was to keep it simple (and small), 75The design goal behind this module was to keep it simple (and small),
58but make it powerful enough to be potentially useful for any module, and 76but make it powerful enough to be potentially useful for any module,
59extensive enough for the most common tasks, such as logging to multiple 77and extensive enough for the most common tasks, such as logging to
60targets, or being able to log into a database. 78multiple targets, or being able to log into a database.
61 79
80The module is also usable before AnyEvent itself is initialised, in which
81case some of the functionality might be reduced.
82
62The amount of documentation might indicate otherwise, but the module is 83The amount of documentation might indicate otherwise, but the runtime part
63still just 240 lines or so. 84of the module is still just below 300 lines of code.
85
86=head1 LOGGING LEVELS
87
88Logging levels in this module range from C<1> (highest priority) to C<9>
89(lowest priority). Note that the lowest numerical value is the highest
90priority, so when this document says "higher priority" it means "lower
91numerical value".
92
93Instead of specifying levels by name you can also specify them by aliases:
94
95 LVL NAME SYSLOG PERL NOTE
96 1 fatal emerg exit system unusable, aborts program!
97 2 alert failure in primary system
98 3 critical crit failure in backup system
99 4 error err die non-urgent program errors, a bug
100 5 warn warning possible problem, not necessarily error
101 6 note notice unusual conditions
102 7 info normal messages, no action required
103 8 debug debugging messages for development
104 9 trace copious tracing output
105
106As you can see, some logging levels have multiple aliases - the first one
107is the "official" name, the second one the "syslog" name (if it differs)
108and the third one the "perl" name, suggesting (only!) that you log C<die>
109messages at C<error> priority. The NOTE column tries to provide some
110rationale on how to chose a logging level.
111
112As a rough guideline, levels 1..3 are primarily meant for users of the
113program (admins, staff), and are the only ones logged to STDERR by
114default. Levels 4..6 are meant for users and developers alike, while
115levels 7..9 are usually meant for developers.
116
117You can normally only log a message once at highest priority level (C<1>,
118C<fatal>), because logging a fatal message will also quit the program - so
119use it sparingly :)
120
121For example, a program that finds an unknown switch on the commandline
122might well use a fatal logging level to tell users about it - the "system"
123in this case would be the program, or module.
124
125Some methods also offer some extra levels, such as C<0>, C<off>, C<none>
126or C<all> - these are only valid for the methods that documented them.
64 127
65=head1 LOGGING FUNCTIONS 128=head1 LOGGING FUNCTIONS
66 129
67These functions allow you to log messages. They always use the caller's 130The following functions allow you to log messages. They always use the
68package as a "logging module/source". Also, the main logging function is 131caller's package as a "logging context". Also, the main logging function,
69callable as C<AnyEvent::log> or C<AE::log> when the C<AnyEvent> module is 132C<log>, is aliased to C<AnyEvent::log> and C<AE::log> when the C<AnyEvent>
70loaded. 133module is loaded.
71 134
72=over 4 135=over 4
73 136
74=cut 137=cut
75 138
76package AnyEvent::Log; 139package AnyEvent::Log;
77 140
78use Carp (); 141use Carp ();
79use POSIX (); 142use POSIX ();
80 143
144# layout of a context
145# 0 1 2 3 4, 5
146# [$title, $level, %$slaves, &$logcb, &$fmtcb, $cap]
147
81use AnyEvent (); BEGIN { AnyEvent::common_sense } 148use AnyEvent (); BEGIN { AnyEvent::common_sense }
82use AnyEvent::Util (); 149#use AnyEvent::Util (); need to load this in a delayed fashion, as it uses AE::log
83 150
84our $VERSION = $AnyEvent::VERSION; 151our $VERSION = $AnyEvent::VERSION;
85 152
153our ($COLLECT, $FILTER, $LOG);
154
86our ($now_int, $now_str1, $now_str2); 155our ($now_int, $now_str1, $now_str2);
87 156
88# Format Time, not public - yet? 157# Format Time, not public - yet?
89sub ft($) { 158sub format_time($) {
90 my $i = int $_[0]; 159 my $i = int $_[0];
91 my $f = sprintf "%06d", 1e6 * ($_[0] - $i); 160 my $f = sprintf "%06d", 1e6 * ($_[0] - $i);
92 161
93 ($now_int, $now_str1, $now_str2) = ($i, split /\x01/, POSIX::strftime "%Y-%m-%d %H:%M:%S.\x01 %z", localtime $i) 162 ($now_int, $now_str1, $now_str2) = ($i, split /\x01/, POSIX::strftime "%Y-%m-%d %H:%M:%S.\x01 %z", localtime $i)
94 if $now_int != $i; 163 if $now_int != $i;
95 164
96 "$now_str1$f$now_str2" 165 "$now_str1$f$now_str2"
97} 166}
98 167
99our %CTX; # all logging contexts 168our %CTX; # all package contexts
100 169
101# creates a default package context object for the given package 170# creates a default package context object for the given package
102sub _pkg_ctx($) { 171sub _pkg_ctx($) {
103 my $ctx = bless [$_[0], (1 << 10) - 1 - 1, {}], "AnyEvent::Log::Ctx"; 172 my $ctx = bless [$_[0], (1 << 10) - 1 - 1, {}], "AnyEvent::Log::Ctx";
104 173
105 # link "parent" package 174 # link "parent" package
106 my $pkg = $_[0] =~ /^(.+)::/ ? $1 : "AE::Log::Top"; 175 my $parent = $_[0] =~ /^(.+)::/
176 ? $CTX{$1} ||= &_pkg_ctx ("$1")
177 : $COLLECT;
107 178
108 $pkg = $CTX{$pkg} ||= &_pkg_ctx ($pkg);
109 $ctx->[2]{$pkg+0} = $pkg; 179 $ctx->[2]{$parent+0} = $parent;
110 180
111 $ctx 181 $ctx
112} 182}
113 183
114=item AnyEvent::Log::log $level, $msg[, @args] 184=item AnyEvent::Log::log $level, $msg[, @args]
115 185
116Requests logging of the given C<$msg> with the given log level (1..9). 186Requests logging of the given C<$msg> with the given log level, and
117You can also use the following strings as log level: C<fatal> (1), 187returns true if the message was logged I<somewhere>.
118C<alert> (2), C<critical> (3), C<error> (4), C<warn> (5), C<note> (6),
119C<info> (7), C<debug> (8), C<trace> (9).
120 188
121For C<fatal> log levels, the program will abort. 189For loglevel C<fatal>, the program will abort.
122 190
123If only a C<$msg> is given, it is logged as-is. With extra C<@args>, the 191If only a C<$msg> is given, it is logged as-is. With extra C<@args>, the
124C<$msg> is interpreted as an sprintf format string. 192C<$msg> is interpreted as an sprintf format string.
125 193
126The C<$msg> should not end with C<\n>, but may if that is convenient for 194The C<$msg> should not end with C<\n>, but may if that is convenient for
129Last not least, C<$msg> might be a code reference, in which case it is 197Last not least, C<$msg> might be a code reference, in which case it is
130supposed to return the message. It will be called only then the message 198supposed to return the message. It will be called only then the message
131actually gets logged, which is useful if it is costly to create the 199actually gets logged, which is useful if it is costly to create the
132message in the first place. 200message in the first place.
133 201
202This function takes care of saving and restoring C<$!> and C<$@>, so you
203don't have to.
204
134Whether the given message will be logged depends on the maximum log level 205Whether the given message will be logged depends on the maximum log level
135and the caller's package. 206and the caller's package. The return value can be used to ensure that
207messages or not "lost" - for example, when L<AnyEvent::Debug> detects a
208runtime error it tries to log it at C<die> level, but if that message is
209lost it simply uses warn.
136 210
137Note that you can (and should) call this function as C<AnyEvent::log> or 211Note that you can (and should) call this function as C<AnyEvent::log> or
138C<AE::log>, without C<use>-ing this module if possible (i.e. you don't 212C<AE::log>, without C<use>-ing this module if possible (i.e. you don't
139need any additional functionality), as those functions will load the 213need any additional functionality), as those functions will load the
140logging module on demand only. They are also much shorter to write. 214logging module on demand only. They are also much shorter to write.
157 231
158=cut 232=cut
159 233
160# also allow syslog equivalent names 234# also allow syslog equivalent names
161our %STR2LEVEL = ( 235our %STR2LEVEL = (
162 fatal => 1, emerg => 1, 236 fatal => 1, emerg => 1, exit => 1,
163 alert => 2, 237 alert => 2,
164 critical => 3, crit => 3, 238 critical => 3, crit => 3,
165 error => 4, err => 4, 239 error => 4, err => 4, die => 4,
166 warn => 5, warning => 5, 240 warn => 5, warning => 5,
167 note => 6, notice => 6, 241 note => 6, notice => 6,
168 info => 7, 242 info => 7,
169 debug => 8, 243 debug => 8,
170 trace => 9, 244 trace => 9,
171); 245);
172 246
173sub now () { time } 247our $TIME_EXACT;
248
249sub exact_time($) {
250 $TIME_EXACT = shift;
251 *_ts = $AnyEvent::MODEL
252 ? $TIME_EXACT ? \&AE::now : \&AE::time
253 : sub () { $TIME_EXACT ? do { require Time::HiRes; Time::HiRes::time () } : time };
254}
255
256BEGIN {
257 exact_time 0;
258}
174 259
175AnyEvent::post_detect { 260AnyEvent::post_detect {
176 *now = \&AE::now; 261 exact_time $TIME_EXACT;
177}; 262};
178 263
179our @LEVEL2STR = qw(0 fatal alert crit error warn note info debug trace); 264our @LEVEL2STR = qw(0 fatal alert crit error warn note info debug trace);
180 265
181# time, ctx, level, msg 266# time, ctx, level, msg
182sub _format($$$$) { 267sub default_format($$$$) {
183 my $ts = ft $_[0]; 268 my $ts = format_time $_[0];
184 my $ct = " "; 269 my $ct = " ";
185 270
186 my @res; 271 my @res;
187 272
188 for (split /\n/, sprintf "%-5s %s: %s", $LEVEL2STR[$_[2]], $_[1][0], $_[3]) { 273 for (split /\n/, sprintf "%-5s %s: %s", $LEVEL2STR[$_[2]], $_[1][0], $_[3]) {
191 } 276 }
192 277
193 join "", @res 278 join "", @res
194} 279}
195 280
281sub fatal_exit() {
282 exit 1;
283}
284
196sub _log { 285sub _log {
197 my ($ctx, $level, $format, @args) = @_; 286 my ($ctx, $level, $format, @args) = @_;
198 287
199 $level = $level > 0 && $level <= 9 288 $level = $level > 0 && $level <= 9
200 ? $level+0 289 ? $level+0
201 : $STR2LEVEL{$level} || Carp::croak "$level: not a valid logging level, caught"; 290 : $STR2LEVEL{$level} || Carp::croak "$level: not a valid logging level, caught";
202 291
203 my $mask = 1 << $level; 292 my $mask = 1 << $level;
204 293
205 my (%seen, @ctx, $now, $fmt); 294 my ($success, %seen, @ctx, $now, @fmt);
206 295
207 do 296 do
208 { 297 {
209 # skip if masked 298 # if !ref, then it's a level number
299 if (!ref $ctx) {
300 $level = $ctx;
210 if ($ctx->[1] & $mask && !$seen{$ctx+0}++) { 301 } elsif ($ctx->[1] & $mask and !$seen{$ctx+0}++) {
302 # logging/recursing into this context
303
304 # level cap
305 if ($ctx->[5] > $level) {
306 push @ctx, $level; # restore level when going up in tree
307 $level = $ctx->[5];
308 }
309
310 # log if log cb
211 if ($ctx->[3]) { 311 if ($ctx->[3]) {
212 # logging target found 312 # logging target found
313
314 local ($!, $@);
213 315
214 # now get raw message, unless we have it already 316 # now get raw message, unless we have it already
215 unless ($now) { 317 unless ($now) {
216 $format = $format->() if ref $format; 318 $format = $format->() if ref $format;
217 $format = sprintf $format, @args if @args; 319 $format = sprintf $format, @args if @args;
218 $format =~ s/\n$//; 320 $format =~ s/\n$//;
219 $now = AE::now; 321 $now = _ts;
220 }; 322 };
221 323
222 # format msg 324 # format msg
223 my $str = $ctx->[4] 325 my $str = $ctx->[4]
224 ? $ctx->[4]($now, $_[0], $level, $format) 326 ? $ctx->[4]($now, $_[0], $level, $format)
225 : $fmt ||= _format $now, $_[0], $level, $format; 327 : ($fmt[$level] ||= default_format $now, $_[0], $level, $format);
226 328
329 $success = 1;
330
227 $ctx->[3]($str); 331 $ctx->[3]($str)
332 or push @ctx, values %{ $ctx->[2] }; # not consumed - propagate
333 } else {
334 push @ctx, values %{ $ctx->[2] }; # not masked - propagate
228 } 335 }
229
230 # not masked, not consumed - propagate to parent contexts
231 push @ctx, values %{ $ctx->[2] };
232 } 336 }
233 } 337 }
234 while $ctx = pop @ctx; 338 while $ctx = pop @ctx;
235 339
236 exit 1 if $level <= 1; 340 fatal_exit if $level <= 1;
341
342 $success
237} 343}
238 344
239sub log($$;@) { 345sub log($$;@) {
240 _log 346 _log
241 $CTX{ (caller)[0] } ||= _pkg_ctx +(caller)[0], 347 $CTX{ (caller)[0] } ||= _pkg_ctx +(caller)[0],
242 @_; 348 @_;
243} 349}
244 350
245*AnyEvent::log = *AE::log = \&log;
246
247=item $logger = AnyEvent::Log::logger $level[, \$enabled] 351=item $logger = AnyEvent::Log::logger $level[, \$enabled]
248 352
249Creates a code reference that, when called, acts as if the 353Creates a code reference that, when called, acts as if the
250C<AnyEvent::Log::log> function was called at this point with the givne 354C<AnyEvent::Log::log> function was called at this point with the given
251level. C<$logger> is passed a C<$msg> and optional C<@args>, just as with 355level. C<$logger> is passed a C<$msg> and optional C<@args>, just as with
252the C<AnyEvent::Log::log> function: 356the C<AnyEvent::Log::log> function:
253 357
254 my $debug_log = AnyEvent::Log::logger "debug"; 358 my $debug_log = AnyEvent::Log::logger "debug";
255 359
280 # and later in your program 384 # and later in your program
281 $debug_log->("yo, stuff here") if $debug; 385 $debug_log->("yo, stuff here") if $debug;
282 386
283 $debug and $debug_log->("123"); 387 $debug and $debug_log->("123");
284 388
285Note: currently the enabled var is always true - that will be fixed in a
286future version :)
287
288=cut 389=cut
289 390
290our %LOGGER; 391our %LOGGER;
291 392
292# re-assess logging status for all loggers 393# re-assess logging status for all loggers
293sub _reassess { 394sub _reassess {
395 local $SIG{__DIE__};
396 my $die = sub { die };
397
294 for (@_ ? $LOGGER{$_[0]} : values %LOGGER) { 398 for (@_ ? $LOGGER{$_[0]} : values %LOGGER) {
295 my ($ctx, $level, $renabled) = @$_; 399 my ($ctx, $level, $renabled) = @$_;
296 400
297 # to detect whether a message would be logged, we # actually 401 # to detect whether a message would be logged, we actually
298 # try to log one and die. this isn't fast, but we can be 402 # try to log one and die. this isn't fast, but we can be
299 # sure that the logging decision is correct :) 403 # sure that the logging decision is correct :)
300 404
301 $$renabled = !eval { 405 $$renabled = !eval {
302 local $SIG{__DIE__};
303
304 _log $ctx, $level, sub { die }; 406 _log $ctx, $level, $die;
305 407
306 1 408 1
307 }; 409 };
308
309 $$renabled = 1; # TODO
310 } 410 }
311} 411}
312 412
313sub _logger { 413sub _logger {
314 my ($ctx, $level, $renabled) = @_; 414 my ($ctx, $level, $renabled) = @_;
319 419
320 $LOGGER{$logger+0} = $logger; 420 $LOGGER{$logger+0} = $logger;
321 421
322 _reassess $logger+0; 422 _reassess $logger+0;
323 423
424 require AnyEvent::Util unless $AnyEvent::Util::VERSION;
324 my $guard = AnyEvent::Util::guard { 425 my $guard = AnyEvent::Util::guard (sub {
325 # "clean up" 426 # "clean up"
326 delete $LOGGER{$logger+0}; 427 delete $LOGGER{$logger+0};
327 }; 428 });
328 429
329 sub { 430 sub {
330 $guard if 0; # keep guard alive, but don't cause runtime overhead 431 $guard if 0; # keep guard alive, but don't cause runtime overhead
331 432
332 _log $ctx, $level, @_ 433 _log $ctx, $level, @_
337sub logger($;$) { 438sub logger($;$) {
338 _logger 439 _logger
339 $CTX{ (caller)[0] } ||= _pkg_ctx +(caller)[0], 440 $CTX{ (caller)[0] } ||= _pkg_ctx +(caller)[0],
340 @_ 441 @_
341} 442}
443
444=item AnyEvent::Log::exact_time $on
445
446By default, C<AnyEvent::Log> will use C<AE::now>, i.e. the cached
447eventloop time, for the log timestamps. After calling this function with a
448true value it will instead resort to C<AE::time>, i.e. fetch the current
449time on each log message. This only makes a difference for event loops
450that actually cache the time (such as L<EV> or L<AnyEvent::Loop>).
451
452This setting can be changed at any time by calling this function.
453
454Since C<AnyEvent::Log> has to work even before the L<AnyEvent> has been
455initialised, this switch will also decide whether to use C<CORE::time> or
456C<Time::HiRes::time> when logging a message before L<AnyEvent> becomes
457available.
458
459=item AnyEvent::Log::format_time $timestamp
460
461Formats a timestamp as returned by C<< AnyEvent->now >> or C<<
462AnyEvent->time >> or many other functions in the same way as
463C<AnyEvent::Log> does.
464
465In your main program (as opposed to in your module) you can override
466the default timestamp display format by loading this module and then
467redefining this function.
468
469Most commonly, this function can be used in formatting callbacks.
470
471=item AnyEvent::Log::default_format $time, $ctx, $level, $msg
472
473Format a log message using the given timestamp, logging context, log level
474and log message.
475
476This is the formatting function used to format messages when no custom
477function is provided.
478
479In your main program (as opposed to in your module) you can override the
480default message format by loading this module and then redefining this
481function.
482
483=item AnyEvent::Log::fatal_exit
484
485This is the function that is called after logging a C<fatal> log
486message. It must not return.
487
488The default implementation simpl calls C<exit 1>.
489
490In your main program (as opposed to in your module) you can override
491the fatal exit function by loading this module and then redefining this
492function. Make sure you don't return.
342 493
343=back 494=back
344 495
345=head1 LOGGING CONTEXTS 496=head1 LOGGING CONTEXTS
346 497
359timestamp, context, level and string message and formats it in the way 510timestamp, context, level and string message and formats it in the way
360it should be logged) and a logging callback (which is responsible for 511it should be logged) and a logging callback (which is responsible for
361actually logging the formatted message and telling C<AnyEvent::Log> 512actually logging the formatted message and telling C<AnyEvent::Log>
362whether it has consumed the message, or whether it should be propagated). 513whether it has consumed the message, or whether it should be propagated).
363 514
364For propagation, a context can have any number of attached I<parent 515For propagation, a context can have any number of attached I<slave
365contexts>. Any message that is neither masked by the logging mask nor 516contexts>. Any message that is neither masked by the logging mask nor
366masked by the logging callback returning true will be passed to all parent 517masked by the logging callback returning true will be passed to all slave
367contexts. 518contexts.
368 519
369Each call to a logging function will log the message at most once per 520Each call to a logging function will log the message at most once per
370context, so it does not matter (much) if there are cycles or if the 521context, so it does not matter (much) if there are cycles or if the
371message can arrive at the same context via multiple paths. 522message can arrive at the same context via multiple paths.
375By default, all logging contexts have an full set of log levels ("all"), a 526By default, all logging contexts have an full set of log levels ("all"), a
376disabled logging callback and the default formatting callback. 527disabled logging callback and the default formatting callback.
377 528
378Package contexts have the package name as logging title by default. 529Package contexts have the package name as logging title by default.
379 530
380They have exactly one parent - the context of the "parent" package. The 531They have exactly one slave - the context of the "parent" package. The
381parent package is simply defined to be the package name without the last 532parent package is simply defined to be the package name without the last
382component, i.e. C<AnyEvent::Debug::Wrapped> becomes C<AnyEvent::Debug>, 533component, i.e. C<AnyEvent::Debug::Wrapped> becomes C<AnyEvent::Debug>,
383and C<AnyEvent> becomes ... C<AnyEvent::Log::Top> which is the 534and C<AnyEvent> becomes ... C<$AnyEvent::Log::COLLECT> which is the
384exception of the rule - just like the parent of any package name in 535exception of the rule - just like the "parent" of any single-component
385Perl is C<main>, the default parent of any top-level package context is 536package name in Perl is C<main>, the default slave of any top-level
386C<AnyEvent::Log::Top>. 537package context is C<$AnyEvent::Log::COLLECT>.
387 538
388Since perl packages form only an approximate hierarchy, this parent 539Since perl packages form only an approximate hierarchy, this slave
389context can of course be removed. 540context can of course be removed.
390 541
391All other (anonymous) contexts have no parents and an empty title by 542All other (anonymous) contexts have no slaves and an empty title by
392default. 543default.
393 544
394When the module is loaded it creates the default context called 545When the module is loaded it creates the C<$AnyEvent::Log::LOG> logging
395C<AnyEvent::Log::Default> (also stored in C<$AnyEvent::Log::Default>), 546context that simply logs everything via C<warn>, without propagating
396which simply logs everything via C<warn> and doesn't propagate anything
397anywhere by default. The purpose of the default context is to provide 547anything anywhere by default. The purpose of this context is to provide
398a convenient place to override the global logging target or to attach 548a convenient place to override the global logging target or to attach
399additional log targets. It's not meant for filtering. 549additional log targets. It's not meant for filtering.
400 550
401It then creates the root context called C<AnyEvent::Log::Root> (also 551It then creates the C<$AnyEvent::Log::FILTER> context whose
402stored in C<$AnyEvent::Log::Root>) and sets its log level set to all 552purpose is to suppress all messages with priority higher
403levels up to the one specified by C<$ENV{PERL_ANYEVENT_VERBOSE}>. It 553than C<$ENV{PERL_ANYEVENT_VERBOSE}>. It then attached the
404then attached the default logging context to it. The purpose of the root 554C<$AnyEvent::Log::LOG> context to it. The purpose of the filter context
405context is to simply provide filtering according to some global log level. 555is to simply provide filtering according to some global log level.
406 556
407Finally it creates the top-level package context called 557Finally it creates the top-level package context C<$AnyEvent::Log::COLLECT>
408C<AnyEvent::Log::Top> (also stored in, you might have guessed, 558and attaches the C<$AnyEvent::Log::FILTER> context to it, but otherwise
409C<$AnyEvent::Log::Top>) and attached the root context but otherwise leaves
410it at default config. It's purpose is simply to collect all log messages 559leaves it at default config. Its purpose is simply to collect all log
411system-wide. 560messages system-wide.
412 561
413These three special contexts can also be referred to by the 562The hierarchy is then:
414package/context names C<AE::Log::Default>, C<AE::Log::Root> and
415C<AE::Log::Top>.
416 563
564 any package, eventually -> $COLLECT -> $FILTER -> $LOG
565
417The effect of all this is that log messages, by default, wander up 566The effect of all this is that log messages, by default, wander up to the
418to the root context where log messages with lower priority then 567C<$AnyEvent::Log::COLLECT> context where all messages normally end up,
568from there to C<$AnyEvent::Log::FILTER> where log messages with lower
419C<$ENV{PERL_ANYEVENT_VERBOSE}> will be filtered away and then to the 569priority then C<$ENV{PERL_ANYEVENT_VERBOSE}> will be filtered out and then
420AnyEvent::Log::Default context to be passed to C<warn>. 570to the C<$AnyEvent::Log::LOG> context to be passed to C<warn>.
421 571
422Splitting the top level context into three contexts makes it easy to set 572This makes it easy to set a global logging level (by modifying $FILTER),
423a global logging level (by modifying the root context), but still allow 573but still allow other contexts to send, for example, their debug and trace
424other contexts to log, for example, their debug and trace messages to the
425default target despite the global logging level, or to attach additional 574messages to the $LOG target despite the global logging level, or to attach
426log targets that log messages, regardless of the global logging level. 575additional log targets that log messages, regardless of the global logging
576level.
427 577
428It also makes it easy to replace the default warn-logger by something that 578It also makes it easy to modify the default warn-logger ($LOG) to
429logs to a file, or to attach additional logging targets. 579something that logs to a file, or to attach additional logging targets
580(such as loggign to a file) by attaching it to $FILTER.
430 581
431=head2 CREATING/FINDING/DESTROYING CONTEXTS 582=head2 CREATING/FINDING/DESTROYING CONTEXTS
432 583
433=over 4 584=over 4
434 585
456 : bless [undef, (1 << 10) - 1 - 1], "AnyEvent::Log::Ctx" 607 : bless [undef, (1 << 10) - 1 - 1], "AnyEvent::Log::Ctx"
457} 608}
458 609
459=item AnyEvent::Log::reset 610=item AnyEvent::Log::reset
460 611
461Resets all package contexts contexts and recreates the default hierarchy 612Resets all package contexts and recreates the default hierarchy if
462if necessary, i.e. resets the logging subsystem to defaults. 613necessary, i.e. resets the logging subsystem to defaults, as much as
614possible. This process keeps references to contexts held by other parts of
615the program intact.
463 616
464This can be used to implement config-file (re-)loading: before loading a 617This can be used to implement config-file (re-)loading: before loading a
465configuration, reset all contexts. 618configuration, reset all contexts.
466 619
467Note that this currently destroys all logger callbacks - bug me if you
468need this fixed :)
469
470=cut 620=cut
621
622our $ORIG_VERBOSE = $AnyEvent::VERBOSE;
623$AnyEvent::VERBOSE = 9;
471 624
472sub reset { 625sub reset {
473 # hard to kill complex data structures 626 # hard to kill complex data structures
474 # we recreate all package loggers and reset the hierarchy 627 # we "recreate" all package loggers and reset the hierarchy
475 while (my ($k, $v) = each %CTX) { 628 while (my ($k, $v) = each %CTX) {
476 @$v = ($k, (1 << 10) - 1 - 1, { }); 629 @$v = ($k, (1 << 10) - 1 - 1, { });
477 630
478 my $pkg = $k =~ /^(.+)::/ ? $1 : "AE::Log::Top"; 631 $v->attach ($k =~ /^(.+)::/ ? $CTX{$1} : $AnyEvent::Log::COLLECT);
479 $v->attach ($CTX{$pkg});
480 } 632 }
481 633
482 $AnyEvent::Log::Default->parents; 634 @$_ = ($_->[0], (1 << 10) - 1 - 1)
483 $AnyEvent::Log::Default->title ("AnyEvent::Log::Default"); 635 for $LOG, $FILTER, $COLLECT;
484 $AnyEvent::Log::Default->log_cb (sub {
485 warn shift;
486 0
487 });
488 $CTX{"AnyEvent::Log::Default"} = $CTX{"AE::Log::Default"} = $AnyEvent::Log::Default;
489 636
490 $AnyEvent::Log::Root->parents ($AnyEvent::Log::Default); 637 #$LOG->slaves;
491 $AnyEvent::Log::Root->title ("AnyEvent::Log::Root"); 638 $LOG->title ('$AnyEvent::Log::LOG');
492 $AnyEvent::Log::Root->level ($AnyEvent::VERBOSE); 639 $LOG->log_to_warn;
493 $CTX{"AnyEvent::Log::Root"} = $CTX{"AE::Log::Root"} = $AnyEvent::Log::Root;
494 640
495 $AnyEvent::Log::Top->parents ($AnyEvent::Log::Root); 641 $FILTER->slaves ($LOG);
496 $AnyEvent::Log::Top->title ("AnyEvent::Log::Top"); 642 $FILTER->title ('$AnyEvent::Log::FILTER');
497 $CTX{"AnyEvent::Log::Top"} = $CTX{"AE::Log::Top"} = $AnyEvent::Log::Top; 643 $FILTER->level ($ORIG_VERBOSE);
644
645 $COLLECT->slaves ($FILTER);
646 $COLLECT->title ('$AnyEvent::Log::COLLECT');
498 647
499 _reassess; 648 _reassess;
500} 649}
501 650
651# override AE::log/logger
652*AnyEvent::log = *AE::log = \&log;
653*AnyEvent::logger = *AE::logger = \&logger;
654
655# convert AnyEvent loggers to AnyEvent::Log loggers
656$_->[0] = ctx $_->[0] # convert "pkg" to "ctx"
657 for values %LOGGER;
658
502# create the default logger contexts 659# create the default logger contexts
503$AnyEvent::Log::Default = ctx undef; 660$LOG = ctx undef;
504$AnyEvent::Log::Root = ctx undef; 661$FILTER = ctx undef;
505$AnyEvent::Log::Top = ctx undef; 662$COLLECT = ctx undef;
506 663
507AnyEvent::Log::reset; 664AnyEvent::Log::reset;
508 665
509# hello, CPAN, please catch me 666# hello, CPAN, please catch me
510package AnyEvent::Log::Default;
511package AE::Log::Default;
512package AnyEvent::Log::Root;
513package AE::Log::Root;
514package AnyEvent::Log::Top; 667package AnyEvent::Log::LOG;
515package AE::Log::Top; 668package AE::Log::LOG;
669package AnyEvent::Log::FILTER;
670package AE::Log::FILTER;
671package AnyEvent::Log::COLLECT;
672package AE::Log::COLLECT;
516 673
517package AnyEvent::Log::Ctx; 674package AnyEvent::Log::Ctx;
518
519# 0 1 2 3 4
520# [$title, $level, %$parents, &$logcb, &$fmtcb]
521 675
522=item $ctx = new AnyEvent::Log::Ctx methodname => param... 676=item $ctx = new AnyEvent::Log::Ctx methodname => param...
523 677
524This is a convenience constructor that makes it simpler to construct 678This is a convenience constructor that makes it simpler to construct
525anonymous logging contexts. 679anonymous logging contexts.
528name as the key with the value as parameter, unless the value is an 682name as the key with the value as parameter, unless the value is an
529arrayref, in which case it calls the method with the contents of the 683arrayref, in which case it calls the method with the contents of the
530array. The methods are called in the same order as specified. 684array. The methods are called in the same order as specified.
531 685
532Example: create a new logging context and set both the default logging 686Example: create a new logging context and set both the default logging
533level, some parent contexts and a logging callback. 687level, some slave contexts and a logging callback.
534 688
535 $ctx = new AnyEvent::Log::Ctx 689 $ctx = new AnyEvent::Log::Ctx
536 title => "dubious messages", 690 title => "dubious messages",
537 level => "error", 691 level => "error",
538 log_cb => sub { print STDOUT shift; 0 }, 692 log_cb => sub { print STDOUT shift; 0 },
539 parents => [$ctx1, $ctx, $ctx2], 693 slaves => [$ctx1, $ctx, $ctx2],
540 ; 694 ;
541 695
542=back 696=back
543 697
544=cut 698=cut
612Enables logging for the given levels, leaving all others unchanged. 766Enables logging for the given levels, leaving all others unchanged.
613 767
614=item $ctx->disable ($level[, $level...]) 768=item $ctx->disable ($level[, $level...])
615 769
616Disables logging for the given levels, leaving all others unchanged. 770Disables logging for the given levels, leaving all others unchanged.
771
772=item $ctx->cap ($level)
773
774Caps the maximum priority to the given level, for all messages logged
775to, or passing through, this context. That is, while this doesn't affect
776whether a message is logged or passed on, the maximum priority of messages
777will be limited to the specified level - messages with a higher priority
778will be set to the specified priority.
779
780Another way to view this is that C<< ->level >> filters out messages with
781a too low priority, while C<< ->cap >> modifies messages with a too high
782priority.
783
784This is useful when different log targets have different interpretations
785of priority. For example, for a specific command line program, a wrong
786command line switch might well result in a C<fatal> log message, while the
787same message, logged to syslog, is likely I<not> fatal to the system or
788syslog facility as a whole, but more likely a mere C<error>.
789
790This can be modeled by having a stderr logger that logs messages "as-is"
791and a syslog logger that logs messages with a level cap of, say, C<error>,
792or, for truly system-critical components, actually C<critical>.
617 793
618=cut 794=cut
619 795
620sub _lvl_lst { 796sub _lvl_lst {
621 map { 797 map {
623 : $_ eq "all" ? (1 .. 9) 799 : $_ eq "all" ? (1 .. 9)
624 : $STR2LEVEL{$_} || Carp::croak "$_: not a valid logging level, caught" 800 : $STR2LEVEL{$_} || Carp::croak "$_: not a valid logging level, caught"
625 } @_ 801 } @_
626} 802}
627 803
804sub _lvl {
805 $_[0] =~ /^(?:0|off|none)$/ ? 0 : (_lvl_lst $_[0])[-1]
806}
807
628our $NOP_CB = sub { 0 }; 808our $NOP_CB = sub { 0 };
629 809
630sub levels { 810sub levels {
631 my $ctx = shift; 811 my $ctx = shift;
632 $ctx->[1] = 0; 812 $ctx->[1] = 0;
635 AnyEvent::Log::_reassess; 815 AnyEvent::Log::_reassess;
636} 816}
637 817
638sub level { 818sub level {
639 my $ctx = shift; 819 my $ctx = shift;
640 my $lvl = $_[0] =~ /^(?:0|off|none)$/ ? 0 : (_lvl_lst $_[0])[-1];
641
642 $ctx->[1] = ((1 << $lvl) - 1) << 1; 820 $ctx->[1] = ((1 << &_lvl) - 1) << 1;
643 AnyEvent::Log::_reassess; 821 AnyEvent::Log::_reassess;
644} 822}
645 823
646sub enable { 824sub enable {
647 my $ctx = shift; 825 my $ctx = shift;
655 $ctx->[1] &= ~(1 << $_) 833 $ctx->[1] &= ~(1 << $_)
656 for &_lvl_lst; 834 for &_lvl_lst;
657 AnyEvent::Log::_reassess; 835 AnyEvent::Log::_reassess;
658} 836}
659 837
838sub cap {
839 my $ctx = shift;
840 $ctx->[5] = &_lvl;
841}
842
660=back 843=back
661 844
662=head3 PARENT CONTEXTS 845=head3 SLAVE CONTEXTS
663 846
664The following methods attach and detach another logging context to a 847The following methods attach and detach another logging context to a
665logging context. 848logging context.
666 849
667Log messages are propagated to all parent contexts, unless the logging 850Log messages are propagated to all slave contexts, unless the logging
668callback consumes the message. 851callback consumes the message.
669 852
670=over 4 853=over 4
671 854
672=item $ctx->attach ($ctx2[, $ctx3...]) 855=item $ctx->attach ($ctx2[, $ctx3...])
673 856
674Attaches the given contexts as parents to this context. It is not an error 857Attaches the given contexts as slaves to this context. It is not an error
675to add a context twice (the second add will be ignored). 858to add a context twice (the second add will be ignored).
676 859
677A context can be specified either as package name or as a context object. 860A context can be specified either as package name or as a context object.
678 861
679=item $ctx->detach ($ctx2[, $ctx3...]) 862=item $ctx->detach ($ctx2[, $ctx3...])
680 863
681Removes the given parents from this context - it's not an error to attempt 864Removes the given slaves from this context - it's not an error to attempt
682to remove a context that hasn't been added. 865to remove a context that hasn't been added.
683 866
684A context can be specified either as package name or as a context object. 867A context can be specified either as package name or as a context object.
685 868
686=item $ctx->parents ($ctx2[, $ctx3...]) 869=item $ctx->slaves ($ctx2[, $ctx3...])
687 870
688Replaces all parents attached to this context by the ones given. 871Replaces all slaves attached to this context by the ones given.
689 872
690=cut 873=cut
691 874
692sub attach { 875sub attach {
693 my $ctx = shift; 876 my $ctx = shift;
701 884
702 delete $ctx->[2]{$_+0} 885 delete $ctx->[2]{$_+0}
703 for map { AnyEvent::Log::ctx $_ } @_; 886 for map { AnyEvent::Log::ctx $_ } @_;
704} 887}
705 888
706sub parents { 889sub slaves {
707 undef $_[0][2]; 890 undef $_[0][2];
708 &attach; 891 &attach;
709} 892}
710 893
711=back 894=back
712 895
713=head3 MESSAGE LOGGING 896=head3 LOG TARGETS
714 897
715The following methods configure how the logging context actually does 898The following methods configure how the logging context actually does
716the logging (which consists of formatting the message and printing it or 899the logging (which consists of formatting the message and printing it or
717whatever it wants to do with it) and also allows you to log messages 900whatever it wants to do with it).
718directly to a context, without going via your package context.
719 901
720=over 4 902=over 4
721 903
722=item $ctx->log_cb ($cb->($str)) 904=item $ctx->log_cb ($cb->($str))
723 905
728(see C<fmt_cb> below) - normally simple text strings that end with a 910(see C<fmt_cb> below) - normally simple text strings that end with a
729newline (and are possibly multiline themselves). 911newline (and are possibly multiline themselves).
730 912
731It also has to return true iff it has consumed the log message, and false 913It also has to return true iff it has consumed the log message, and false
732if it hasn't. Consuming a message means that it will not be sent to any 914if it hasn't. Consuming a message means that it will not be sent to any
733parent context. When in doubt, return C<0> from your logging callback. 915slave context. When in doubt, return C<0> from your logging callback.
734 916
735Example: a very simple logging callback, simply dump the message to STDOUT 917Example: a very simple logging callback, simply dump the message to STDOUT
736and do not consume it. 918and do not consume it.
737 919
738 $ctx->log_cb (sub { print STDERR shift; 0 }); 920 $ctx->log_cb (sub { print STDERR shift; 0 });
746your program. 928your program.
747 929
748 $ctx->levels ("debug", "trace"); 930 $ctx->levels ("debug", "trace");
749 $ctx->log_cb (sub { 1 }); # do not log, but eat debug and trace messages 931 $ctx->log_cb (sub { 1 }); # do not log, but eat debug and trace messages
750 932
751=item $ctx->fmt_cb ($fmt_cb->($timestamp, $ctx, $level, $message)) 933=item $ctx->fmt_cb ($fmt_cb->($timestamp, $orig_ctx, $level, $message))
752 934
753Replaces the formatting callback on the context (C<undef> restores the 935Replaces the formatting callback on the context (C<undef> restores the
754default formatter). 936default formatter).
755 937
756The callback is passed the (possibly fractional) timestamp, the original 938The callback is passed the (possibly fractional) timestamp, the original
757logging context, the (numeric) logging level and the raw message string and needs to 939logging context (object, not title), the (numeric) logging level and
758return a formatted log message. In most cases this will be a string, but 940the raw message string and needs to return a formatted log message. In
759it could just as well be an array reference that just stores the values. 941most cases this will be a string, but it could just as well be an array
942reference that just stores the values.
943
944If, for some reason, you want to use C<caller> to find out more about the
945logger then you should walk up the call stack until you are no longer
946inside the C<AnyEvent::Log> package.
947
948To implement your own logging callback, you might find the
949C<AnyEvent::Log::format_time> and C<AnyEvent::Log::default_format>
950functions useful.
951
952Example: format the message just as AnyEvent::Log would, by letting
953AnyEvent::Log do the work. This is a good basis to design a formatting
954callback that only changes minor aspects of the formatting.
955
956 $ctx->fmt_cb (sub {
957 my ($time, $ctx, $lvl, $msg) = @_;
958
959 AnyEvent::Log::default_format $time, $ctx, $lvl, $msg
960 });
760 961
761Example: format just the raw message, with numeric log level in angle 962Example: format just the raw message, with numeric log level in angle
762brackets. 963brackets.
763 964
764 $ctx->fmt_cb (sub { 965 $ctx->fmt_cb (sub {
766 967
767 "<$lvl>$msg\n" 968 "<$lvl>$msg\n"
768 }); 969 });
769 970
770Example: return an array reference with just the log values, and use 971Example: return an array reference with just the log values, and use
771C<PApp::SQL::sql_exec> to store the emssage in a database. 972C<PApp::SQL::sql_exec> to store the message in a database.
772 973
773 $ctx->fmt_cb (sub { \@_ }); 974 $ctx->fmt_cb (sub { \@_ });
774 $ctx->log_cb (sub { 975 $ctx->log_cb (sub {
775 my ($msg) = @_; 976 my ($msg) = @_;
776 977
781 "$msg->[3]"; 982 "$msg->[3]";
782 983
783 0 984 0
784 }); 985 });
785 986
987=item $ctx->log_to_warn
988
989Sets the C<log_cb> to simply use C<CORE::warn> to report any messages
990(usually this logs to STDERR).
991
992=item $ctx->log_to_file ($path)
993
994Sets the C<log_cb> to log to a file (by appending), unbuffered. The
995function might return before the log file has been opened or created.
996
997=item $ctx->log_to_path ($path)
998
999Same as C<< ->log_to_file >>, but opens the file for each message. This
1000is much slower, but allows you to change/move/rename/delete the file at
1001basically any time.
1002
1003Needless(?) to say, if you do not want to be bitten by some evil person
1004calling C<chdir>, the path should be absolute. Doesn't help with
1005C<chroot>, but hey...
1006
1007=item $ctx->log_to_syslog ([$facility])
1008
1009Logs all messages via L<Sys::Syslog>, mapping C<trace> to C<debug> and
1010all the others in the obvious way. If specified, then the C<$facility> is
1011used as the facility (C<user>, C<auth>, C<local0> and so on). The default
1012facility is C<user>.
1013
1014Note that this function also sets a C<fmt_cb> - the logging part requires
1015an array reference with [$level, $str] as input.
1016
786=cut 1017=cut
787 1018
788sub log_cb { 1019sub log_cb {
789 my ($ctx, $cb) = @_; 1020 my ($ctx, $cb) = @_;
790 1021
795 my ($ctx, $cb) = @_; 1026 my ($ctx, $cb) = @_;
796 1027
797 $ctx->[4] = $cb; 1028 $ctx->[4] = $cb;
798} 1029}
799 1030
1031sub log_to_warn {
1032 my ($ctx, $path) = @_;
1033
1034 $ctx->log_cb (sub {
1035 warn shift;
1036 0
1037 });
1038}
1039
1040# this function is a good example of why threads are a must,
1041# simply for priority inversion.
1042sub _log_to_disk {
1043 # eval'uating this at runtime saves 220kb rss - perl has become
1044 # an insane memory waster.
1045 eval q{ # poor man's autoloading {}
1046 sub _log_to_disk {
1047 my ($ctx, $path, $keepopen) = @_;
1048
1049 my $fh;
1050 my @queue;
1051 my $delay;
1052 my $disable;
1053
1054 use AnyEvent::IO ();
1055
1056 my $kick = sub {
1057 undef $delay;
1058 return unless @queue;
1059 $delay = 1;
1060
1061 # we pass $kick to $kick, so $kick itself doesn't keep a reference to $kick.
1062 my $kick = shift;
1063
1064 # write one or more messages
1065 my $write = sub {
1066 # we write as many messages as have been queued
1067 my $data = join "", @queue;
1068 @queue = ();
1069
1070 AnyEvent::IO::aio_write $fh, $data, sub {
1071 $disable = 1;
1072 @_
1073 ? ($_[0] == length $data or AE::log 4 => "unable to write to logfile '$path': short write")
1074 : AE::log 4 => "unable to write to logfile '$path': $!";
1075 undef $disable;
1076
1077 if ($keepopen) {
1078 $kick->($kick);
1079 } else {
1080 AnyEvent::IO::aio_close ($fh, sub {
1081 undef $fh;
1082 $kick->($kick);
1083 });
1084 }
1085 };
1086 };
1087
1088 if ($fh) {
1089 $write->();
1090 } else {
1091 AnyEvent::IO::aio_open
1092 $path,
1093 AnyEvent::IO::O_CREAT | AnyEvent::IO::O_WRONLY | AnyEvent::IO::O_APPEND,
1094 0666,
1095 sub {
1096 $fh = shift
1097 or do {
1098 $disable = 1;
1099 AE::log 4 => "unable to open logfile '$path': $!";
1100 undef $disable;
1101 return;
1102 };
1103
1104 $write->();
1105 }
1106 ;
1107 }
1108 };
1109
1110 $ctx->log_cb (sub {
1111 return if $disable;
1112 push @queue, shift;
1113 $kick->($kick) unless $delay;
1114 0
1115 });
1116
1117 $kick->($kick) if $keepopen; # initial open
1118 };
1119 };
1120 die if $@;
1121 &_log_to_disk
1122}
1123
1124sub log_to_file {
1125 my ($ctx, $path) = @_;
1126
1127 _log_to_disk $ctx, $path, 1;
1128}
1129
1130sub log_to_path {
1131 my ($ctx, $path) = @_;
1132
1133 _log_to_disk $ctx, $path, 0;
1134}
1135
1136sub log_to_syslog {
1137 my ($ctx, $facility) = @_;
1138
1139 require Sys::Syslog;
1140
1141 $ctx->fmt_cb (sub {
1142 my $str = $_[3];
1143 $str =~ s/\n(?=.)/\n+ /g;
1144
1145 [$_[2], "($_[1][0]) $str"]
1146 });
1147
1148 $facility ||= "user";
1149
1150 $ctx->log_cb (sub {
1151 my $lvl = $_[0][0] < 9 ? $_[0][0] : 8;
1152
1153 Sys::Syslog::syslog ("$facility|" . ($lvl - 1), $_)
1154 for split /\n/, $_[0][1];
1155
1156 0
1157 });
1158}
1159
1160=back
1161
1162=head3 MESSAGE LOGGING
1163
1164These methods allow you to log messages directly to a context, without
1165going via your package context.
1166
1167=over 4
1168
800=item $ctx->log ($level, $msg[, @params]) 1169=item $ctx->log ($level, $msg[, @params])
801 1170
802Same as C<AnyEvent::Log::log>, but uses the given context as log context. 1171Same as C<AnyEvent::Log::log>, but uses the given context as log context.
1172
1173Example: log a message in the context of another package.
1174
1175 (AnyEvent::Log::ctx "Other::Package")->log (warn => "heely bo");
803 1176
804=item $logger = $ctx->logger ($level[, \$enabled]) 1177=item $logger = $ctx->logger ($level[, \$enabled])
805 1178
806Same as C<AnyEvent::Log::logger>, but uses the given context as log 1179Same as C<AnyEvent::Log::logger>, but uses the given context as log
807context. 1180context.
809=cut 1182=cut
810 1183
811*log = \&AnyEvent::Log::_log; 1184*log = \&AnyEvent::Log::_log;
812*logger = \&AnyEvent::Log::_logger; 1185*logger = \&AnyEvent::Log::_logger;
813 1186
8141;
815
816=back 1187=back
817 1188
1189=cut
1190
1191package AnyEvent::Log;
1192
1193=head1 CONFIGURATION VIA $ENV{PERL_ANYEVENT_LOG}
1194
1195Logging can also be configured by setting the environment variable
1196C<PERL_ANYEVENT_LOG> (or C<AE_LOG>).
1197
1198The value consists of one or more logging context specifications separated
1199by C<:> or whitespace. Each logging specification in turn starts with a
1200context name, followed by C<=>, followed by zero or more comma-separated
1201configuration directives, here are some examples:
1202
1203 # set default logging level
1204 filter=warn
1205
1206 # log to file instead of to stderr
1207 log=file=/tmp/mylog
1208
1209 # log to file in addition to stderr
1210 log=+%file:%file=file=/tmp/mylog
1211
1212 # enable debug log messages, log warnings and above to syslog
1213 filter=debug:log=+%warnings:%warnings=warn,syslog=LOG_LOCAL0
1214
1215 # log trace messages (only) from AnyEvent::Debug to file
1216 AnyEvent::Debug=+%trace:%trace=only,trace,file=/tmp/tracelog
1217
1218A context name in the log specification can be any of the following:
1219
1220=over 4
1221
1222=item C<collect>, C<filter>, C<log>
1223
1224Correspond to the three predefined C<$AnyEvent::Log::COLLECT>,
1225C<AnyEvent::Log::FILTER> and C<$AnyEvent::Log::LOG> contexts.
1226
1227=item C<%name>
1228
1229Context names starting with a C<%> are anonymous contexts created when the
1230name is first mentioned. The difference to package contexts is that by
1231default they have no attached slaves.
1232
1233=item a perl package name
1234
1235Any other string references the logging context associated with the given
1236Perl C<package>. In the unlikely case where you want to specify a package
1237context that matches on of the other context name forms, you can add a
1238C<::> to the package name to force interpretation as a package.
1239
1240=back
1241
1242The configuration specifications can be any number of the following:
1243
1244=over 4
1245
1246=item C<stderr>
1247
1248Configures the context to use Perl's C<warn> function (which typically
1249logs to C<STDERR>). Works like C<log_to_warn>.
1250
1251=item C<file=>I<path>
1252
1253Configures the context to log to a file with the given path. Works like
1254C<log_to_file>.
1255
1256=item C<path=>I<path>
1257
1258Configures the context to log to a file with the given path. Works like
1259C<log_to_path>.
1260
1261=item C<syslog> or C<syslog=>I<expr>
1262
1263Configures the context to log to syslog. If I<expr> is given, then it is
1264evaluated in the L<Sys::Syslog> package, so you could use:
1265
1266 log=syslog=LOG_LOCAL0
1267
1268=item C<nolog>
1269
1270Configures the context to not log anything by itself, which is the
1271default. Same as C<< $ctx->log_cb (undef) >>.
1272
1273=item C<cap=>I<level>
1274
1275Caps logging messages entering this context at the given level, i.e.
1276reduces the priority of messages with higher priority than this level. The
1277default is C<0> (or C<off>), meaning the priority will not be touched.
1278
1279=item C<0> or C<off>
1280
1281Sets the logging level of the context to C<0>, i.e. all messages will be
1282filtered out.
1283
1284=item C<all>
1285
1286Enables all logging levels, i.e. filtering will effectively be switched
1287off (the default).
1288
1289=item C<only>
1290
1291Disables all logging levels, and changes the interpretation of following
1292level specifications to enable the specified level only.
1293
1294Example: only enable debug messages for a context.
1295
1296 context=only,debug
1297
1298=item C<except>
1299
1300Enables all logging levels, and changes the interpretation of following
1301level specifications to disable that level. Rarely used.
1302
1303Example: enable all logging levels except fatal and trace (this is rather
1304nonsensical).
1305
1306 filter=exept,fatal,trace
1307
1308=item C<level>
1309
1310Enables all logging levels, and changes the interpretation of following
1311level specifications to be "that level or any higher priority
1312message". This is the default.
1313
1314Example: log anything at or above warn level.
1315
1316 filter=warn
1317
1318 # or, more verbose
1319 filter=only,level,warn
1320
1321=item C<1>..C<9> or a logging level name (C<error>, C<debug> etc.)
1322
1323A numeric loglevel or the name of a loglevel will be interpreted according
1324to the most recent C<only>, C<except> or C<level> directive. By default,
1325specifying a logging level enables that and any higher priority messages.
1326
1327=item C<+>I<context>
1328
1329Attaches the named context as slave to the context.
1330
1331=item C<+>
1332
1333A lone C<+> detaches all contexts, i.e. clears the slave list from the
1334context. Anonymous (C<%name>) contexts have no attached slaves by default,
1335but package contexts have the parent context as slave by default.
1336
1337Example: log messages from My::Module to a file, do not send them to the
1338default log collector.
1339
1340 My::Module=+,file=/tmp/mymodulelog
1341
1342=back
1343
1344Any character can be escaped by prefixing it with a C<\> (backslash), as
1345usual, so to log to a file containing a comma, colon, backslash and some
1346spaces in the filename, you would do this:
1347
1348 PERL_ANYEVENT_LOG='log=file=/some\ \:file\ with\,\ \\-escapes'
1349
1350Since whitespace (which includes newlines) is allowed, it is fine to
1351specify multiple lines in C<PERL_ANYEVENT_LOG>, e.g.:
1352
1353 PERL_ANYEVENT_LOG="
1354 filter=warn
1355 AnyEvent::Debug=+%trace
1356 %trace=only,trace,+log
1357 " myprog
1358
1359Also, in the unlikely case when you want to concatenate specifications,
1360use whitespace as separator, as C<::> will be interpreted as part of a
1361module name, an empty spec with two separators:
1362
1363 PERL_ANYEVENT_LOG="$PERL_ANYEVENT_LOG MyMod=debug"
1364
1365=cut
1366
1367for (my $spec = $ENV{PERL_ANYEVENT_LOG}) {
1368 my %anon;
1369
1370 my $pkg = sub {
1371 $_[0] eq "log" ? $LOG
1372 : $_[0] eq "filter" ? $FILTER
1373 : $_[0] eq "collect" ? $COLLECT
1374 : $_[0] =~ /^%(.+)$/ ? ($anon{$1} ||= do { my $ctx = ctx undef; $ctx->[0] = $_[0]; $ctx })
1375 : $_[0] =~ /^(.*?)(?:::)?$/ ? ctx "$1" # egad :/
1376 : die # never reached?
1377 };
1378
1379 /\G[[:space:]]+/gc; # skip initial whitespace
1380
1381 while (/\G((?:[^:=[:space:]]+|::|\\.)+)=/gc) {
1382 my $ctx = $pkg->($1);
1383 my $level = "level";
1384
1385 while (/\G((?:[^,:[:space:]]+|::|\\.)+)/gc) {
1386 for ("$1") {
1387 if ($_ eq "stderr" ) { $ctx->log_to_warn;
1388 } elsif (/^file=(.+)/ ) { $ctx->log_to_file ("$1");
1389 } elsif (/^path=(.+)/ ) { $ctx->log_to_path ("$1");
1390 } elsif (/^syslog(?:=(.*))?/ ) { require Sys::Syslog; $ctx->log_to_syslog ("$1");
1391 } elsif ($_ eq "nolog" ) { $ctx->log_cb (undef);
1392 } elsif (/^cap=(.+)/ ) { $ctx->cap ("$1");
1393 } elsif (/^\+(.+)$/ ) { $ctx->attach ($pkg->("$1"));
1394 } elsif ($_ eq "+" ) { $ctx->slaves;
1395 } elsif ($_ eq "off" or $_ eq "0") { $ctx->level (0);
1396 } elsif ($_ eq "all" ) { $ctx->level ("all");
1397 } elsif ($_ eq "level" ) { $ctx->level ("all"); $level = "level";
1398 } elsif ($_ eq "only" ) { $ctx->level ("off"); $level = "enable";
1399 } elsif ($_ eq "except" ) { $ctx->level ("all"); $level = "disable";
1400 } elsif (/^\d$/ ) { $ctx->$level ($_);
1401 } elsif (exists $STR2LEVEL{$_} ) { $ctx->$level ($_);
1402 } else { die "PERL_ANYEVENT_LOG ($spec): parse error at '$_'\n";
1403 }
1404 }
1405
1406 /\G,/gc or last;
1407 }
1408
1409 /\G[:[:space:]]+/gc or last;
1410 }
1411
1412 /\G[[:space:]]+/gc; # skip trailing whitespace
1413
1414 if (/\G(.+)/g) {
1415 die "PERL_ANYEVENT_LOG ($spec): parse error at '$1'\n";
1416 }
1417}
1418
818=head1 EXAMPLES 1419=head1 EXAMPLES
819 1420
820This section shows some common configurations. 1421This section shows some common configurations, both as code, and as
1422C<PERL_ANYEVENT_LOG> string.
821 1423
822=over 4 1424=over 4
823 1425
824=item Setting the global logging level. 1426=item Setting the global logging level.
825 1427
826Either put PERL_ANYEVENT_VERBOSE=<number> into your environment before 1428Either put C<PERL_ANYEVENT_VERBOSE=><number> into your environment before
827running your program, or modify the log level of the root context: 1429running your program, use C<PERL_ANYEVENT_LOG> or modify the log level of
1430the root context at runtime:
828 1431
829 PERL_ANYEVENT_VERBOSE=5 ./myprog 1432 PERL_ANYEVENT_VERBOSE=5 ./myprog
830 1433
1434 PERL_ANYEVENT_LOG=log=warn
1435
831 $AnyEvent::Log::Root->level ("warn"); 1436 $AnyEvent::Log::FILTER->level ("warn");
832 1437
833=item Append all messages to a file instead of sending them to STDERR. 1438=item Append all messages to a file instead of sending them to STDERR.
834 1439
835This is affected by the global logging level. 1440This is affected by the global logging level.
836 1441
837 open my $fh, ">>", $path 1442 $AnyEvent::Log::LOG->log_to_file ($path);
838 or die "$path: $!";
839 1443
840 $AnyEvent::Log::Default->log_cb (sub { 1444 PERL_ANYEVENT_LOG=log=file=/some/path
841 syswrite $fh, shift;
842 0
843 });
844 1445
845=item Write all messages with priority C<error> and higher to a file. 1446=item Write all messages with priority C<error> and higher to a file.
846 1447
847This writes them only when the global logging level allows it, because 1448This writes them only when the global logging level allows it, because
848it is attached to the default context which is invoked I<after> global 1449it is attached to the default context which is invoked I<after> global
849filtering. 1450filtering.
850 1451
851 open my $fh, ">>", $path 1452 $AnyEvent::Log::FILTER->attach (
852 or die "$path: $!"; 1453 new AnyEvent::Log::Ctx log_to_file => $path);
853 1454
854 $AnyEvent::Log::Default->attach (new AnyEvent::Log::Ctx 1455 PERL_ANYEVENT_LOG=filter=+%filelogger:%filelogger=file=/some/path
855 log_cb => sub { syswrite $fh, shift; 0 });
856 1456
857This writes them regardless of the global logging level, because it is 1457This writes them regardless of the global logging level, because it is
858attached to the toplevel context, which receives all messages I<before> 1458attached to the toplevel context, which receives all messages I<before>
859the global filtering. 1459the global filtering.
860 1460
861 $AnyEvent::Log::Top->attach (new AnyEvent::Log::Ctx 1461 $AnyEvent::Log::COLLECT->attach (
862 log_cb => sub { syswrite $fh, shift; 0 }); 1462 new AnyEvent::Log::Ctx log_to_file => $path);
863 1463
1464 PERL_ANYEVENT_LOG=%filelogger=file=/some/path:collect=+%filelogger
1465
864In both cases, messages are still written to STDOUT. 1466In both cases, messages are still written to STDERR.
1467
1468=item Additionally log all messages with C<warn> and higher priority to
1469C<syslog>, but cap at C<error>.
1470
1471This logs all messages to the default log target, but also logs messages
1472with priority C<warn> or higher (and not filtered otherwise) to syslog
1473facility C<user>. Messages with priority higher than C<error> will be
1474logged with level C<error>.
1475
1476 $AnyEvent::Log::LOG->attach (
1477 new AnyEvent::Log::Ctx
1478 level => "warn",
1479 cap => "error",
1480 syslog => "user",
1481 );
1482
1483 PERL_ANYEVENT_LOG=log=+%syslog:%syslog=warn,cap=error,syslog
865 1484
866=item Write trace messages (only) from L<AnyEvent::Debug> to the default logging target(s). 1485=item Write trace messages (only) from L<AnyEvent::Debug> to the default logging target(s).
867 1486
868Attach the CyAnyEvent::Log::Default> context to the C<AnyEvent::Debug> 1487Attach the C<$AnyEvent::Log::LOG> context to the C<AnyEvent::Debug>
869context and increase the C<AnyEvent::Debug> logging level - this simply
870circumvents the global filtering for trace messages. 1488context - this simply circumvents the global filtering for trace messages.
871 1489
872 my $debug = AnyEvent::Debug->AnyEvent::Log::ctx; 1490 my $debug = AnyEvent::Debug->AnyEvent::Log::ctx;
873 $debug->attach ($AnyEvent::Log::Default); 1491 $debug->attach ($AnyEvent::Log::LOG);
874 $debug->levels ("trace"); # not "level"!
875 1492
876This of course works for any package. 1493 PERL_ANYEVENT_LOG=AnyEvent::Debug=+log
1494
1495This of course works for any package, not just L<AnyEvent::Debug>, but
1496assumes the log level for AnyEvent::Debug hasn't been changed from the
1497default.
877 1498
878=back 1499=back
879 1500
1501=head1 ASYNCHRONOUS DISK I/O
1502
1503This module uses L<AnyEvent::IO> to actually write log messages (in
1504C<log_to_file> and C<log_to_path>), so it doesn't block your program when
1505the disk is busy and a non-blocking L<AnyEvent::IO> backend is available.
1506
880=head1 AUTHOR 1507=head1 AUTHOR
881 1508
882 Marc Lehmann <schmorp@schmorp.de> 1509 Marc Lehmann <schmorp@schmorp.de>
883 http://home.schmorp.de/ 1510 http://anyevent.schmorp.de
884 1511
885=cut 1512=cut
1513
15141
1515

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines