diff options
Diffstat (limited to 'src/thread.c')
| -rw-r--r-- | src/thread.c | 16 |
1 files changed, 13 insertions, 3 deletions
diff --git a/src/thread.c b/src/thread.c index 4a4704e..c2e736b 100644 --- a/src/thread.c +++ b/src/thread.c @@ -1,4 +1,4 @@ -/* $Id: thread.c,v 1.6 2001-08-26 21:14:30 rjkaes Exp $ +/* $Id: thread.c,v 1.7 2001-08-27 17:45:50 rjkaes Exp $ * * Handles the creation/destruction of the various threads required for * processing incoming connections. @@ -42,6 +42,9 @@ struct thread_s { static struct thread_s *thread_ptr; static pthread_mutex_t mlock = PTHREAD_MUTEX_INITIALIZER; +/* Used to override the default statck size. */ +static pthread_attr_t thread_attr; + static struct thread_config_s { unsigned int maxclients, maxrequestsperchild; unsigned int maxspareservers, minspareservers, startservers; @@ -146,6 +149,13 @@ int thread_pool_create(void) { unsigned int i; + /* + * Initialize thread_attr to contain a non-default stack size + * because the default on some OS's is too small. + */ + pthread_attr_init(&thread_attr); + pthread_attr_setstacksize(&thread_attr, (1024 * 1024)); + if (thread_config.maxclients == 0) { log_message(LOG_ERR, "You must set MaxClients to a value greater than 0"); return -1; @@ -167,7 +177,7 @@ int thread_pool_create(void) for (i = 0; i < thread_config.startservers; i++) { thread_ptr[i].status = T_WAITING; servers_waiting++; - pthread_create(&thread_ptr[i].tid, NULL, &thread_main, &thread_ptr[i]); + pthread_create(&thread_ptr[i].tid, &thread_attr, &thread_main, &thread_ptr[i]); } for (i = thread_config.startservers; i < thread_config.maxclients; i++) { thread_ptr[i].status = T_EMPTY; @@ -189,7 +199,7 @@ int thread_main_loop(void) if (servers_waiting < thread_config.minspareservers) { for (i = 0; i < thread_config.maxclients; i++) { if (thread_ptr[i].status == T_EMPTY) { - pthread_create(&thread_ptr[i].tid, NULL, &thread_main, &thread_ptr[i]); + pthread_create(&thread_ptr[i].tid, &thread_attr, &thread_main, &thread_ptr[i]); thread_ptr[i].status = T_WAITING; thread_ptr[i].connects = 0; |