Changeset 21379 for trunk/Ohana/src/opihi/pcontrol/check.c

Timestamp:

Feb 6, 2009, 10:37:19 AM (17 years ago)

Author:

eugene

Message:

report pending / process time with status; cycle over all hosts for each of NEED, WANT, ANY, OLDWANT; wait up to 10 sec for WANT before giving up

File:

• trunk/Ohana/src/opihi/pcontrol/check.c (modified) (4 diffs)

trunk/Ohana/src/opihi/pcontrol/check.c

@@ -3 +3 @@
 int check (int argc, char **argv) {
 
+  int N, Save;
   int JobID, HostID;
 
@@ -8 +9 @@
   Job *job = NULL;
   Host *host = NULL;
+
+  Save = FALSE;
+  if ((N = get_argument (argc, argv, "-save"))) {
+    remove_argument (N, &argc, argv);
+    Save = TRUE;
+  }
 
   if (argc != 3) {
@@ -39 +46 @@
         gprint (GP_LOG, "HOSTNAME NONE\n");
     }
+
+    if (Save) {
+        set_str_variable ("JOB_STATUS", GetJobStackName(job[0].stack));
+        set_int_variable ("JOB_EXITST", job[0].exit_status);
+        set_int_variable ("JOB_STDOUT_SIZE", job[0].stdout.size);
+        set_int_variable ("JOB_STDERR_SIZE", job[0].stderr.size);
+        set_variable ("JOB_DTIME", job[0].dtime);
+        set_str_variable ("JOB_HOSTNAME", job[0].hostname);
+        if (job[0].realhost) {
+            set_str_variable ("JOB_REALHOST", job[0].realhost);
+        } else {
+            set_str_variable ("JOB_REALHOST", "NONE");
+        }
+    }
+
     PushStack (stack, STACK_BOTTOM, job, job[0].JobID, job[0].argv[0]);
     return (TRUE);
@@ -53 +75 @@
     }
     gprint (GP_LOG, "host %s\n", GetHostStackName(host[0].stack));
+
+    if (Save) {
+        set_str_variable ("HOST_STATE", GetHostStackName(host[0].stack));
+    }
+
     PushStack (stack, STACK_BOTTOM, host, host[0].HostID, host[0].hostname);
     return (TRUE);