diff options
Diffstat (limited to '')
| -rw-r--r-- | src/event/ngx_event_posted.h | 30 |
1 files changed, 6 insertions, 24 deletions
diff --git a/src/event/ngx_event_posted.h b/src/event/ngx_event_posted.h index abd2e261d..c24fd4e9b 100644 --- a/src/event/ngx_event_posted.h +++ b/src/event/ngx_event_posted.h @@ -14,16 +14,11 @@ #include <ngx_event.h> -#if (NGX_THREADS) -extern ngx_mutex_t *ngx_posted_events_mutex; -#endif - - -#define ngx_locked_post_event(ev, queue) \ +#define ngx_post_event(ev, queue) \ \ if (ev->prev == NULL) { \ - ev->next = (ngx_event_t *) *queue; \ - ev->prev = (ngx_event_t **) queue; \ + ev->next = *queue; \ + ev->prev = queue; \ *queue = ev; \ \ if (ev->next) { \ @@ -38,13 +33,6 @@ extern ngx_mutex_t *ngx_posted_events_mutex; } -#define ngx_post_event(ev, queue) \ - \ - ngx_mutex_lock(ngx_posted_events_mutex); \ - ngx_locked_post_event(ev, queue); \ - ngx_mutex_unlock(ngx_posted_events_mutex); - - #define ngx_delete_posted_event(ev) \ \ *(ev->prev) = ev->next; \ @@ -59,17 +47,11 @@ extern ngx_mutex_t *ngx_posted_events_mutex; -void ngx_event_process_posted(ngx_cycle_t *cycle, - ngx_thread_volatile ngx_event_t **posted); -void ngx_wakeup_worker_thread(ngx_cycle_t *cycle); - -#if (NGX_THREADS) -ngx_int_t ngx_event_thread_process_posted(ngx_cycle_t *cycle); -#endif +void ngx_event_process_posted(ngx_cycle_t *cycle, ngx_event_t **posted); -extern ngx_thread_volatile ngx_event_t *ngx_posted_accept_events; -extern ngx_thread_volatile ngx_event_t *ngx_posted_events; +extern ngx_event_t *ngx_posted_accept_events; +extern ngx_event_t *ngx_posted_events; #endif /* _NGX_EVENT_POSTED_H_INCLUDED_ */ |