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

Staggered forking ssh connects to HMC/IVM - added site.maxssh to control

Browse Source 
git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@1243 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
This commit is contained in:
sakolish 2008-05-01 19:57:58 +00:00
parent 5db0602c89
commit 5d4aa10f7a
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
perl-xCAT-2.0/xCAT/PPC.pm
View File

@ -83,6 +83,7 @@ sub process_command {
my $request = shift;
my $maxp = 64;
my $maxssh = 10;
my %nodes = ();
my $callback = $request->{callback};
my $sitetab = xCAT::Table->new( 'site' );
@ -101,6 +102,10 @@ sub process_command {
if ( defined($ent) ) {
$timeout = $ent->{value};
}
($ent) = $sitetab->getAttribs({ key=>'maxssh'},'value');
if ( defined($ent) ) {
$maxssh = $ent->{value};
}
}
if ( exists( $request->{verbose} )) {
$start = Time::HiRes::gettimeofday();
@ -118,11 +123,25 @@ sub process_command {
my $children = 0;
$SIG{CHLD} = sub { while (waitpid(-1, WNOHANG) > 0) { $children--; } };
my $fds = new IO::Select;
my $hw;
my $sessions;
foreach ( @$nodes ) {
while ( $children > $maxp ) {
Time::HiRes::sleep(0.1);
}
###################################
# sleep between connects to same
# HMC/IVM so as not to overwelm it
###################################
if ( $hw ne @$_[0] ) {
$sessions = 1;
} elsif ( $sessions++ >= $maxssh ) {
Time::HiRes::sleep(0.1);
$sessions = 1;
}
$hw = @$_[0];
my $pipe = fork_cmd( @$_[0], @$_[1], $request, $timeout );
if ( $pipe ) {
$fds->add( $pipe );