Changeset 20047 for trunk/Ohana/src/opihi/pcontrol/JobOps.c

Timestamp:

Oct 10, 2008, 12:51:04 PM (18 years ago)

Author:

eugene

Message:

allow job stdout / stderr from pclient to arrive slowly

File:

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

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

@@ -175 +175 @@
 }
 
+int InitJobOutput (JobOutput *output) {
+
+  output[0].size = 0;
+  output[0].requested = FALSE;
+  output[0].completed = FALSE;
+  InitIOBuffer (&output[0].buffer, 0x1000);
+
+  return TRUE;
+}
+
+int ResetJobOutput (JobOutput *output) {
+
+  output[0].size = 0;
+  output[0].requested = FALSE;
+  output[0].completed = FALSE;
+  FlushIOBuffer (&output[0].buffer);
+
+  return TRUE;
+}
+
 IDtype AddJob (char *hostname, JobMode mode, int timeout, int argc, char **argv) {
 
@@ -189 +209 @@
   job[0].exit_status = 0;
   job[0].Reset    = FALSE;
-  job[0].stdout_size = 0;
-  job[0].stderr_size = 0;
+
+  InitJobOutput (&job[0].stdout);
+  InitJobOutput (&job[0].stderr);
 
   job[0].mode     = mode;
@@ -196 +217 @@
   job[0].state = 0;
   job[0].stack = 0;
-
-  /* do this step on start? */
-  InitIOBuffer (&job[0].stdout_buff, 0x1000);
-  InitIOBuffer (&job[0].stderr_buff, 0x1000);
 
   job[0].dtime = 0.0;
@@ -233 +250 @@
   FREE (job[0].argv);
 
-  FreeIOBuffer (&job[0].stdout_buff);
-  FreeIOBuffer (&job[0].stderr_buff);
+  FreeIOBuffer (&job[0].stdout.buffer);
+  FreeIOBuffer (&job[0].stderr.buffer);
 
   FREE (job);