Changeset 113

Timestamp:

Jun 22, 2015, 7:09:25 PM (10 years ago)

Author:

g7moreau

Message:

• Delay launch of each subjob by one second

File:

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

trunk/oarutils/oar-parexec

@@ -29 +29 @@
 my $sig_transmit;
 my $sig_checkpoint = 'USR2';
+my $job_launch_brake = 1; # one second time brake
 
 Getopt::Long::GetOptions(
@@ -208 +209 @@
 # asynchrone start job block
 async {
+   my $timer;
    JOB:
    for my $job (@job) {
@@ -228 +230 @@
          }
 
+      # wait to not re-launch oarstat to fast
+      # equivalent to sleep $job_launch_brake
+      $timer = AE::now + $job_launch_brake;
+      while ( AE::now < $timer ) {
+         # force update of AE time
+         AE::now_update;
+         cede;
+         }
+
       # take job ressource
       my $job_ressource = $ressources->get;
@@ -242 +253 @@
       $fh = unblock $fh;
 
-      my $msg = sprintf "start job %${job_name_maxlen}s / %5i at %s on node %s\n",
-         $job_name, $job_pid, time, $job_ressource;
+      my $msg = sprintf "start job %${job_name_maxlen}s / %5i at %s oar job %i on node %s\n",
+         $job_name, $job_pid, time, $ENV{OAR_JOB_ID}, $job_ressource;
       $log_h->print($msg) if $logtrace;
       print($msg) if $verbose;
@@ -302 +313 @@
          # non blocking PID test
          if (waitpid($job_pid, WNOHANG)) {
-            my $msg = sprintf "end   job %${job_name_maxlen}s / %5i at %s on node %s\n",
+            my $msg = sprintf "end   job %${job_name_maxlen}s / %5i at %s oar job %i on node %s\n",
                $scheduled{$job_pid}->{name},
-               $job_pid, time, $scheduled{$job_pid}->{ressource};
+               $job_pid, time, $ENV{OAR_JOB_ID}, $scheduled{$job_pid}->{ressource};
 
             # Job non finish, just suspend if received checkpoint signal