
#include <ngx_config.h>
#include <ngx_core.h>
#include <ngx_event.h>


ngx_thread_volatile ngx_event_t  *ngx_posted_events;

#if (NGX_THREADS)
ngx_mutex_t                      *ngx_posted_events_mutex;
ngx_cond_t                       *ngx_posted_events_cv;
#endif


void ngx_event_process_posted(ngx_cycle_t *cycle)
{
    ngx_event_t  *ev;

    for ( ;; ) {

        ev = (ngx_event_t *) ngx_posted_events;

        ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
                      "posted event " PTR_FMT, ev);

        if (ev == NULL) {
            return;
        }

        ngx_delete_posted_event(ev);

#if 0
        /* do not check instance ??? */

        if (ev->accept) {
            continue;
        }
#endif

        if (ev->closed
            || (ev->use_instance && ev->instance != ev->returned_instance))
        {
            /*
             * the stale event from a file descriptor
             * that was just closed in this iteration
             */

            ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
                           "stale posted event " PTR_FMT, ev);
            continue;
        }

        ev->event_handler(ev);
    }
}


#if (NGX_THREADS)

ngx_int_t ngx_event_thread_process_posted(ngx_cycle_t *cycle)
{
    ngx_event_t  *ev;

    for ( ;; ) {

        ev = (ngx_event_t *) ngx_posted_events;

        for ( ;; ) {

            ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
                          "posted event " PTR_FMT, ev);

            if (ev == NULL) {
                ngx_mutex_unlock(ngx_posted_events_mutex);
                return NGX_OK;
            }

            if (ngx_trylock(ev->lock) == 0) {

                ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
                               "posted event " PTR_FMT " is busy", ev);

                ev = ev->next;
                continue;
            }

            ngx_delete_posted_event(ev);

            ngx_log_debug3(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
                          "event instance: c:%d i:%d r:%d",
                          ev->closed, ev->instance, ev->returned_instance);

            if (ev->closed
                || (ev->use_instance && ev->instance != ev->returned_instance))
            {
                /*
                 * The stale event from a file descriptor that was just
                 * closed in this iteration.  We use ngx_cycle->log
                 * because ev->log may be already destoyed.
                 */

                ngx_log_debug1(NGX_LOG_DEBUG_EVENT, ngx_cycle->log, 0,
                               "stale posted event " PTR_FMT, ev);

                ngx_unlock(ev->lock);

                ev = ev->next;

                continue;
            }

            ev->locked = 1;

            ev->ready |= ev->posted_ready;
            ev->timedout |= ev->posted_timedout;
            ev->available |= ev->posted_available;
            ev->pending_eof |= ev->posted_eof;
#if (HAVE_KQUEUE)
            ev->kq_errno |= ev->posted_errno;
#endif

            ev->posted_ready = 0;
            ev->posted_timedout = 0;
            ev->posted_available = 0;
            ev->posted_eof = 0;
#if (HAVE_KQUEUE)
            ev->posted_errno = 0;
#endif

            ngx_mutex_unlock(ngx_posted_events_mutex);

            ev->event_handler(ev);

            if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
                return NGX_ERROR;
            }

            if (ev->locked) {
                ngx_unlock(ev->lock);
            }

            break;
        }
    }
}

#endif