diff options
Diffstat (limited to 'httpd.c')
| -rw-r--r-- | httpd.c | 16 |
1 files changed, 10 insertions, 6 deletions
@@ -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++) |