Changeset 97 for trunk/oarutils

Timestamp:

Jan 26, 2013, 11:06:54 AM (11 years ago)

Author:

g7moreau

Message:

• Clean code and add comments

File:

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

trunk/oarutils/oar-dispatch

@@ -24 +24 @@
 my $sig_transmit;
 my $sig_checkpoint = 'USR2';
+my $brake = 5; # five second time brake
 
 Getopt::Long::GetOptions(
@@ -36 +37 @@
    'transmit'     => \$sig_transmit,
    'kill=s'       => \$sig_checkpoint,
+   'brake=i'      => \$brake,
    ) || pod2usage(-verbose => 0);
 pod2usage(-verbose => 2) if $help;
@@ -213 +215 @@
          while () {
             cede;
-            $timer = AE::now + 5;
-            while ( AE::now < $timer ) { AE::now_update; cede; }
+
+            # wait to not re-launch oarstat to fast
+            # equivalent to sleep $brake
+            $timer = AE::now + $brake;
+            while ( AE::now < $timer ) {
+               # force update of AE time
+               AE::now_update;
+               cede;
+               }
+
             my $is_finish = `oarstat -s -j $job_id`;
             chomp $is_finish;
@@ -223 +233 @@
             $scheduled{$job_id}->{name}, $job_id, time;
 
-            # Job non finish, just suspend if received checkpoint signal
-            $msg =~ s/^end\s+job/suspend job/
-               if $sig_transmit and $oar_checkpoint->count() > 0;
-
-            $log_h->print($msg) if $logtrace;
-            print($msg) if $verbose;
+         # Job non finish, just suspend if received checkpoint signal
+         $msg =~ s/^end\s+job/suspend job/
+            if $sig_transmit and $oar_checkpoint->count() > 0;
+
+         $log_h->print($msg) if $logtrace;
+         print($msg) if $verbose;
 
          $job_active->down;
@@ -235 +245 @@
          }
       }
-   };
+   }
 
 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;
-#         }
-
       # checkpointing ! just finishing running job and quit
       $finished->send if $oar_checkpoint->count() > 0 and scalar(keys(%scheduled)) == 0;
@@ -256 +255 @@
       cede;
       }
-   };
+   }
 
 cede;