session_destroy_modules(&sessions_to_kill);
sessions_to_kill = sptr;
}
+}
- /*
- * Check the size of our thread pool. If all threads are executing, spawn another.
- */
- begin_critical_section(S_SPAWNER);
+/*
+ * Check the size of our thread pool. If all threads are executing, spawn another.
+ */
+void check_thread_pool_size(void)
+{
+ if (time_to_die) return; /* don't expand the thread pool during shutdown */
+
+ begin_critical_section(S_SPAWNER); /* only one of these should run at a time */
while (
(num_threads_executing >= num_threads_existing)
&& (num_threads_existing < MAX_WORKER_THREADS)
) {
+ lprintf(3, "%d of %d threads are executing. Adding another worker thread.\n",
+ num_threads_executing,
+ num_threads_existing
+ );
spawn_another_worker_thread();
}
end_critical_section(S_SPAWNER);
}
if (ssock < 0 ) continue;
+ check_thread_pool_size();
+
/* Now do something. */
if (msock < 0) {
if (ssock > 0) close (ssock);
pthread_attr_t attr; /* Thread attributes */
int ret;
- lprintf(3, "Creating a new thread.\n");
-
++num_threads_existing;
++num_threads_executing;
void http_transmit_thing(const char *content_type, int is_static);
long unescape_input(char *buf);
void do_selected_iconbar(void);
+void check_thread_pool_size(void);
void spawn_another_worker_thread(void);
void StrEndTab(StrBuf *Target, int tabnum, int num_tabs);
void StrBeginTab(StrBuf *Target, int tabnum, int num_tabs);
#define WC_TIMEFORMAT_AMPM 1
#define WC_TIMEFORMAT_24 2
+extern int time_to_die; /* Nonzero if server is shutting down */