arif/xcat-core
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Have xCAT more aggressively drain the listen queue on the main listening socket.

Browse Source 
This change manages to have xCAT successfully field a large amount of incoming connections with a relatively small listen queue.

git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/branches/2.7@11962 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
This commit is contained in:
jbjohnso 2012-03-23 12:55:35 +00:00
parent 03ccf3c095
commit bd4af1093f
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
xCAT-server/sbin/xcatd
View File

@ -823,6 +823,7 @@ while (not $listener and $retry) {
}
sleep(0.05);
}
my $listenwatcher = IO::Select->new($listener);
unless ($listener) {
kill 2, $pid_UDP;
@ -840,13 +841,28 @@ open($mainpidfile,">","/tmp/xcat/mainservice.pid"); #if here, everyone else has
print $mainpidfile $$;
close($mainpidfile);
closelog();
my @pendingconnections;
my $tconn;
until ($quit) {
$SIG{CHLD} = \&ssl_reaper; #set here to ensure that signal handler is not corrupted during loop
next unless my $cnnection=$listener->accept;
my $connection;
while ($sslclients > $maxsslclients) { #THROTTLE
sleep 0.1; #Keep processor utilization down
if (@pendingconnections) {
while ($listenwatcher->can_read(0)) { #grab everything we ca
$tconn = $listener->accept;
unless ($tconn) { next; }
push @pendingconnections,$tconn;
}
} else {
$tconn = $listener->accept;
unless ($tconn) { next; }
push @pendingconnections,$tconn;
}
unless (scalar @pendingconnections) { next; }
if ($sslclients > $maxsslclients) { #THROTTLE
$listenwatcher->can_read(0.1); #when next connection tries to come in or a tenth of a second, whichever comes first
next; #just keep pulling things off listen queue onto our own
}
my $cnnection=shift @pendingconnections;
my $connection;
my $child = xCAT::Utils->xfork(); #Yes we fork, IO::Socket::SSL is not threadsafe..
if ($child) {
$immediatechildren{$child}=1;