Changeset 96

Timestamp:

Jan 26, 2013, 10:58:11 AM (12 years ago)

Author:

g7moreau

Message:

• Change sleep function (do not work) with manual timer

File:

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

trunk/oarutils/oar-dispatch

@@ -10 +10 @@
 use Coro::Signal;
 use Coro::Semaphore;
-use Coro::Timer qw(sleep);
+use Coro::AnyEvent;
 use Coro::Handle;
 use IO::File;
@@ -206 +206 @@
          }
       cede;
-      
+
       # asynchrone guard for job end
       async {
-         my $job_id = shift;
+         my $timer;
          GUARD:
          while () {
-            sleep 15; # async, do not re-launch oarstat to fast
+            cede;
+            $timer = AE::now + 5;
+            while ( AE::now < $timer ) { AE::now_update; cede; }
             my $is_finish = `oarstat -s -j $job_id`;
             chomp $is_finish;
@@ -231 +233 @@
          $job_todo->down;
          delete $scheduled{$job_id};
-         } $job_id;
+         }
       }
    };