Changeset 93 for trunk/oarutils

Timestamp:

Jan 24, 2013, 3:50:46 PM (11 years ago)

Author:

g7moreau

Message:

• Create a thread by job to catch the end of that job

File:

• trunk/oarutils/oar-dispatch (modified) (2 diffs)

trunk/oarutils/oar-dispatch

@@ -10 +10 @@
 use Coro::Signal;
 use Coro::Semaphore;
-#use Coro::Timer qw(sleep);
+use Coro::Timer qw(sleep);
 
 my $task = 0;
@@ -76 +76 @@
          }
       cede;
+      
+      # asynchrone guard for job end
+      async {
+         my $job_id = shift;
+         GUARD:
+         while () {
+            sleep 15; # async, do not re-launch oarstat to fast
+            my $is_finish = `oarstat -s -j $job_id`;
+            chomp $is_finish;
+            last GUARD if $is_finish =~ m/Terminated/;
+            }
+         delete $scheduled{$job_id};
+         $job_active->down;
+         $job_todo->down;
+         } $job_id;
       }
-   }
+   };
 
 async {
    while () {
-      for my $job_id (keys %scheduled) {
-         my $is_finish = `oarstat -s -j $job_id`;
-         chomp $is_finish;
-         if ($is_finish =~ m/Terminated/) {
-            delete $scheduled{$job_id};
-            $job_active->down;
-            $job_todo->down;
-            }
-         cede;
-         }
+#      for my $job_id (keys %scheduled) {
+#         my $is_finish = `oarstat -s -j $job_id`;
+#         chomp $is_finish;
+#         if ($is_finish =~ m/Terminated/) {
+#            delete $scheduled{$job_id};
+#            $job_active->down;
+#            $job_todo->down;
+#            }
+#         cede;
+#         }
 
       $finished->send if $job_todo->count == 0;
       cede;
       }
-   }
+   };
 
 cede;