Changeset 6249 for trunk/Ohana/src/opihi/pantasks/CheckJobs.c

Timestamp:

Jan 29, 2006, 9:36:21 AM (20 years ago)

Author:

eugene

Message:

adding to queue options, psched handling

File:

• trunk/Ohana/src/opihi/pantasks/CheckJobs.c (modified) (5 diffs)

trunk/Ohana/src/opihi/pantasks/CheckJobs.c

@@ -6 +6 @@
   Macro *macro;
   int i, status;
+  char varname[64];
 
   /** test all jobs: ready to test?  finished? **/
@@ -30 +31 @@
         PushNamedQueue ("stdout", job[0].stdout.buffer);
         PushNamedQueue ("stderr", job[0].stderr.buffer);
+        /* set taskarg variables */
+        for (i = 0; i < job[0].argc; i++) {
+            sprintf (varname, "taskarg:%d", i);
+            set_str_variable (varname, job[0].argv[i]);
+        }
+        set_int_variable ("taskarg:n", job[0].argc);
+
         /* XXX this will break on 0 values in output streams */
         /* perhaps define PushNamedQueueBuffer */
@@ -43 +51 @@
         PushNamedQueue ("stdout", job[0].stdout.buffer);
         PushNamedQueue ("stderr", job[0].stderr.buffer);
+        /* set taskarg variables */
+        for (i = 0; i < job[0].argc; i++) {
+            sprintf (varname, "taskarg:%d", i);
+            set_str_variable (varname, job[0].argv[i]);
+        }
+        set_int_variable ("taskarg:n", job[0].argc);
+
+        /* update the exit status counters */
+        if (job[0].exit_status) {
+            job[0].task[0].Nfailure ++;
+        } else {
+            job[0].task[0].Nsuccess ++;
+        }
+
         /* run corresponding task[0].exit macro, if it exists */
         macro = job[0].task[0].defexit;
@@ -68 +90 @@
       if (GetTaskTimer(job[0].start) < job[0].task[0].timeout_period) continue;
       if (VerboseMode()) fprintf (stderr, "timeout on %s\n", job[0].task[0].name);
+
+      /* update the timeout counter */
+      job[0].task[0].Ntimeout ++;
+
       if (!KillLocalJob (job)) {
         job[0].state = JOB_HUNG;
@@ -73 +99 @@
         continue;
       }
+
+      /* set taskarg variables */
+      for (i = 0; i < job[0].argc; i++) {
+          sprintf (varname, "taskarg:%d", i);
+          set_str_variable (varname, job[0].argv[i]);
+      }
+      set_int_variable ("taskarg:n", job[0].argc);
+
+
       /* run task[0].timeout macro, if it exists */
       if (job[0].task[0].timeout != NULL) {