Switch sense of adaptive logging. Immediately echo log lines <= max level
and save log lines <= min level. IIF a message is accepted for delivery, then echo out the saved log lines (typically just FROM and TO) with the prefix for multilog filtering into independent log files. Update POD in logging/adaptive to describe changed behavior as well as give an example log/run file to filter the messages accordingly. git-svn-id: https://svn.perl.org/qpsmtpd/trunk@443 958fd67b-6ff1-0310-b445-bb7760255be9
This commit is contained in:
parent
9664eb9469
commit
51b035ad62
@ -3,7 +3,7 @@
|
|||||||
# one level for DENY'd messages
|
# one level for DENY'd messages
|
||||||
|
|
||||||
sub register {
|
sub register {
|
||||||
my ($self, $qp, %args) = @_;
|
my ( $self, $qp, %args ) = @_;
|
||||||
|
|
||||||
$self->{_minlevel} = LOGERROR;
|
$self->{_minlevel} = LOGERROR;
|
||||||
if ( defined( $args{accept} ) ) {
|
if ( defined( $args{accept} ) ) {
|
||||||
@ -25,73 +25,74 @@ sub register {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
$self->{_prefix} = '!';
|
$self->{_prefix} = '`';
|
||||||
if ( defined $args{prefix} and $args{prefix} =~ /^(.+)$/ ) {
|
if ( defined $args{prefix} and $args{prefix} =~ /^(.+)$/ ) {
|
||||||
$self->{_prefix} = $1;
|
$self->{_prefix} = $1;
|
||||||
}
|
}
|
||||||
|
|
||||||
$self->register_hook('logging', 'wlog');
|
$self->register_hook( 'logging', 'wlog' );
|
||||||
$self->register_hook('deny', 'dlog');
|
$self->register_hook( 'deny', 'dlog' );
|
||||||
$self->register_hook('reset_transaction', 'slog');
|
$self->register_hook( 'reset_transaction', 'slog' );
|
||||||
|
|
||||||
# If you want to capture this log entry with this plugin, you need to
|
# If you want to capture this log entry with this plugin, you need to
|
||||||
# wait until after you register the plugin
|
# wait until after you register the plugin
|
||||||
$self->log(LOGINFO,'Initializing logging::adaptive plugin');
|
$self->log( LOGINFO, 'Initializing logging::adaptive plugin' );
|
||||||
}
|
}
|
||||||
|
|
||||||
sub wlog {
|
sub wlog {
|
||||||
my ($self, $transaction, $trace, $hook, $plugin, @log) = @_;
|
my ( $self, $transaction, $trace, $hook, $plugin, @log ) = @_;
|
||||||
|
|
||||||
# Don't log your own log entries! If this is the only logging plugin
|
# Don't log your own log entries! If this is the only logging plugin
|
||||||
# then these lines will not be logged at all. You can safely comment
|
# then these lines will not be logged at all. You can safely comment
|
||||||
# out this line and it will not cause an infinite loop.
|
# out this line and it will not cause an infinite loop.
|
||||||
return DECLINED if defined $plugin and $plugin eq $self->plugin_name;
|
return DECLINED if defined $plugin and $plugin eq $self->plugin_name;
|
||||||
|
|
||||||
push @{$transaction->{_log}}, [$trace, $hook, $plugin, @log];
|
if ( $trace <= $self->{_maxlevel} ) {
|
||||||
|
warn join(
|
||||||
|
" ", $$.
|
||||||
|
(
|
||||||
|
defined $plugin ? " $plugin plugin:"
|
||||||
|
: defined $hook ? " running plugin ($hook):"
|
||||||
|
: ""
|
||||||
|
),
|
||||||
|
@log
|
||||||
|
),
|
||||||
|
"\n"
|
||||||
|
unless $log[0] =~ /logging::adaptive/;
|
||||||
|
push @{ $transaction->{_log} }, [ $trace, $hook, $plugin, @log ]
|
||||||
|
if ( $trace <= $self->{_minlevel} );
|
||||||
|
}
|
||||||
|
|
||||||
return DECLINED;
|
return DECLINED;
|
||||||
}
|
}
|
||||||
|
|
||||||
sub dlog {
|
sub dlog {
|
||||||
# fires when a message is denied
|
my ( $self, $transaction, $prev_hook, $return, $return_text ) = @_;
|
||||||
my ($self, $transaction, $prev_hook, $return, $return_text) = @_;
|
$self->{_denied} = 1;
|
||||||
warn join(" ", $$, $self->{_prefix},
|
|
||||||
"Plugin $prev_hook returned",
|
|
||||||
return_code($return).
|
|
||||||
": '$return_text'"), "\n";
|
|
||||||
|
|
||||||
foreach my $row ( @{$transaction->{_log}} ) {
|
|
||||||
next unless scalar @$row; # skip over empty log lines
|
|
||||||
my ($trace, $hook, $plugin, @log) = @$row;
|
|
||||||
if ($trace <= $self->{_maxlevel}) {
|
|
||||||
warn
|
|
||||||
join(" ", $$, $self->{_prefix}.
|
|
||||||
(defined $plugin ? " $plugin plugin:" :
|
|
||||||
defined $hook ? " running plugin ($hook):" : ""),
|
|
||||||
@log), "\n"
|
|
||||||
unless $log[0] =~ /logging::adaptive/;
|
|
||||||
# consume any lines you print so that they don't also
|
|
||||||
# show up as OK lines
|
|
||||||
$row = [];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return DECLINED;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
sub slog {
|
sub slog {
|
||||||
# fires when a message is accepted
|
|
||||||
my ($self, $transaction, @args) = @_;
|
|
||||||
|
|
||||||
foreach my $row ( @{$transaction->{_log}} ) {
|
# fires when a message is accepted
|
||||||
|
my ( $self, $transaction, @args ) = @_;
|
||||||
|
|
||||||
|
return DECLINED if $self->{_denied};
|
||||||
|
|
||||||
|
foreach my $row ( @{ $transaction->{_log} } ) {
|
||||||
next unless scalar @$row; # skip over empty log lines
|
next unless scalar @$row; # skip over empty log lines
|
||||||
my ($trace, $hook, $plugin, @log) = @$row;
|
my ( $trace, $hook, $plugin, @log ) = @$row;
|
||||||
warn
|
warn join(
|
||||||
join(" ", $$ .
|
" ", $$,
|
||||||
(defined $plugin ? " $plugin plugin:" :
|
$self->{_prefix}.
|
||||||
defined $hook ? " running plugin ($hook):" : ""),
|
(
|
||||||
@log), "\n"
|
defined $plugin ? " $plugin plugin:"
|
||||||
if ($trace <= $self->{_minlevel});
|
: defined $hook ? " running plugin ($hook):"
|
||||||
|
: ""
|
||||||
|
),
|
||||||
|
@log
|
||||||
|
),
|
||||||
|
"\n"
|
||||||
|
if ( $trace <= $self->{_minlevel} );
|
||||||
}
|
}
|
||||||
|
|
||||||
return DECLINED;
|
return DECLINED;
|
||||||
@ -99,6 +100,7 @@ sub slog {
|
|||||||
|
|
||||||
=cut
|
=cut
|
||||||
|
|
||||||
|
|
||||||
=head1 NAME
|
=head1 NAME
|
||||||
|
|
||||||
adaptive - An adaptive logging plugin for qpsmtpd
|
adaptive - An adaptive logging plugin for qpsmtpd
|
||||||
@ -138,14 +140,42 @@ is probably not high enough for most sites.
|
|||||||
=item B<prefix>
|
=item B<prefix>
|
||||||
|
|
||||||
In order to visually distinguish the accepted from rejected lines, all
|
In order to visually distinguish the accepted from rejected lines, all
|
||||||
log lines from a rejected message will be prefixed with the character
|
log lines from a accepted message will be prefixed with the character
|
||||||
listed here (directly after the PID). You can use anything you want as
|
listed here (directly after the PID). You can use anything you want as
|
||||||
a prefix, but it is recommended that it be short (preferably just a single
|
a prefix, but it is recommended that it be short (preferably just a single
|
||||||
character) to minimize the amount of bloat in the log file. If absent, the
|
character) to minimize the amount of bloat in the log file. If absent, the
|
||||||
prefix defaults to the exclamation point (!).
|
prefix defaults to the left single quote (`).
|
||||||
|
|
||||||
=back
|
=back
|
||||||
|
|
||||||
|
=head1 TYPICAL USAGE
|
||||||
|
|
||||||
|
If you are using multilog to handle your logging, you can replace the system
|
||||||
|
provided log/run file with something like this:
|
||||||
|
|
||||||
|
#! /bin/sh
|
||||||
|
export LOGDIR=./main
|
||||||
|
mkdir -p $LOGDIR/failed
|
||||||
|
exec multilog t n10 \
|
||||||
|
'-*` *' $LOGDIR/detailed \
|
||||||
|
'-*' '+*` *' $LOGDIR/accepted
|
||||||
|
|
||||||
|
which will have the following effects:
|
||||||
|
|
||||||
|
=over 4
|
||||||
|
|
||||||
|
=item 1. All lines will be logged into the ./mail/detailed folder
|
||||||
|
|
||||||
|
=item 2. Log lines for messages that are accepted will go to ./main/accepted
|
||||||
|
|
||||||
|
=back
|
||||||
|
|
||||||
|
You may want to use the s####### option to multilog to ensure that the log
|
||||||
|
files are large enough to maintain a proper amount of history. Depending on
|
||||||
|
your site load, it is useful to have at least a week and preferrably three
|
||||||
|
weeks of accepted messages. You can also use the n## option to have more
|
||||||
|
log history files maintained.
|
||||||
|
|
||||||
=head1 AUTHOR
|
=head1 AUTHOR
|
||||||
|
|
||||||
John Peacock <jpeacock@cpan.org>
|
John Peacock <jpeacock@cpan.org>
|
||||||
|
Loading…
Reference in New Issue
Block a user