byterazor/qpsmtpd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use class logging where we can so we get proper log levels

Browse Source 
Accept all new incoming connections not just one


git-svn-id: https://svn.perl.org/qpsmtpd/branches/high_perf@415 958fd67b-6ff1-0310-b445-bb7760255be9
This commit is contained in:
Matt Sergeant 2005-05-12 12:57:05 +00:00
parent 726128aef6
commit 7633e038c1
1 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
qpsmtpd
View File

@ -251,14 +251,14 @@ sub run_as_server {
push @kids, spawn_child(); push @kids, spawn_child();
} }
$SIG{INT} = $SIG{TERM} = sub { $SIG{CHLD} = "IGNORE"; kill 2 => @kids; exit }; $SIG{INT} = $SIG{TERM} = sub { $SIG{CHLD} = "IGNORE"; kill 2 => @kids; exit };
::log(LOGDEBUG, "Listening on $PORT with $PROCS children $POLL"); $plugin_loader->log(LOGDEBUG, "Listening on $PORT with $PROCS children $POLL");
sleep while (1); sleep while (1);
} }
else { else {
if ($LineMode) { if ($LineMode) {
$SIG{INT} = $SIG{TERM} = \&HUNTSMAN; $SIG{INT} = $SIG{TERM} = \&HUNTSMAN;
} }
::log(LOGDEBUG, "Listening on $PORT with single process $POLL" . $plugin_loader->log(LOGDEBUG, "Listening on $PORT with single process $POLL" .
($LineMode ? " (forking server)" : "")); ($LineMode ? " (forking server)" : ""));
Qpsmtpd::PollServer->OtherFds(fileno($SERVER) => \&accept_handler, Qpsmtpd::PollServer->OtherFds(fileno($SERVER) => \&accept_handler,
fileno($CONFIG_SERVER) => \&config_handler, fileno($CONFIG_SERVER) => \&config_handler,
@ -274,7 +274,7 @@ sub run_as_server {
sub config_handler { sub config_handler {
my $csock = $CONFIG_SERVER->accept(); my $csock = $CONFIG_SERVER->accept();
if (!$csock) { if (!$csock) {
warn("accept failed on config server: $!"); # warn("accept failed on config server: $!");
return; return;
} }
binmode($csock, ':raw'); binmode($csock, ':raw');
@ -289,8 +289,14 @@ sub config_handler {
return; return;
} }
# Accept a new connection # Accept all new connections
sub accept_handler { sub accept_handler {
for (1..10000) {
last unless _accept_handler();
}
}
sub _accept_handler {
my $running; my $running;
if( $LineMode ) { if( $LineMode ) {
$running = scalar keys %childstatus; $running = scalar keys %childstatus;
@ -299,7 +305,7 @@ sub accept_handler {
my $descriptors = Danga::Client->DescriptorMap; my $descriptors = Danga::Client->DescriptorMap;
$running = scalar keys %$descriptors; $running = scalar keys %$descriptors;
} }
while ($running >= $MAXCONN) { if ($running >= $MAXCONN) {
::log(LOGINFO,"Too many connections: $running >= $MAXCONN."); ::log(LOGINFO,"Too many connections: $running >= $MAXCONN.");
return; return;
} }
@ -326,7 +332,7 @@ sub accept_handler {
if ($PAUSED) { if ($PAUSED) {
$client->write("451 Sorry, this server is currently paused\r\n"); $client->write("451 Sorry, this server is currently paused\r\n");
$client->close; $client->close;
return; return 1;
} }
if ($MAXCONNIP) { if ($MAXCONNIP) {
@ -344,22 +350,22 @@ sub accept_handler {
} }
if ($num_conn > $MAXCONNIP) { if ($num_conn > $MAXCONNIP) {
::log(LOGINFO,"Too many connections from $rem_ip: " $client->log(LOGINFO,"Too many connections from $rem_ip: "
."$num_conn > $MAXCONNIP. Denying connection."); ."$num_conn > $MAXCONNIP. Denying connection.");
$client->write("451 Sorry, too many connections from $rem_ip, try again later\r\n"); $client->write("451 Sorry, too many connections from $rem_ip, try again later\r\n");
$client->close; $client->close;
return; return 1;
} }
::log(LOGINFO, "accepted connection $running/$MAXCONN ($num_conn/$MAXCONNIP) from $rem_ip"); $client->log(LOGINFO, "accepted connection $running/$MAXCONN ($num_conn/$MAXCONNIP) from $rem_ip");
} }
my $rc = $client->start_conversation; my $rc = $client->start_conversation;
if ($rc != DONE) { if ($rc != DONE) {
$client->close; $client->close;
return; return 1;
} }
$client->watch_read(1); $client->watch_read(1);
return; return 1;
} }
# fork-per-connection mode # fork-per-connection mode
@ -378,7 +384,7 @@ sub accept_handler {
."$num_conn > $MAXCONNIP. Denying connection."); ."$num_conn > $MAXCONNIP. Denying connection.");
print $csock "451 Sorry, too many connections from $rem_ip, try again later\r\n"; print $csock "451 Sorry, too many connections from $rem_ip, try again later\r\n";
close $csock; close $csock;
return; return 1;
} }
} }
@ -408,7 +414,7 @@ sub accept_handler {
$client->watch_read(1); $client->watch_read(1);
} }
::log(LOGDEBUG, "Finished with child %d.\n", fileno($csock)) $client->log(LOGDEBUG, "Finished with child %d.\n", fileno($csock))
if $DEBUG; if $DEBUG;
$client->close(); $client->close();