Changeset 23530 for trunk/Ohana/src/opihi/pantasks/delete.c

Timestamp:

Mar 25, 2009, 11:56:09 AM (17 years ago)

Author:

eugene

Message:

upgrade threading/locking model for pantasks: changes merged from eam_branch_20090322

File:

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

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

@@ -11 +11 @@
     JobID = atoi (argv[2]);
 
+    JobTaskLock();
     job = FindJob (JobID);
     if (job == NULL) {
       gprint (GP_LOG, "job not found\n");
+      JobTaskUnlock();
       return (TRUE);
     }
@@ -21 +23 @@
         job[0].state = JOB_HUNG;
         if (VerboseMode()) gprint (GP_LOG, "child process %d is hung, cannot kill\n", job[0].pid);
+        JobTaskUnlock();
         return (FALSE);
       }
@@ -27 +30 @@
         job[0].state = JOB_HUNG;
         if (VerboseMode()) gprint (GP_LOG, "child process %d is hung, cannot kill\n", job[0].pid);
+        JobTaskUnlock();
         return (FALSE);
       }
@@ -32 +36 @@
     DeleteJob (job);
     gprint (GP_LOG, "job removed\n");
+    JobTaskUnlock();
     return (TRUE);
   }
@@ -41 +46 @@
 
 usage:
-    gprint (GP_ERR, "USAGE: delete job (JobID)\n");
-    gprint (GP_ERR, "USAGE: delete task (TaskName)\n");
-    return (FALSE);
+  gprint (GP_ERR, "USAGE: delete job (JobID)\n");
+  gprint (GP_ERR, "USAGE: delete task (TaskName)\n");
+  return (FALSE);
 }