Changeset 23530 for trunk/Ohana/src/opihi/pantasks/task_stdout.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/task_stdout.c (modified) (6 diffs)

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

@@ -11 +11 @@
   }
 
+  JobTaskLock();
   task = GetNewTask ();
   if (task == NULL) {
@@ -16 +17 @@
     if (task == NULL) {
       gprint (GP_ERR, "ERROR: not defining or running a task\n");
+      JobTaskUnlock();
       return (FALSE);
     }
@@ -21 +23 @@
   if (task[0].stdout_dump != NULL) free (task[0].stdout_dump);
   task[0].stdout_dump = strcreate (argv[1]);
+  JobTaskUnlock();
   return (TRUE);
 }
@@ -34 +37 @@
   }
 
+  JobTaskLock();
   task = GetNewTask ();
   if (task == NULL) {
@@ -39 +43 @@
     if (task == NULL) {
       gprint (GP_ERR, "ERROR: not defining or running a task\n");
+      JobTaskUnlock();
       return (FALSE);
     }
@@ -44 +49 @@
   if (task[0].stderr_dump != NULL) free (task[0].stderr_dump);
   task[0].stderr_dump = strcreate (argv[1]);
+  JobTaskUnlock();
   return (TRUE);
 }