Changeset 253:ad6c0118fb50 in freeDiameter for freeDiameter/routing_dispatch.c

Timestamp:

Apr 13, 2010, 2:50:54 PM (14 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Configurable number of server threads

File:

• freeDiameter/routing_dispatch.c (modified) (4 diffs)

freeDiameter/routing_dispatch.c

@@ -1070 +1070 @@
 /********************************************************************************/
 
+static pthread_t * dispatch = NULL;
+static enum thread_state * disp_state = NULL;
+
 /* Later: make this more dynamic */
-static pthread_t dispatch = (pthread_t)NULL;
-static enum thread_state disp_state = INITIAL;
-
 static pthread_t rt_out = (pthread_t)NULL;
 static enum thread_state out_state = INITIAL;
@@ -1083 +1083 @@
 int fd_rtdisp_init(void)
 {
-        CHECK_POSIX( pthread_create( &dispatch, NULL, dispatch_thr, &disp_state ) );
+        int i;
+        
+        /* Prepare the array for dispatch */
+        CHECK_MALLOC( dispatch = calloc(fd_g_config->cnf_dispthr, sizeof(pthread_t)) );
+        CHECK_MALLOC( disp_state = calloc(fd_g_config->cnf_dispthr, sizeof(enum thread_state)) );
+        
+        /* Create the threads */
+        for (i=0; i < fd_g_config->cnf_dispthr; i++) {
+                CHECK_POSIX( pthread_create( &dispatch[i], NULL, dispatch_thr, &disp_state[i] ) );
+        }
         CHECK_POSIX( pthread_create( &rt_out, NULL, routing_out_thr, &out_state) );
         CHECK_POSIX( pthread_create( &rt_in,  NULL, routing_in_thr,  &in_state) );
@@ -1139 +1148 @@
 int fd_rtdisp_fini(void)
 {
+        int i;
+        
         /* Destroy the incoming queue */
         CHECK_FCT_DO( fd_queues_fini(&fd_g_incoming), /* ignore */);
@@ -1155 +1166 @@
         
         /* Stop the Dispatch thread */
-        stop_thread_delayed(&disp_state, &dispatch, "Dispatching");
+        for (i=0; i < fd_g_config->cnf_dispthr; i++) {
+                stop_thread_delayed(&disp_state[i], &dispatch[i], "Dispatching");
+        }
         
         return 0;