Changeset 39

Timestamp:

Dec 4, 2011, 11:17:31 PM (13 years ago)

Author:

g7moreau

Message:

• Add OAR checkpointing!

File:

• trunk/oarutils/oar-parexec (modified) (3 diffs)

trunk/oarutils/oar-parexec

@@ -104 +104 @@
 my %scheduled = ();
 
+my $oar_checkpoint = new Coro::Semaphore 0;
+$SIG{USR2} = sub { $oar_checkpoint->up };
+
 async {
    for my $job (@job) {
@@ -117 +120 @@
 
       my $job_ressource = $ressources->get;
+
+                last if $oar_checkpoint->count > 0;
 
       my ($node_connect) = split ',', $job_ressource;
@@ -175 +180 @@
          }
 
+                $finished->send  if $oar_checkpoint->count > 0 and keys(%scheduled) == 0;
+
       $finished->send if $job_todo->count == 0;
       cede;