Changeset 28003 for branches/pap/Ohana/src/opihi/pantasks/pantasks_server.c.in

Timestamp:

May 18, 2010, 12:49:05 PM (16 years ago)

Author:

eugene

Message:

merging changes from trunk into branches/pap

Location:

branches/pap

Files:

• . (modified) (1 prop)
• Ohana (modified) (1 prop)
• Ohana/src/opihi/pantasks/pantasks_server.c.in (modified) (4 diffs)

branches/pap/Ohana/src/opihi/pantasks/pantasks_server.c.in

@@ -13 +13 @@
 */
 
+void special_init (int *argc, char **argv);
+
 /* program-dependent initialization */
 int main (int argc, char **argv) {
   
-  char log_stdout[128], log_stderr[128];
+  char log_stdout[1024], log_stderr[1024];
   pthread_t JobsAndTasksThread;
   pthread_t clientsThread;
@@ -23 +25 @@
   SockAddress Address;
 
-  general_init (&argc, argv);
+  strcpy (log_stdout, "stdout");
+  strcpy (log_stderr, "stderr");
 
-  // define server output log files
+  special_init (&argc, argv);
+
+  // 
+  stdin = freopen ("/dev/zero", "r", stdin);
+
+  // this block redirects the actual stderr, stdout steams to the output files
   if (VarConfig ("PANTASKS_SERVER_STDOUT", "%s", log_stdout) != NULL) {
+    if (strcmp (log_stdout, "stdout")) {
+      stdout = freopen (log_stdout, "a", stdout);
+      if (!stdout) {
+        fprintf (stderr, "failed to open %s for output\n", log_stdout);
+        exit (1);
+      }
+    }
+  }
+  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+    if (strcmp (log_stderr, "stderr")) {
+      stderr = freopen (log_stderr, "a", stderr);
+      if (!stderr) {
+        fprintf (stdout, "failed to open %s for error output\n", log_stderr);
+        exit (1);
+      }
+    }
+  }
+
+  /* init for main (or only) thread */
+  gprintInit ();
+
+  // this block changes the target of the gprint output streams
+  if (strcmp (log_stdout, "stdout")) {
       gprintSetFileThisThread (GP_LOG, log_stdout);
   }
-  if (VarConfig ("PANTASKS_SERVER_STDERR", "%s", log_stderr) != NULL) {
+  if (strcmp (log_stderr, "stderr")) {
       gprintSetFileThisThread (GP_ERR, log_stderr);
   }
@@ -41 +72 @@
   InitBasic ();
   InitData ();
+  InitAstro ();
   InitPantasksServer ();
 
@@ -105 +137 @@
 void welcome () { }
 void program_init (int *argc, char **argv) {}
+
+// I need to do things in a different order here to have config / freopen / gprint sequenced correctly
+void special_init (int *argc, char **argv) {
+
+  /* init srand for rnd numbers elsewhere */
+  long A, B;
+  A = time(NULL);
+  for (B = 0; A == time(NULL); B++);
+  srand48(B);
+ 
+  /* set signals */
+  signal (SIGINT, SIG_IGN);
+
+  init_error ();
+
+  /* load config data (.ptolemyrc) */
+  if (!ConfigInit (argc, argv)) {
+    fprintf (stderr, "can't find (.ptolemyrc,ptolemy.rc) config file. some functions will be unavailable\n");
+  }
+
+  return;
+}