lib/libhttp
1
0
Fork 0
mirror of https://github.com/lammertb/libhttp.git synced 2025-12-22 04:02:04 +03:00
Code Activity

Use eventfd instead of pthread_cond (step 5/?)

Browse Source
This commit is contained in:
bel
2016-07-04 21:52:11 +02:00
parent ff52c41922
commit 8d166b2d4b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/civetweb.c
View File

@@ -1591,6 +1591,7 @@ typedef struct tagTHREADNAME_INFO {
#include <sys/eventfd.h> #include <sys/eventfd.h>
#ifdef ALTERNATIVE_QUEUE
static int static int
event_create(void) event_create(void)
{ {
@@ -1636,6 +1637,7 @@ event_destroy(int eventhdl)
{ {
close(eventhdl); close(eventhdl);
} }
#endif
#endif #endif
@@ -3060,6 +3062,7 @@ pthread_cond_destroy(pthread_cond_t *cv)
} }
#ifdef ALTERNATIVE_QUEUE
static int static int
event_create(void) event_create(void)
{ {
@@ -3087,6 +3090,7 @@ event_destroy(int eventhdl)
{ {
CloseHandle((HANDLE)eventhdl); CloseHandle((HANDLE)eventhdl);
} }
#endif
#if defined(__MINGW32__) #if defined(__MINGW32__)
@@ -12658,11 +12662,11 @@ consume_socket(struct mg_context *ctx, struct socket *sp, int thread_index)
/* Worker threads take accepted socket from the queue */ /* Worker threads take accepted socket from the queue */
static int static int
consume_socket(struct mg_context *ctx, struct socket *sp, int index) consume_socket(struct mg_context *ctx, struct socket *sp, int thread_index)
{ {
#define QUEUE_SIZE(ctx) ((int)(ARRAY_SIZE(ctx->queue))) #define QUEUE_SIZE(ctx) ((int)(ARRAY_SIZE(ctx->queue)))
(void)index; (void)thread_index;
(void)pthread_mutex_lock(&ctx->thread_mutex); (void)pthread_mutex_lock(&ctx->thread_mutex);
DEBUG_TRACE("%s", "going idle"); DEBUG_TRACE("%s", "going idle");