Changeset 4684 for trunk/Ohana/src/opihi/pantasks/LocalJob.c

Timestamp:

Jul 31, 2005, 8:04:11 AM (21 years ago)

Author:

eugene

Message:

task/job list cleanup, fixing kill/delete

File:

• trunk/Ohana/src/opihi/pantasks/LocalJob.c (modified) (3 diffs)

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

@@ -102 +102 @@
   int result, waitstatus;
 
+  fprintf (stderr, "checking on %d\n", job[0].pid);
+
   /* check local job status */
   result = waitpid (job[0].pid, &waitstatus, WNOHANG);
@@ -135 +137 @@
         exit (1);
       }
+      fprintf (stderr, "waited for %d\n", result);
       
       if (WIFEXITED(waitstatus)) {
@@ -151 +154 @@
   return;
 }
+
+int KillLocalJob (Job *job) {
+
+  int i, result, waitstatus;
+
+  if (job[0].state != JOB_BUSY) return (TRUE);
+
+  /* send SIGTERM signal to job */
+  kill (job[0].pid, SIGTERM);
+  result = 0;
+  for (i = 0; (i < 10) && (result == 0); i++) {
+    usleep (10000);  /* 10 ms is min */
+    result = waitpid (job[0].pid, &waitstatus, WNOHANG);
+  }
+  if (result) return (TRUE);
+
+  /* send SIGKILL signal to job */
+  kill (job[0].pid, SIGKILL);
+  result = 0;
+  for (i = 0; (i < 10) && (result == 0); i++) {
+    usleep (10000);  /* 10 ms is min */
+    result = waitpid (job[0].pid, &waitstatus, WNOHANG);
+  }
+  if (result) return (TRUE);
+
+  /* total failure, don't reset */
+  return (FALSE);
+}
+