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

Rework pulling packets off the socket, less delay in moving data to a more stable data structure

Browse Source 
git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@13346 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
This commit is contained in:
jbjohnso
2012-07-25 20:19:20 +00:00
parent 825e410d16
commit f19277afe8
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
xCAT-server/lib/perl/xCAT/IPMI.pm
View File

@@ -391,8 +391,20 @@ sub waitforrsp {
if ($select->can_read($timeout)) {
while ($select->can_read(0)) {
$peerport = $socket->recv($data,1500,0);
route_ipmiresponse($peerport,unpack("C*",$data));
my @ipmiq=();
while ($select->can_read(0)) {
$peerport = $socket->recv($data,1500,0);
push @ipmiq,[$peerport,$data];
}
while (@ipmiq) {
my $datagram = shift @ipmiq;
($peerport,$data) = @$datagram;
route_ipmiresponse($peerport,unpack("C*",$data));
while ($select->can_read(0)) {
$peerport = $socket->recv($data,1500,0);
push @ipmiq,[$peerport,$data];
}
}
}
}
return scalar (keys %sessions_waiting);
@@ -401,7 +413,7 @@ sub waitforrsp {
sub timedout {
my $self = shift;
$self->{timeout} = $self->{timeout}+1;
if ($self->{timeout} > 4) { #giveup, really
if ($self->{timeout} > 5) { #giveup, really
$self->{timeout}=2;
my $rsp={};
$rsp->{error} = "timeout";