Trailing whitespace cleanup

git-svn-id: https://svn.perl.org/qpsmtpd/trunk@965 958fd67b-6ff1-0310-b445-bb7760255be9
This commit is contained in:
Robert Spier 2008-12-31 21:46:40 +00:00 committed by Ask Bjørn Hansen
parent 9e7a4c8e3b
commit 79c5a726a3

View File

@ -21,13 +21,13 @@ my %config_dir_memo;
#my $SAMPLER = DashProfiler->prepare("qpsmtpd"); #my $SAMPLER = DashProfiler->prepare("qpsmtpd");
my $LOGGING_LOADED = 0; my $LOGGING_LOADED = 0;
sub _restart { sub _restart {
my $self = shift; my $self = shift;
my %args = @_; my %args = @_;
if ($args{restart}) { if ($args{restart}) {
# reset all global vars to defaults # reset all global vars to defaults
$self->clear_config_cache; $self->clear_config_cache;
$hooks = {}; $hooks = {};
$LOGGING_LOADED = 0; $LOGGING_LOADED = 0;
%config_dir_memo = (); %config_dir_memo = ();
$TraceLevel = LOGWARN; $TraceLevel = LOGWARN;
@ -49,7 +49,7 @@ sub TRACE_LEVEL { $TraceLevel }; # leave for plugin compatibility
sub hooks { $hooks; } sub hooks { $hooks; }
sub load_logging { sub load_logging {
# need to do this differently that other plugins so as to # need to do this differently that other plugins so as to
# not trigger logging activity # not trigger logging activity
return if $LOGGING_LOADED; return if $LOGGING_LOADED;
my $self = shift; my $self = shift;
@ -65,7 +65,7 @@ sub load_logging {
my ($name) = ($0 =~ m!(.*?)/([^/]+)$!); my ($name) = ($0 =~ m!(.*?)/([^/]+)$!);
@plugin_dirs = ( "$name/plugins" ); @plugin_dirs = ( "$name/plugins" );
} }
my @loaded; my @loaded;
for my $logger (@loggers) { for my $logger (@loggers) {
push @loaded, $self->_load_plugin($logger, @plugin_dirs); push @loaded, $self->_load_plugin($logger, @plugin_dirs);
@ -87,7 +87,7 @@ sub load_logging {
return @loggers; return @loggers;
} }
sub trace_level { sub trace_level {
my $self = shift; my $self = shift;
return $TraceLevel; return $TraceLevel;
@ -122,7 +122,7 @@ sub varlog {
unless ( $rc and $rc == DECLINED or $rc == OK ) { unless ( $rc and $rc == DECLINED or $rc == OK ) {
# no logging plugins registered so fall back to STDERR # no logging plugins registered so fall back to STDERR
warn join(" ", $$ . warn join(" ", $$ .
(defined $plugin ? " $plugin plugin ($hook):" : (defined $plugin ? " $plugin plugin ($hook):" :
defined $hook ? " running plugin ($hook):" : ""), defined $hook ? " running plugin ($hook):" : ""),
@log), "\n" @log), "\n"
if $trace <= $TraceLevel; if $trace <= $TraceLevel;
@ -145,9 +145,9 @@ sub config {
if ($_config_cache->{$c}) { if ($_config_cache->{$c}) {
return wantarray ? @{$_config_cache->{$c}} : $_config_cache->{$c}->[0]; return wantarray ? @{$_config_cache->{$c}} : $_config_cache->{$c}->[0];
} }
$_config_cache->{$c} = [$defaults{$c}] if exists($defaults{$c}); $_config_cache->{$c} = [$defaults{$c}] if exists($defaults{$c});
#warn "SELF->config($c) ", ref $self; #warn "SELF->config($c) ", ref $self;
my ($rc, @config) = $self->run_hooks_no_respond("config", $c); my ($rc, @config) = $self->run_hooks_no_respond("config", $c);
@ -157,12 +157,12 @@ sub config {
@config = $self->get_qmail_config($c, $type) unless @config; @config = $self->get_qmail_config($c, $type) unless @config;
@config = $defaults{$c} if (!@config and $defaults{$c}); @config = $defaults{$c} if (!@config and $defaults{$c});
return @config; return @config;
} }
else { else {
return $config[0] if defined($config[0]); return $config[0] if defined($config[0]);
my $val = $self->get_qmail_config($c, $type); my $val = $self->get_qmail_config($c, $type);
return $val if defined($val); return $val if defined($val);
return $defaults{$c}; return $defaults{$c};
} }
} }
@ -184,7 +184,7 @@ sub config_dir {
sub plugin_dirs { sub plugin_dirs {
my $self = shift; my $self = shift;
my @plugin_dirs = $self->config('plugin_dirs'); my @plugin_dirs = $self->config('plugin_dirs');
unless (@plugin_dirs) { unless (@plugin_dirs) {
my ($path) = ($ENV{PROCESS} ? $ENV{PROCESS} : $0) =~ m!(.*?)/([^/]+)$!; my ($path) = ($ENV{PROCESS} ? $ENV{PROCESS} : $0) =~ m!(.*?)/([^/]+)$!;
@plugin_dirs = ( "$path/plugins" ); @plugin_dirs = ( "$path/plugins" );
@ -310,7 +310,7 @@ sub expand_inclusion_ {
sub load_plugins { sub load_plugins {
my $self = shift; my $self = shift;
my @plugins = $self->config('plugins'); my @plugins = $self->config('plugins');
my @loaded; my @loaded;
@ -339,13 +339,13 @@ sub _load_plugin {
# "full" package plugin (My::Plugin) # "full" package plugin (My::Plugin)
$package = $plugin; $package = $plugin;
$package =~ s/[^_a-z0-9:]+//gi; $package =~ s/[^_a-z0-9:]+//gi;
my $eval = qq[require $package;\n] my $eval = qq[require $package;\n]
.qq[sub ${plugin}::plugin_name { '$plugin' }]; .qq[sub ${plugin}::plugin_name { '$plugin' }];
$eval =~ m/(.*)/s; $eval =~ m/(.*)/s;
$eval = $1; $eval = $1;
eval $eval; eval $eval;
die "Failed loading $package - eval $@" if $@; die "Failed loading $package - eval $@" if $@;
$self->log(LOGDEBUG, "Loading $package ($plugin_line)") $self->log(LOGDEBUG, "Loading $package ($plugin_line)")
unless $plugin_line =~ /logging/; unless $plugin_line =~ /logging/;
} }
else { else {
@ -355,7 +355,7 @@ sub _load_plugin {
# Escape everything into valid perl identifiers # Escape everything into valid perl identifiers
$plugin_name =~ s/([^A-Za-z0-9_\/])/sprintf("_%2x",unpack("C",$1))/eg; $plugin_name =~ s/([^A-Za-z0-9_\/])/sprintf("_%2x",unpack("C",$1))/eg;
# second pass cares for slashes and words starting with a digit # second pass cares for slashes and words starting with a digit
$plugin_name =~ s{ $plugin_name =~ s{
(/+) # directory (/+) # directory
@ -363,16 +363,16 @@ sub _load_plugin {
}[ }[
"::" . (length $2 ? sprintf("_%2x",unpack("C",$2)) : "") "::" . (length $2 ? sprintf("_%2x",unpack("C",$2)) : "")
]egx; ]egx;
$package = "Qpsmtpd::Plugin::$plugin_name"; $package = "Qpsmtpd::Plugin::$plugin_name";
# don't reload plugins if they are already loaded # don't reload plugins if they are already loaded
unless ( defined &{"${package}::plugin_name"} ) { unless ( defined &{"${package}::plugin_name"} ) {
PLUGIN_DIR: for my $dir (@plugin_dirs) { PLUGIN_DIR: for my $dir (@plugin_dirs) {
if (-e "$dir/$plugin") { if (-e "$dir/$plugin") {
Qpsmtpd::Plugin->compile($plugin_name, $package, Qpsmtpd::Plugin->compile($plugin_name, $package,
"$dir/$plugin", $self->{_test_mode}, $plugin); "$dir/$plugin", $self->{_test_mode}, $plugin);
$self->log(LOGDEBUG, "Loading $plugin_line from $dir/$plugin") $self->log(LOGDEBUG, "Loading $plugin_line from $dir/$plugin")
unless $plugin_line =~ /logging/; unless $plugin_line =~ /logging/;
last PLUGIN_DIR; last PLUGIN_DIR;
} }
@ -385,7 +385,7 @@ sub _load_plugin {
my $plug = $package->new(); my $plug = $package->new();
$plug->_register($self, @args); $plug->_register($self, @args);
return $plug; return $plug;
} }
@ -461,7 +461,7 @@ sub run_continuation {
$cnotes->{"hook_$hook"}->{'return'} = $r[0] $cnotes->{"hook_$hook"}->{'return'} = $r[0]
if (!defined $cnotes || ref $cnotes eq "HASH"); if (!defined $cnotes || ref $cnotes eq "HASH");
} }
if ($r[0] == YIELD) { if ($r[0] == YIELD) {
$self->pause_read(); $self->pause_read();
$self->{_continuation} = [$hook, $args, @$todo]; $self->{_continuation} = [$hook, $args, @$todo];
@ -493,11 +493,11 @@ sub run_continuation {
sub hook_responder { sub hook_responder {
my ($self, $hook, $msg, $args) = @_; my ($self, $hook, $msg, $args) = @_;
#my $t1 = $SAMPLER->("hook_responder", undef, 1); #my $t1 = $SAMPLER->("hook_responder", undef, 1);
my $code = shift @$msg; my $code = shift @$msg;
my $responder = $hook . '_respond'; my $responder = $hook . '_respond';
if (my $meth = $self->can($responder)) { if (my $meth = $self->can($responder)) {
return $meth->($self, $code, $msg, $args); return $meth->($self, $code, $msg, $args);
@ -522,11 +522,11 @@ sub spool_dir {
unless ( $Spool_dir ) { # first time through unless ( $Spool_dir ) { # first time through
$self->log(LOGINFO, "Initializing spool_dir"); $self->log(LOGINFO, "Initializing spool_dir");
$Spool_dir = $self->config('spool_dir') $Spool_dir = $self->config('spool_dir')
|| Qpsmtpd::Utils::tildeexp('~/tmp/'); || Qpsmtpd::Utils::tildeexp('~/tmp/');
$Spool_dir .= "/" unless ($Spool_dir =~ m!/$!); $Spool_dir .= "/" unless ($Spool_dir =~ m!/$!);
$Spool_dir =~ /^(.+)$/ or die "spool_dir not configured properly"; $Spool_dir =~ /^(.+)$/ or die "spool_dir not configured properly";
$Spool_dir = $1; # cleanse the taint $Spool_dir = $1; # cleanse the taint
my $Spool_perms = $self->config('spool_perms') || '0700'; my $Spool_perms = $self->config('spool_perms') || '0700';
@ -540,20 +540,20 @@ sub spool_dir {
or die "Could not create spool_dir $Spool_dir: $!"; or die "Could not create spool_dir $Spool_dir: $!";
} }
} }
return $Spool_dir; return $Spool_dir;
} }
# For unique filenames. We write to a local tmp dir so we don't need # For unique filenames. We write to a local tmp dir so we don't need
# to make them unpredictable. # to make them unpredictable.
my $transaction_counter = 0; my $transaction_counter = 0;
sub temp_file { sub temp_file {
my $self = shift; my $self = shift;
my $filename = $self->spool_dir() my $filename = $self->spool_dir()
. join(":", time, $$, $transaction_counter++); . join(":", time, $$, $transaction_counter++);
return $filename; return $filename;
} }
sub temp_dir { sub temp_dir {
my $self = shift; my $self = shift;
@ -587,7 +587,7 @@ sub auth_mechanism {
my $self = shift; my $self = shift;
return (defined $self->{_auth_mechanism} ? $self->{_auth_mechanism} : "" ); return (defined $self->{_auth_mechanism} ? $self->{_auth_mechanism} : "" );
} }
1; 1;
__END__ __END__