Changeset 10651

Timestamp:

Dec 12, 2006, 12:54:20 AM (19 years ago)

Author:

eugene

Message:

HUNG jobs goto PENDING, not BUSY

Location:

trunk/Ohana/src/opihi/pcontrol

Files:

• CheckBusyJob.c (modified) (2 diffs)
• CheckSystem.c (modified) (1 diff)
• KillJob.c (modified) (1 diff)

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

@@ -38 +38 @@
       host[0].job = NULL;
       PutHost (host, PCONTROL_HOST_DOWN, STACK_BOTTOM);
-      PutJobSetState (job, PCONTROL_JOB_BUSY, STACK_BOTTOM, PCONTROL_JOB_HUNG);
+      PutJobSetState (job, PCONTROL_JOB_PENDING, STACK_BOTTOM, PCONTROL_JOB_HUNG);
       FreeIOBuffer (&buffer);
       return (TRUE);
@@ -79 +79 @@
   sscanf (p, "%*s %d", &job[0].stderr_size);
 
+  if (job[0].stdout_size > 100000) abort();
+  if (job[0].stderr_size > 100000) abort();
+
   // job has exited : move to DONE stack 
   // the host is still BUSY until job output is gathered (int CheckDoneJob)

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

@@ -140 +140 @@
     }
     host = (Host *) job[0].host;
+    ASSERT (host != NULL, "host is NULL");
     RemoveStackByID (hoststack, host[0].HostID);
     UnlockStack (hoststack);

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

@@ -32 +32 @@
       host[0].job = NULL;
       PutHost (host, PCONTROL_HOST_DOWN, STACK_BOTTOM);
-      PutJobSetState (job, PCONTROL_JOB_BUSY, STACK_BOTTOM, PCONTROL_JOB_HUNG);
+      PutJobSetState (job, PCONTROL_JOB_PENDING, STACK_BOTTOM, PCONTROL_JOB_HUNG);
       FreeIOBuffer (&buffer);
       return (TRUE);