Changeset 4714 for trunk/Ohana/src/opihi/pantasks/JobOps.c

Timestamp:

Aug 5, 2005, 9:53:49 AM (21 years ago)

Author:

eugene

Message:

fixed some memory leaks, pushed extra init functions into lib inits

File:

• trunk/Ohana/src/opihi/pantasks/JobOps.c (modified) (4 diffs)

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

@@ -39 +39 @@
   for (i = 0; i < Njobs; i++) {
     if (jobs[i][0].JobID == JobID) {
+      return (jobs[i]);
+    }
+  }
+  return (NULL);
+}  
+
+/* return job with given controller Job ID */
+Job *FindControllerJob (int JobID) {
+
+  int i;
+
+  /* return job with matching JobID */
+  for (i = 0; i < Njobs; i++) {
+    if (jobs[i][0].mode == JOB_LOCAL) continue;
+    if (jobs[i][0].pid  == JobID) {
       return (jobs[i]);
     }
@@ -96 +111 @@
      need to have matched entries to these quantites in the job structure */
 
+  InitIOBuffer (&job[0].stdout, 0x100);
+  InitIOBuffer (&job[0].stderr, 0x100);
+
   jobs[Njobs] = job;
   Njobs ++;
@@ -117 +135 @@
   }
   free (job[0].argv);
+
+  FreeIOBuffer (&job[0].stdout);
+  FreeIOBuffer (&job[0].stderr);
+  free (job);
   return;
 }
@@ -161 +183 @@
   gettimeofday (&job[0].start, (void *) NULL);
   job[0].last = job[0].start;
-  
+  job[0].state = JOB_PENDING;
   return (TRUE);
 }