Return to ngx_event_posted.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / nginx / src / event

Annotation of embedaddon/nginx/src/event/ngx_event_posted.h, revision 1.1

1.1     ! misho       1: 
        !             2: /*
        !             3:  * Copyright (C) Igor Sysoev
        !             4:  * Copyright (C) Nginx, Inc.
        !             5:  */
        !             6: 
        !             7: 
        !             8: #ifndef _NGX_EVENT_POSTED_H_INCLUDED_
        !             9: #define _NGX_EVENT_POSTED_H_INCLUDED_
        !            10: 
        !            11: 
        !            12: #include <ngx_config.h>
        !            13: #include <ngx_core.h>
        !            14: #include <ngx_event.h>
        !            15: 
        !            16: 
        !            17: #if (NGX_THREADS)
        !            18: extern ngx_mutex_t  *ngx_posted_events_mutex;
        !            19: #endif
        !            20: 
        !            21: 
        !            22: #define ngx_locked_post_event(ev, queue)                                      \
        !            23:                                                                               \
        !            24:     if (ev->prev == NULL) {                                                   \
        !            25:         ev->next = (ngx_event_t *) *queue;                                    \
        !            26:         ev->prev = (ngx_event_t **) queue;                                    \
        !            27:         *queue = ev;                                                          \
        !            28:                                                                               \
        !            29:         if (ev->next) {                                                       \
        !            30:             ev->next->prev = &ev->next;                                       \
        !            31:         }                                                                     \
        !            32:                                                                               \
        !            33:         ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0, "post event %p", ev);  \
        !            34:                                                                               \
        !            35:     } else  {                                                                 \
        !            36:         ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0,                        \
        !            37:                        "update posted event %p", ev);                         \
        !            38:     }
        !            39: 
        !            40: 
        !            41: #define ngx_post_event(ev, queue)                                             \
        !            42:                                                                               \
        !            43:     ngx_mutex_lock(ngx_posted_events_mutex);                                  \
        !            44:     ngx_locked_post_event(ev, queue);                                         \
        !            45:     ngx_mutex_unlock(ngx_posted_events_mutex);
        !            46: 
        !            47: 
        !            48: #define ngx_delete_posted_event(ev)                                           \
        !            49:                                                                               \
        !            50:     *(ev->prev) = ev->next;                                                   \
        !            51:                                                                               \
        !            52:     if (ev->next) {                                                           \
        !            53:         ev->next->prev = ev->prev;                                            \
        !            54:     }                                                                         \
        !            55:                                                                               \
        !            56:     ev->prev = NULL;                                                          \
        !            57:     ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0,                            \
        !            58:                    "delete posted event %p", ev);
        !            59: 
        !            60: 
        !            61: 
        !            62: void ngx_event_process_posted(ngx_cycle_t *cycle,
        !            63:     ngx_thread_volatile ngx_event_t **posted);
        !            64: void ngx_wakeup_worker_thread(ngx_cycle_t *cycle);
        !            65: 
        !            66: #if (NGX_THREADS)
        !            67: ngx_int_t ngx_event_thread_process_posted(ngx_cycle_t *cycle);
        !            68: #endif
        !            69: 
        !            70: 
        !            71: extern ngx_thread_volatile ngx_event_t  *ngx_posted_accept_events;
        !            72: extern ngx_thread_volatile ngx_event_t  *ngx_posted_events;
        !            73: 
        !            74: 
        !            75: #endif /* _NGX_EVENT_POSTED_H_INCLUDED_ */