Connection jobs are treated as urgent.

1 files changed, 10 insertions, 6 deletions

diff --git a/httpd.c b/httpd.c
index 1d91b34..d32903e 100644
--- a/httpd.c
+++ b/httpd.c
@@ -262,7 +262,7 @@ int job_fifo_ready(void)
 }
 
 
-void job_post(const xs_val *job)
+void job_post(const xs_val *job, int urgent)
 /* posts a job for the threads to process it */
 {
     if (job != NULL) {
@@ -270,8 +270,12 @@ void job_post(const xs_val *job)
         pthread_mutex_lock(&job_mutex);
 
         /* add to the fifo */
-        if (job_fifo != NULL)
-            job_fifo = xs_list_append(job_fifo, job);
+        if (job_fifo != NULL) {
+            if (urgent)
+                job_fifo = xs_list_insert(job_fifo, 0, job);
+            else
+                job_fifo = xs_list_append(job_fifo, job);
+        }
 
         /* unlock the mutex */
         pthread_mutex_unlock(&job_mutex);
@@ -386,7 +390,7 @@ static void *background_thread(void *arg)
 
             xs *q_item = xs_dict_new();
             q_item = xs_dict_append(q_item, "type", "purge");
-            job_post(q_item);
+            job_post(q_item, 0);
         }
 
         if (cnt == 0) {
@@ -485,7 +489,7 @@ void httpd(void)
 
             if (f != NULL) {
                 xs *job = xs_data_new(&f, sizeof(FILE *));
-                job_post(job);
+                job_post(job, 1);
             }
             else
                 break;
@@ -496,7 +500,7 @@ void httpd(void)
 
     /* send as many empty jobs as working threads */
     for (n = 1; n < n_threads; n++)
-        job_post(NULL);
+        job_post(NULL, 0);
 
     /* wait for all the threads to exit */
     for (n = 0; n < n_threads; n++)