Changeset 250

Show
Ignore:
Timestamp:
09/01/09 11:26:15 (3 months ago)
Author:
cholt
Message:

fix run_all method and next_chunk method in MpiTiers?

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • lib/Process/MpiTiers.pm

    r165 r250  
    121121sub next_chunk { 
    122122   my $self = shift; 
    123    my $level = $self->{LEVEL}{CURRENT}; 
    124123 
    125124   return undef if ($self->terminated || $self->failed); 
    126125 
    127    $self->_next_level if($self->_level_finished); 
     126   #handle levels that have no chunks to run 
     127   while($self->_level_finished){ 
     128       $self->_next_level; 
     129       $self->_load_chunks; 
     130   } 
     131 
     132   #handle case where level needs to be initialized 
    128133   $self->_load_chunks if(! $self->_level_started); 
     134 
     135   #get level after doing any necessary moves to next level 
     136   my $level = $self->{LEVEL}{CURRENT}; 
    129137 
    130138   if (my $chunk = shift @{$self->{LEVEL}{$level}{CHUNKS}}) {