One Level Up Top Level

src/event/modules/ngx_aio_module.c - nginx-1.7.10

Global variables defined

Functions defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #include <ngx_config.h>
  9. #include <ngx_core.h>
  10. #include <ngx_event.h>


  13. extern ngx_event_module_t  ngx_kqueue_module_ctx;


  16. static ngx_int_t ngx_aio_init(ngx_cycle_t *cycle, ngx_msec_t timer);
  17. static void ngx_aio_done(ngx_cycle_t *cycle);
  18. static ngx_int_t ngx_aio_add_event(ngx_event_t *ev, ngx_int_t event,
  19.     ngx_uint_t flags);
  20. static ngx_int_t ngx_aio_del_event(ngx_event_t *ev, ngx_int_t event,
  21.     ngx_uint_t flags);
  22. static ngx_int_t ngx_aio_del_connection(ngx_connection_t *c, ngx_uint_t flags);
  23. static ngx_int_t ngx_aio_process_events(ngx_cycle_t *cycle, ngx_msec_t timer,
  24.     ngx_uint_t flags);


  27. ‌ngx_os_io_t ngx_os_aio = {
  28.     ngx_aio_read,
  29.     ngx_aio_read_chain,
  30.     NULL,
  31.     ngx_aio_write,
  32.     ngx_aio_write_chain,
  33.     0
  34. };


  37. ‌static ngx_str_t      aio_name = ngx_string("aio");

  39. ‌ngx_event_module_t  ngx_aio_module_ctx = {
  40.     &aio_name,
  41.     NULL,                                  /* create configuration */
  42.     NULL,                                  /* init configuration */

  44.     {
  45.         ngx_aio_add_event,                 /* add an event */
  46.         ngx_aio_del_event,                 /* delete an event */
  47.         NULL,                              /* enable an event */
  48.         NULL,                              /* disable an event */
  49.         NULL,                              /* add an connection */
  50.         ngx_aio_del_connection,            /* delete an connection */
  51.         NULL,                              /* process the changes */
  52.         ngx_aio_process_events,            /* process the events */
  53.         ngx_aio_init,                      /* init the events */
  54.         ngx_aio_done                       /* done the events */
  55.     }

  57. };

  59. ‌ngx_module_t  ngx_aio_module = {
  60.     NGX_MODULE_V1,
  61.     &ngx_aio_module_ctx,                   /* module context */
  62.     NULL,                                  /* module directives */
  63.     NGX_EVENT_MODULE,                      /* module type */
  64.     NULL,                                  /* init master */
  65.     NULL,                                  /* init module */
  66.     NULL,                                  /* init process */
  67.     NULL,                                  /* init thread */
  68.     NULL,                                  /* exit thread */
  69.     NULL,                                  /* exit process */
  70.     NULL,                                  /* exit master */
  71.     NGX_MODULE_V1_PADDING
  72. };


  75. #if (NGX_HAVE_KQUEUE)

  77. static ngx_int_t
  78. ‌ngx_aio_init(ngx_cycle_t *cycle, ngx_msec_t timer)
  79. {
  80.     if (ngx_kqueue_module_ctx.actions.init(cycle, timer) == NGX_ERROR) {
  81.         return NGX_ERROR;
  82.     }

  84.     ngx_io = ngx_os_aio;

  86.     ngx_event_flags = NGX_USE_AIO_EVENT;
  87.     ngx_event_actions = ngx_aio_module_ctx.actions;


  90.     return NGX_OK;
  91. }


  94. static void
  95. ‌ngx_aio_done(ngx_cycle_t *cycle)
  96. {
  97.     ngx_kqueue_module_ctx.actions.done(cycle);
  98. }


  101. /* the event adding and deleting are needed for the listening sockets */

  103. static ngx_int_t
  104. ‌ngx_aio_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)
  105. {
  106.     return ngx_kqueue_module_ctx.actions.add(ev, event, flags);
  107. }


  110. static ngx_int_t
  111. ‌ngx_aio_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags)
  112. {
  113.     return ngx_kqueue_module_ctx.actions.del(ev, event, flags);
  114. }


  117. static ngx_int_t
  118. ‌ngx_aio_del_connection(ngx_connection_t *c, ngx_uint_t flags)
  119. {
  120.     int  rc;

  122.     if (c->read->active == 0 && c->write->active == 0) {
  123.         return NGX_OK;
  124.     }

  126.     if (flags & NGX_CLOSE_EVENT) {
  127.         return NGX_OK;
  128.     }

  130.     rc = aio_cancel(c->fd, NULL);

  132.     ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_cancel: %d", rc);

  134.     if (rc == AIO_CANCELED) {
  135.         c->read->active = 0;
  136.         c->write->active = 0;
  137.         return NGX_OK;
  138.     }

  140.     if (rc == AIO_ALLDONE) {
  141.         c->read->active = 0;
  142.         c->write->active = 0;
  143.         ngx_log_error(NGX_LOG_ALERT, c->log, 0,
  144.                       "aio_cancel() returned AIO_ALLDONE");
  145.         return NGX_OK;
  146.     }

  148.     if (rc == -1) {
  149.         ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno,
  150.                       "aio_cancel() failed");
  151.         return NGX_ERROR;
  152.     }

  154.     if (rc == AIO_NOTCANCELED) {
  155.         ngx_log_error(NGX_LOG_ALERT, c->log, 0,
  156.                       "aio_cancel() returned AIO_NOTCANCELED");

  158.         return NGX_ERROR;
  159.     }

  161.     return NGX_OK;
  162. }


  165. static ngx_int_t
  166. ‌ngx_aio_process_events(ngx_cycle_t *cycle, ngx_msec_t timer, ngx_uint_t flags)
  167. {
  168.     return ngx_kqueue_module_ctx.actions.process_events(cycle, timer, flags);
  169. }

  171. #endif /* NGX_HAVE_KQUEUE */

One Level Up Top Level