Ignore:
Timestamp:
Dec 4, 2011, 11:17:31 PM (12 years ago)
Author:
g7moreau
Message:
  • Add OAR checkpointing!
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/oarutils/oar-parexec

    r38 r39  
    104104my %scheduled = ();
    105105
     106my $oar_checkpoint = new Coro::Semaphore 0;
     107$SIG{USR2} = sub { $oar_checkpoint->up };
     108
    106109async {
    107110   for my $job (@job) {
     
    117120
    118121      my $job_ressource = $ressources->get;
     122
     123                last if $oar_checkpoint->count > 0;
    119124
    120125      my ($node_connect) = split ',', $job_ressource;
     
    175180         }
    176181
     182                $finished->send  if $oar_checkpoint->count > 0 and keys(%scheduled) == 0;
     183
    177184      $finished->send if $job_todo->count == 0;
    178185      cede;
Note: See TracChangeset for help on using the changeset viewer.