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

fix for 2874219, handling large amounts of data in non-streaming mode

Browse Source 
git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@4439 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
This commit is contained in:
lissav 2009-10-22 13:53:49 +00:00
parent 0ddccda28f
commit 66a4ef81e6
1 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
xCAT-server/lib/xcat/plugins/xdsh.pm
View File

@ -291,7 +291,6 @@ sub process_request
my $args = $request->{arg};
my $envs = $request->{env};
my $rsp = {};
# get the Environment Variables and set them in the current environment
foreach my $envar (@{$request->{env}})
{
@ -334,16 +333,30 @@ sub xdsh
{
my ($nodes, $args, $callback, $command, $noderange) = @_;
my $rsp = {};
# parse dsh input
my @local_results =
xCAT::DSHCLI->parse_and_run_dsh($nodes, $args, $callback,
$command, $noderange);
push @{$rsp->{data}}, @local_results;
xCAT::MsgUtils->message("D", $rsp, $callback);
#print $local_results[0];
#print "\n";
#`echo $local_results[0] >> /tmp/lissa/testxdsh`;
my $maxlines=10000;
my $arraylen=@local_results;
my $rsp = {};
my $i=0;
my $j;
while ($i < $arraylen) {
for ($j = 0 ; $j < $maxlines ; $j++) {
if ($i > $arraylen) {
last;
} else {
$rsp->{data}->[$j]= $local_results[$i]; # send max lines
}
$i++
}
xCAT::MsgUtils->message("D", $rsp, $callback);
}
return;
}