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

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

@@ -12 +12 @@
     if (argc != 1) goto usage;
 
+    JobTaskLock();
     task = GetNewTask ();
     if (task == NULL) {
       gprint (GP_ERR, "ERROR: not defining or running a task\n");
+      JobTaskUnlock();
       return (FALSE);
     }
@@ -20 +22 @@
     task[0].Nranges = 0;
     REALLOCATE (task[0].ranges, TimeRange, 1);
+    JobTaskUnlock();
     return (TRUE);
   } 
@@ -40 +43 @@
 
   if (argc != 3) goto usage;
-
-  task = GetNewTask ();
-  if (task == NULL) {
-    gprint (GP_ERR, "ERROR: not defining or running a task\n");
-    return (FALSE);
-  }
 
   /* test for Mon[@HH:MM:SS] - both must match */
@@ -83 +80 @@
 
 valid:
+  JobTaskLock();
+  task = GetNewTask ();
+  if (task == NULL) {
+    gprint (GP_ERR, "ERROR: not defining or running a task\n");
+    JobTaskUnlock();
+    return (FALSE);
+  }
+
   N = task[0].Nranges;
   task[0].Nranges ++;
@@ -88 +93 @@
   
   task[0].ranges[N] = range;
+  JobTaskUnlock();
   return (TRUE);