Changeset 7952 for trunk/Ohana/src/opihi/pantasks/pantasks_server.c

Timestamp:

Jul 23, 2006, 3:05:21 PM (20 years ago)

Author:

eugene

Message:

adding working threads to server/client mode

File:

• trunk/Ohana/src/opihi/pantasks/pantasks_server.c (modified) (3 diffs)

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

@@ -16 +16 @@
 int main (int argc, char **argv) {
   
-  pthread_t thread;
+  pthread_t clientsThread;
+  pthread_t tasksThread;
+  pthread_t jobsThread;
+  pthread_t inputsThread;
+  pthread_t controllerThread;
   int InitSocket, BindSocket;
   SockAddress Address;
@@ -32 +36 @@
   
   gprintInit ();  // each thread needs to init the printing system
+  InitInputs ();
 
   signal (SIGPIPE, gotsignal);
@@ -38 +43 @@
   signal (SIGINT, SIG_DFL);
 
-  // startup (&argc, argv);
-
-  /* set up mechanisms for sharing data between the threads */
-  // init_data_handling ();
+  startup (&argc, argv);
 
   /* start up the background threads here */
-  pthread_create (&thread, NULL, &ListenClients, NULL);
-
-  // pthread_create (&thread, NULL, &RunScheduler, NULL);
-  // pthread_create (&thread, NULL, &RunController, NULL);
+  pthread_create (&clientsThread,    NULL, &ListenClients,         NULL);
+  pthread_create (&tasksThread,      NULL, &CheckTasksThread,      NULL);
+  pthread_create (&jobsThread,       NULL, &CheckJobsThread,       NULL);
+  pthread_create (&controllerThread, NULL, &CheckControllerThread, NULL);
+  pthread_create (&inputsThread,     NULL, &CheckInputsThread,     NULL);
 
   /* in this loop, we listen for incoming connections, validate, and