Changeset 13544

Timestamp:

May 30, 2007, 12:15:19 PM (19 years ago)

Author:

eugene

Message:

send pantasks server stdout/stderr to named log files

Location:

trunk/Ohana/src/opihi/pantasks

Files:

• ListenClients.c (modified) (3 diffs)
• controller_threads.c (modified) (1 diff)
• input_threads.c (modified) (1 diff)
• job_threads.c (modified) (1 diff)
• task_threads.c (modified) (1 diff)

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

@@ -62 +62 @@
   
   int i, Ncurrent, Nmax, status, Nread;
-  char *line;
+  char *line, log_stdout[128], log_stderr[128];
   fd_set fdSet;
   struct timeval timeout;
@@ -69 +69 @@
   InitClients ();
   gprintInit ();  // each thread needs to init the printing system
+
+  // define server output log files
+  if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+    gprintSetFile (GP_LOG, log_stdout);
+  } else {
+    strcpy (log_stdout, "stdout");
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+      gprintSetFile (GP_ERR, log_stderr);
+  } else {
+    strcpy (log_stderr, "stderr");
+  }
 
   while (1) {
@@ -146 +158 @@
         
         /* clear and reset the output buffers */
-        gprintSetFile (GP_LOG, "stdout");
-        gprintSetFile (GP_ERR, "stderr");
+        gprintSetFile (GP_LOG, log_stdout);
+        gprintSetFile (GP_ERR, log_stderr);
       }
       free (line);

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

@@ -14 +14 @@
 void *CheckControllerThread (void *data) {
 
+  char log_stdout[128], log_stderr[128];
+
   gprintInit ();  // each thread needs to init the printing system
+  // define server output log files
+  if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+      gprintSetFile (GP_LOG, log_stdout);
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+      gprintSetFile (GP_ERR, log_stderr);
+  }
+
   while (1) {
 

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

@@ -14 +14 @@
 void *CheckInputsThread (void *data) {
 
+  char log_stdout[128], log_stderr[128];
+
   gprintInit ();  // each thread needs to init the printing system
+
+  // define server output log files
+  if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+      gprintSetFile (GP_LOG, log_stdout);
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+      gprintSetFile (GP_ERR, log_stderr);
+  }
+
   while (1) {
 

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

@@ -14 +14 @@
 void *CheckJobsThread (void *data) {
 
+  char log_stdout[128], log_stderr[128];
   float next_timeout;
 
   gprintInit ();  // each thread needs to init the printing system
+
+  // define server output log files
+  if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+      gprintSetFile (GP_LOG, log_stdout);
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+      gprintSetFile (GP_ERR, log_stderr);
+  }
+
   while (1) {
 

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

@@ -15 +15 @@
 
   float next_timeout;
+  char log_stdout[128], log_stderr[128];
 
   gprintInit ();  // each thread needs to init the printing system
+
+  // define server output log files
+  if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+      gprintSetFile (GP_LOG, log_stdout);
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+      gprintSetFile (GP_ERR, log_stderr);
+  }
+
   while (1) {