One Level Up Top Level

src/core/ngx_cycle.c - nginx source code

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. static void ngx_destroy_cycle_pools(ngx_conf_t *conf);
  14. static ngx_int_t ngx_init_zone_pool(ngx_cycle_t *cycle,
  15.     ngx_shm_zone_t *shm_zone);
  16. static ngx_int_t ngx_test_lockfile(u_char *file, ngx_log_t *log);
  17. static void ngx_clean_old_cycles(ngx_event_t *ev);
  18. static void ngx_shutdown_timer_handler(ngx_event_t *ev);


  21. ‌volatile ngx_cycle_t  *ngx_cycle;
  22. ‌ngx_array_t            ngx_old_cycles;

  24. ‌static ngx_pool_t     *ngx_temp_pool;
  25. ‌static ngx_event_t     ngx_cleaner_event;
  26. ‌static ngx_event_t     ngx_shutdown_event;

  28. ‌ngx_uint_t             ngx_test_config;
  29. ‌ngx_uint_t             ngx_dump_config;
  30. ‌ngx_uint_t             ngx_quiet_mode;


  33. /* STUB NAME */
  34. ‌static ngx_connection_t  dumb;
  35. /* STUB */


  38. ngx_cycle_t *
  39. ‌ngx_init_cycle(ngx_cycle_t *old_cycle)
  40. {
  41.     void                *rv, *data;
  42.     char               **senv;
  43.     ngx_uint_t           i, n;
  44.     ngx_log_t           *log;
  45.     ngx_time_t          *tp;
  46.     ngx_conf_t           conf;
  47.     ngx_pool_t          *pool;
  48.     ngx_cycle_t         *cycle, **old;
  49.     ngx_shm_zone_t      *shm_zone, *oshm_zone;
  50.     ngx_list_part_t     *part, *opart;
  51.     ngx_open_file_t     *file;
  52.     ngx_listening_t     *ls, *nls;
  53.     ngx_core_conf_t     *ccf, *old_ccf;
  54.     ngx_core_module_t   *module;
  55.     char                 hostname[NGX_MAXHOSTNAMELEN];

  57.     ngx_timezone_update();

  59.     /* force localtime update with a new timezone */

  61.     tp = ngx_timeofday();
  62.     tp->sec = 0;

  64.     ngx_time_update();


  67.     log = old_cycle->log;

  69.     pool = ngx_create_pool(NGX_CYCLE_POOL_SIZE, log);
  70.     if (pool == NULL) {
  71.         return NULL;
  72.     }
  73.     pool->log = log;

  75.     cycle = ngx_pcalloc(pool, sizeof(ngx_cycle_t));
  76.     if (cycle == NULL) {
  77.         ngx_destroy_pool(pool);
  78.         return NULL;
  79.     }

  81.     cycle->pool = pool;
  82.     cycle->log = log;
  83.     cycle->old_cycle = old_cycle;

  85.     cycle->conf_prefix.len = old_cycle->conf_prefix.len;
  86.     cycle->conf_prefix.data = ngx_pstrdup(pool, &old_cycle->conf_prefix);
  87.     if (cycle->conf_prefix.data == NULL) {
  88.         ngx_destroy_pool(pool);
  89.         return NULL;
  90.     }

  92.     cycle->prefix.len = old_cycle->prefix.len;
  93.     cycle->prefix.data = ngx_pstrdup(pool, &old_cycle->prefix);
  94.     if (cycle->prefix.data == NULL) {
  95.         ngx_destroy_pool(pool);
  96.         return NULL;
  97.     }

  99.     cycle->error_log.len = old_cycle->error_log.len;
  100.     cycle->error_log.data = ngx_pnalloc(pool, old_cycle->error_log.len + 1);
  101.     if (cycle->error_log.data == NULL) {
  102.         ngx_destroy_pool(pool);
  103.         return NULL;
  104.     }
  105.     ngx_cpystrn(cycle->error_log.data, old_cycle->error_log.data,
  106.                 old_cycle->error_log.len + 1);

  108.     cycle->conf_file.len = old_cycle->conf_file.len;
  109.     cycle->conf_file.data = ngx_pnalloc(pool, old_cycle->conf_file.len + 1);
  110.     if (cycle->conf_file.data == NULL) {
  111.         ngx_destroy_pool(pool);
  112.         return NULL;
  113.     }
  114.     ngx_cpystrn(cycle->conf_file.data, old_cycle->conf_file.data,
  115.                 old_cycle->conf_file.len + 1);

  117.     cycle->conf_param.len = old_cycle->conf_param.len;
  118.     cycle->conf_param.data = ngx_pstrdup(pool, &old_cycle->conf_param);
  119.     if (cycle->conf_param.data == NULL) {
  120.         ngx_destroy_pool(pool);
  121.         return NULL;
  122.     }


  125.     n = old_cycle->paths.nelts ? old_cycle->paths.nelts : 10;

  127.     if (ngx_array_init(&cycle->paths, pool, n, sizeof(ngx_path_t *))
  128.         != NGX_OK)
  129.     {
  130.         ngx_destroy_pool(pool);
  131.         return NULL;
  132.     }

  134.     ngx_memzero(cycle->paths.elts, n * sizeof(ngx_path_t *));


  137.     if (ngx_array_init(&cycle->config_dump, pool, 1, sizeof(ngx_conf_dump_t))
  138.         != NGX_OK)
  139.     {
  140.         ngx_destroy_pool(pool);
  141.         return NULL;
  142.     }

  144.     ngx_rbtree_init(&cycle->config_dump_rbtree, &cycle->config_dump_sentinel,
  145.                     ngx_str_rbtree_insert_value);

  147.     if (old_cycle->open_files.part.nelts) {
  148.         n = old_cycle->open_files.part.nelts;
  149.         for (part = old_cycle->open_files.part.next; part; part = part->next) {
  150.             n += part->nelts;
  151.         }

  153.     } else {
  154.         n = 20;
  155.     }

  157.     if (ngx_list_init(&cycle->open_files, pool, n, sizeof(ngx_open_file_t))
  158.         != NGX_OK)
  159.     {
  160.         ngx_destroy_pool(pool);
  161.         return NULL;
  162.     }


  165.     if (old_cycle->shared_memory.part.nelts) {
  166.         n = old_cycle->shared_memory.part.nelts;
  167.         for (part = old_cycle->shared_memory.part.next; part; part = part->next)
  168.         {
  169.             n += part->nelts;
  170.         }

  172.     } else {
  173.         n = 1;
  174.     }

  176.     if (ngx_list_init(&cycle->shared_memory, pool, n, sizeof(ngx_shm_zone_t))
  177.         != NGX_OK)
  178.     {
  179.         ngx_destroy_pool(pool);
  180.         return NULL;
  181.     }

  183.     n = old_cycle->listening.nelts ? old_cycle->listening.nelts : 10;

  185.     if (ngx_array_init(&cycle->listening, pool, n, sizeof(ngx_listening_t))
  186.         != NGX_OK)
  187.     {
  188.         ngx_destroy_pool(pool);
  189.         return NULL;
  190.     }

  192.     ngx_memzero(cycle->listening.elts, n * sizeof(ngx_listening_t));


  195.     ngx_queue_init(&cycle->reusable_connections_queue);


  198.     cycle->conf_ctx = ngx_pcalloc(pool, ngx_max_module * sizeof(void *));
  199.     if (cycle->conf_ctx == NULL) {
  200.         ngx_destroy_pool(pool);
  201.         return NULL;
  202.     }


  205.     if (gethostname(hostname, NGX_MAXHOSTNAMELEN) == -1) {
  206.         ngx_log_error(NGX_LOG_EMERG, log, ngx_errno, "gethostname() failed");
  207.         ngx_destroy_pool(pool);
  208.         return NULL;
  209.     }

  211.     /* on Linux gethostname() silently truncates name that does not fit */

  213.     hostname[NGX_MAXHOSTNAMELEN - 1] = '\0';
  214.     cycle->hostname.len = ngx_strlen(hostname);

  216.     cycle->hostname.data = ngx_pnalloc(pool, cycle->hostname.len);
  217.     if (cycle->hostname.data == NULL) {
  218.         ngx_destroy_pool(pool);
  219.         return NULL;
  220.     }

  222.     ngx_strlow(cycle->hostname.data, (u_char *) hostname, cycle->hostname.len);


  225.     if (ngx_cycle_modules(cycle) != NGX_OK) {
  226.         ngx_destroy_pool(pool);
  227.         return NULL;
  228.     }


  231.     for (i = 0; cycle->modules[i]; i++) {
  232.         if (cycle->modules[i]->type != NGX_CORE_MODULE) {
  233.             continue;
  234.         }

  236.         module = cycle->modules[i]->ctx;

  238.         if (module->create_conf) {
  239.             rv = module->create_conf(cycle);
  240.             if (rv == NULL) {
  241.                 ngx_destroy_pool(pool);
  242.                 return NULL;
  243.             }
  244.             cycle->conf_ctx[cycle->modules[i]->index] = rv;
  245.         }
  246.     }


  249.     senv = environ;


  252.     ngx_memzero(&conf, sizeof(ngx_conf_t));
  253.     /* STUB: init array ? */
  254.     conf.args = ngx_array_create(pool, 10, sizeof(ngx_str_t));
  255.     if (conf.args == NULL) {
  256.         ngx_destroy_pool(pool);
  257.         return NULL;
  258.     }

  260.     conf.temp_pool = ngx_create_pool(NGX_CYCLE_POOL_SIZE, log);
  261.     if (conf.temp_pool == NULL) {
  262.         ngx_destroy_pool(pool);
  263.         return NULL;
  264.     }


  267.     conf.ctx = cycle->conf_ctx;
  268.     conf.cycle = cycle;
  269.     conf.pool = pool;
  270.     conf.log = log;
  271.     conf.module_type = NGX_CORE_MODULE;
  272.     conf.cmd_type = NGX_MAIN_CONF;

  274. #if 0
  275.     log->log_level = NGX_LOG_DEBUG_ALL;
  276. #endif

  278.     if (ngx_conf_param(&conf) != NGX_CONF_OK) {
  279.         environ = senv;
  280.         ngx_destroy_cycle_pools(&conf);
  281.         return NULL;
  282.     }

  284.     if (ngx_conf_parse(&conf, &cycle->conf_file) != NGX_CONF_OK) {
  285.         environ = senv;
  286.         ngx_destroy_cycle_pools(&conf);
  287.         return NULL;
  288.     }

  290.     if (ngx_test_config && !ngx_quiet_mode) {
  291.         ngx_log_stderr(0, "the configuration file %s syntax is ok",
  292.                        cycle->conf_file.data);
  293.     }

  295.     for (i = 0; cycle->modules[i]; i++) {
  296.         if (cycle->modules[i]->type != NGX_CORE_MODULE) {
  297.             continue;
  298.         }

  300.         module = cycle->modules[i]->ctx;

  302.         if (module->init_conf) {
  303.             if (module->init_conf(cycle,
  304.                                   cycle->conf_ctx[cycle->modules[i]->index])
  305.                 == NGX_CONF_ERROR)
  306.             {
  307.                 environ = senv;
  308.                 ngx_destroy_cycle_pools(&conf);
  309.                 return NULL;
  310.             }
  311.         }
  312.     }

  314.     if (ngx_process == NGX_PROCESS_SIGNALLER) {
  315.         return cycle;
  316.     }

  318.     ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);

  320.     if (ngx_test_config) {

  322.         if (ngx_create_pidfile(&ccf->pid, log) != NGX_OK) {
  323.             goto failed;
  324.         }

  326.     } else if (!ngx_is_init_cycle(old_cycle)) {

  328.         /*
  329.          * we do not create the pid file in the first ngx_init_cycle() call
  330.          * because we need to write the demonized process pid
  331.          */

  333.         old_ccf = (ngx_core_conf_t *) ngx_get_conf(old_cycle->conf_ctx,
  334.                                                    ngx_core_module);
  335.         if (ccf->pid.len != old_ccf->pid.len
  336.             || ngx_strcmp(ccf->pid.data, old_ccf->pid.data) != 0)
  337.         {
  338.             /* new pid file name */

  340.             if (ngx_create_pidfile(&ccf->pid, log) != NGX_OK) {
  341.                 goto failed;
  342.             }

  344.             ngx_delete_pidfile(old_cycle);
  345.         }
  346.     }


  349.     if (ngx_test_lockfile(cycle->lock_file.data, log) != NGX_OK) {
  350.         goto failed;
  351.     }


  354.     if (ngx_create_paths(cycle, ccf->user) != NGX_OK) {
  355.         goto failed;
  356.     }


  359.     if (ngx_log_open_default(cycle) != NGX_OK) {
  360.         goto failed;
  361.     }

  363.     /* open the new files */

  365.     part = &cycle->open_files.part;
  366.     file = part->elts;

  368.     for (i = 0; /* void */ ; i++) {

  370.         if (i >= part->nelts) {
  371.             if (part->next == NULL) {
  372.                 break;
  373.             }
  374.             part = part->next;
  375.             file = part->elts;
  376.             i = 0;
  377.         }

  379.         if (file[i].name.len == 0) {
  380.             continue;
  381.         }

  383.         file[i].fd = ngx_open_file(file[i].name.data,
  384.                                    NGX_FILE_APPEND,
  385.                                    NGX_FILE_CREATE_OR_OPEN,
  386.                                    NGX_FILE_DEFAULT_ACCESS);

  388.         ngx_log_debug3(NGX_LOG_DEBUG_CORE, log, 0,
  389.                        "log: %p %d \"%s\"",
  390.                        &file[i], file[i].fd, file[i].name.data);

  392.         if (file[i].fd == NGX_INVALID_FILE) {
  393.             ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  394.                           ngx_open_file_n " \"%s\" failed",
  395.                           file[i].name.data);
  396.             goto failed;
  397.         }

  399. #if !(NGX_WIN32)
  400.         if (fcntl(file[i].fd, F_SETFD, FD_CLOEXEC) == -1) {
  401.             ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  402.                           "fcntl(FD_CLOEXEC) \"%s\" failed",
  403.                           file[i].name.data);
  404.             goto failed;
  405.         }
  406. #endif
  407.     }

  409.     cycle->log = &cycle->new_log;
  410.     pool->log = &cycle->new_log;


  413.     /* create shared memory */

  415.     part = &cycle->shared_memory.part;
  416.     shm_zone = part->elts;

  418.     for (i = 0; /* void */ ; i++) {

  420.         if (i >= part->nelts) {
  421.             if (part->next == NULL) {
  422.                 break;
  423.             }
  424.             part = part->next;
  425.             shm_zone = part->elts;
  426.             i = 0;
  427.         }

  429.         if (shm_zone[i].shm.size == 0) {
  430.             ngx_log_error(NGX_LOG_EMERG, log, 0,
  431.                           "zero size shared memory zone \"%V\"",
  432.                           &shm_zone[i].shm.name);
  433.             goto failed;
  434.         }

  436.         shm_zone[i].shm.log = cycle->log;

  438.         opart = &old_cycle->shared_memory.part;
  439.         oshm_zone = opart->elts;

  441.         data = NULL;

  443.         for (n = 0; /* void */ ; n++) {

  445.             if (n >= opart->nelts) {
  446.                 if (opart->next == NULL) {
  447.                     break;
  448.                 }
  449.                 opart = opart->next;
  450.                 oshm_zone = opart->elts;
  451.                 n = 0;
  452.             }

  454.             if (shm_zone[i].shm.name.len != oshm_zone[n].shm.name.len) {
  455.                 continue;
  456.             }

  458.             if (ngx_strncmp(shm_zone[i].shm.name.data,
  459.                             oshm_zone[n].shm.name.data,
  460.                             shm_zone[i].shm.name.len)
  461.                 != 0)
  462.             {
  463.                 continue;
  464.             }

  466.             if (shm_zone[i].tag == oshm_zone[n].tag && shm_zone[i].noreuse) {
  467.                 data = oshm_zone[n].data;
  468.                 break;
  469.             }

  471.             if (shm_zone[i].tag == oshm_zone[n].tag
  472.                 && shm_zone[i].shm.size == oshm_zone[n].shm.size)
  473.             {
  474.                 shm_zone[i].shm.addr = oshm_zone[n].shm.addr;
  475. #if (NGX_WIN32)
  476.                 shm_zone[i].shm.handle = oshm_zone[n].shm.handle;
  477. #endif

  479.                 if (shm_zone[i].init(&shm_zone[i], oshm_zone[n].data)
  480.                     != NGX_OK)
  481.                 {
  482.                     goto failed;
  483.                 }

  485.                 goto shm_zone_found;
  486.             }

  488.             break;
  489.         }

  491.         if (ngx_shm_alloc(&shm_zone[i].shm) != NGX_OK) {
  492.             goto failed;
  493.         }

  495.         if (ngx_init_zone_pool(cycle, &shm_zone[i]) != NGX_OK) {
  496.             goto failed;
  497.         }

  499.         if (shm_zone[i].init(&shm_zone[i], data) != NGX_OK) {
  500.             goto failed;
  501.         }

  503.     shm_zone_found:

  505.         continue;
  506.     }


  509.     /* handle the listening sockets */

  511.     if (old_cycle->listening.nelts) {
  512.         ls = old_cycle->listening.elts;
  513.         for (i = 0; i < old_cycle->listening.nelts; i++) {
  514.             ls[i].remain = 0;
  515.         }

  517.         nls = cycle->listening.elts;
  518.         for (n = 0; n < cycle->listening.nelts; n++) {

  520.             for (i = 0; i < old_cycle->listening.nelts; i++) {
  521.                 if (ls[i].ignore) {
  522.                     continue;
  523.                 }

  525.                 if (ls[i].remain) {
  526.                     continue;
  527.                 }

  529.                 if (ls[i].type != nls[n].type) {
  530.                     continue;
  531.                 }

  533.                 if (ngx_cmp_sockaddr(nls[n].sockaddr, nls[n].socklen,
  534.                                      ls[i].sockaddr, ls[i].socklen, 1)
  535.                     == NGX_OK)
  536.                 {
  537.                     nls[n].fd = ls[i].fd;
  538.                     nls[n].inherited = ls[i].inherited;
  539.                     nls[n].previous = &ls[i];
  540.                     ls[i].remain = 1;

  542.                     if (ls[i].backlog != nls[n].backlog) {
  543.                         nls[n].listen = 1;
  544.                     }

  546. #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER)

  548.                     /*
  549.                      * FreeBSD, except the most recent versions,
  550.                      * could not remove accept filter
  551.                      */
  552.                     nls[n].deferred_accept = ls[i].deferred_accept;

  554.                     if (ls[i].accept_filter && nls[n].accept_filter) {
  555.                         if (ngx_strcmp(ls[i].accept_filter,
  556.                                        nls[n].accept_filter)
  557.                             != 0)
  558.                         {
  559.                             nls[n].delete_deferred = 1;
  560.                             nls[n].add_deferred = 1;
  561.                         }

  563.                     } else if (ls[i].accept_filter) {
  564.                         nls[n].delete_deferred = 1;

  566.                     } else if (nls[n].accept_filter) {
  567.                         nls[n].add_deferred = 1;
  568.                     }
  569. #endif

  571. #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT)

  573.                     if (ls[i].deferred_accept && !nls[n].deferred_accept) {
  574.                         nls[n].delete_deferred = 1;

  576.                     } else if (ls[i].deferred_accept != nls[n].deferred_accept)
  577.                     {
  578.                         nls[n].add_deferred = 1;
  579.                     }
  580. #endif

  582. #if (NGX_HAVE_REUSEPORT)
  583.                     if (nls[n].reuseport && !ls[i].reuseport) {
  584.                         nls[n].add_reuseport = 1;
  585.                     }
  586. #endif

  588.                     break;
  589.                 }
  590.             }

  592.             if (nls[n].fd == (ngx_socket_t) -1) {
  593.                 nls[n].open = 1;
  594. #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER)
  595.                 if (nls[n].accept_filter) {
  596.                     nls[n].add_deferred = 1;
  597.                 }
  598. #endif
  599. #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT)
  600.                 if (nls[n].deferred_accept) {
  601.                     nls[n].add_deferred = 1;
  602.                 }
  603. #endif
  604.             }
  605.         }

  607.     } else {
  608.         ls = cycle->listening.elts;
  609.         for (i = 0; i < cycle->listening.nelts; i++) {
  610.             ls[i].open = 1;
  611. #if (NGX_HAVE_DEFERRED_ACCEPT && defined SO_ACCEPTFILTER)
  612.             if (ls[i].accept_filter) {
  613.                 ls[i].add_deferred = 1;
  614.             }
  615. #endif
  616. #if (NGX_HAVE_DEFERRED_ACCEPT && defined TCP_DEFER_ACCEPT)
  617.             if (ls[i].deferred_accept) {
  618.                 ls[i].add_deferred = 1;
  619.             }
  620. #endif
  621.         }
  622.     }

  624.     if (ngx_open_listening_sockets(cycle) != NGX_OK) {
  625.         goto failed;
  626.     }

  628.     if (!ngx_test_config) {
  629.         ngx_configure_listening_sockets(cycle);
  630.     }


  633.     /* commit the new cycle configuration */

  635.     if (!ngx_use_stderr) {
  636.         (void) ngx_log_redirect_stderr(cycle);
  637.     }

  639.     pool->log = cycle->log;

  641.     if (ngx_init_modules(cycle) != NGX_OK) {
  642.         /* fatal */
  643.         exit(1);
  644.     }


  647.     /* close and delete stuff that lefts from an old cycle */

  649.     /* free the unnecessary shared memory */

  651.     opart = &old_cycle->shared_memory.part;
  652.     oshm_zone = opart->elts;

  654.     for (i = 0; /* void */ ; i++) {

  656.         if (i >= opart->nelts) {
  657.             if (opart->next == NULL) {
  658.                 goto old_shm_zone_done;
  659.             }
  660.             opart = opart->next;
  661.             oshm_zone = opart->elts;
  662.             i = 0;
  663.         }

  665.         part = &cycle->shared_memory.part;
  666.         shm_zone = part->elts;

  668.         for (n = 0; /* void */ ; n++) {

  670.             if (n >= part->nelts) {
  671.                 if (part->next == NULL) {
  672.                     break;
  673.                 }
  674.                 part = part->next;
  675.                 shm_zone = part->elts;
  676.                 n = 0;
  677.             }

  679.             if (oshm_zone[i].shm.name.len != shm_zone[n].shm.name.len) {
  680.                 continue;
  681.             }

  683.             if (ngx_strncmp(oshm_zone[i].shm.name.data,
  684.                             shm_zone[n].shm.name.data,
  685.                             oshm_zone[i].shm.name.len)
  686.                 != 0)
  687.             {
  688.                 continue;
  689.             }

  691.             if (oshm_zone[i].tag == shm_zone[n].tag
  692.                 && oshm_zone[i].shm.size == shm_zone[n].shm.size
  693.                 && !oshm_zone[i].noreuse)
  694.             {
  695.                 goto live_shm_zone;
  696.             }

  698.             break;
  699.         }

  701.         ngx_shm_free(&oshm_zone[i].shm);

  703.     live_shm_zone:

  705.         continue;
  706.     }

  708. old_shm_zone_done:


  711.     /* close the unnecessary listening sockets */

  713.     ls = old_cycle->listening.elts;
  714.     for (i = 0; i < old_cycle->listening.nelts; i++) {

  716.         if (ls[i].remain || ls[i].fd == (ngx_socket_t) -1) {
  717.             continue;
  718.         }

  720.         if (ngx_close_socket(ls[i].fd) == -1) {
  721.             ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
  722.                           ngx_close_socket_n " listening socket on %V failed",
  723.                           &ls[i].addr_text);
  724.         }

  726. #if (NGX_HAVE_UNIX_DOMAIN)

  728.         if (ls[i].sockaddr->sa_family == AF_UNIX) {
  729.             u_char  *name;

  731.             name = ls[i].addr_text.data + sizeof("unix:") - 1;

  733.             ngx_log_error(NGX_LOG_WARN, cycle->log, 0,
  734.                           "deleting socket %s", name);

  736.             if (ngx_delete_file(name) == NGX_FILE_ERROR) {
  737.                 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_socket_errno,
  738.                               ngx_delete_file_n " %s failed", name);
  739.             }
  740.         }

  742. #endif
  743.     }


  746.     /* close the unnecessary open files */

  748.     part = &old_cycle->open_files.part;
  749.     file = part->elts;

  751.     for (i = 0; /* void */ ; i++) {

  753.         if (i >= part->nelts) {
  754.             if (part->next == NULL) {
  755.                 break;
  756.             }
  757.             part = part->next;
  758.             file = part->elts;
  759.             i = 0;
  760.         }

  762.         if (file[i].fd == NGX_INVALID_FILE || file[i].fd == ngx_stderr) {
  763.             continue;
  764.         }

  766.         if (ngx_close_file(file[i].fd) == NGX_FILE_ERROR) {
  767.             ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  768.                           ngx_close_file_n " \"%s\" failed",
  769.                           file[i].name.data);
  770.         }
  771.     }

  773.     ngx_destroy_pool(conf.temp_pool);

  775.     if (ngx_process == NGX_PROCESS_MASTER || ngx_is_init_cycle(old_cycle)) {

  777.         ngx_destroy_pool(old_cycle->pool);
  778.         cycle->old_cycle = NULL;

  780.         return cycle;
  781.     }


  784.     if (ngx_temp_pool == NULL) {
  785.         ngx_temp_pool = ngx_create_pool(128, cycle->log);
  786.         if (ngx_temp_pool == NULL) {
  787.             ngx_log_error(NGX_LOG_EMERG, cycle->log, 0,
  788.                           "could not create ngx_temp_pool");
  789.             exit(1);
  790.         }

  792.         n = 10;

  794.         if (ngx_array_init(&ngx_old_cycles, ngx_temp_pool, n,
  795.                            sizeof(ngx_cycle_t *))
  796.             != NGX_OK)
  797.         {
  798.             exit(1);
  799.         }

  801.         ngx_memzero(ngx_old_cycles.elts, n * sizeof(ngx_cycle_t *));

  803.         ngx_cleaner_event.handler = ngx_clean_old_cycles;
  804.         ngx_cleaner_event.log = cycle->log;
  805.         ngx_cleaner_event.data = &dumb;
  806.         dumb.fd = (ngx_socket_t) -1;
  807.     }

  809.     ngx_temp_pool->log = cycle->log;

  811.     old = ngx_array_push(&ngx_old_cycles);
  812.     if (old == NULL) {
  813.         exit(1);
  814.     }
  815.     *old = old_cycle;

  817.     if (!ngx_cleaner_event.timer_set) {
  818.         ngx_add_timer(&ngx_cleaner_event, 30000);
  819.         ngx_cleaner_event.timer_set = 1;
  820.     }

  822.     return cycle;


  825. failed:

  827.     if (!ngx_is_init_cycle(old_cycle)) {
  828.         old_ccf = (ngx_core_conf_t *) ngx_get_conf(old_cycle->conf_ctx,
  829.                                                    ngx_core_module);
  830.         if (old_ccf->environment) {
  831.             environ = old_ccf->environment;
  832.         }
  833.     }

  835.     /* rollback the new cycle configuration */

  837.     part = &cycle->open_files.part;
  838.     file = part->elts;

  840.     for (i = 0; /* void */ ; i++) {

  842.         if (i >= part->nelts) {
  843.             if (part->next == NULL) {
  844.                 break;
  845.             }
  846.             part = part->next;
  847.             file = part->elts;
  848.             i = 0;
  849.         }

  851.         if (file[i].fd == NGX_INVALID_FILE || file[i].fd == ngx_stderr) {
  852.             continue;
  853.         }

  855.         if (ngx_close_file(file[i].fd) == NGX_FILE_ERROR) {
  856.             ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  857.                           ngx_close_file_n " \"%s\" failed",
  858.                           file[i].name.data);
  859.         }
  860.     }

  862.     /* free the newly created shared memory */

  864.     part = &cycle->shared_memory.part;
  865.     shm_zone = part->elts;

  867.     for (i = 0; /* void */ ; i++) {

  869.         if (i >= part->nelts) {
  870.             if (part->next == NULL) {
  871.                 break;
  872.             }
  873.             part = part->next;
  874.             shm_zone = part->elts;
  875.             i = 0;
  876.         }

  878.         if (shm_zone[i].shm.addr == NULL) {
  879.             continue;
  880.         }

  882.         opart = &old_cycle->shared_memory.part;
  883.         oshm_zone = opart->elts;

  885.         for (n = 0; /* void */ ; n++) {

  887.             if (n >= opart->nelts) {
  888.                 if (opart->next == NULL) {
  889.                     break;
  890.                 }
  891.                 opart = opart->next;
  892.                 oshm_zone = opart->elts;
  893.                 n = 0;
  894.             }

  896.             if (shm_zone[i].shm.name.len != oshm_zone[n].shm.name.len) {
  897.                 continue;
  898.             }

  900.             if (ngx_strncmp(shm_zone[i].shm.name.data,
  901.                             oshm_zone[n].shm.name.data,
  902.                             shm_zone[i].shm.name.len)
  903.                 != 0)
  904.             {
  905.                 continue;
  906.             }

  908.             if (shm_zone[i].tag == oshm_zone[n].tag
  909.                 && shm_zone[i].shm.size == oshm_zone[n].shm.size
  910.                 && !shm_zone[i].noreuse)
  911.             {
  912.                 goto old_shm_zone_found;
  913.             }

  915.             break;
  916.         }

  918.         ngx_shm_free(&shm_zone[i].shm);

  920.     old_shm_zone_found:

  922.         continue;
  923.     }

  925.     if (ngx_test_config) {
  926.         ngx_destroy_cycle_pools(&conf);
  927.         return NULL;
  928.     }

  930.     ls = cycle->listening.elts;
  931.     for (i = 0; i < cycle->listening.nelts; i++) {
  932.         if (ls[i].fd == (ngx_socket_t) -1 || !ls[i].open) {
  933.             continue;
  934.         }

  936.         if (ngx_close_socket(ls[i].fd) == -1) {
  937.             ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
  938.                           ngx_close_socket_n " %V failed",
  939.                           &ls[i].addr_text);
  940.         }
  941.     }

  943.     ngx_destroy_cycle_pools(&conf);

  945.     return NULL;
  946. }


  949. static void
  950. ‌ngx_destroy_cycle_pools(ngx_conf_t *conf)
  951. {
  952.     ngx_destroy_pool(conf->temp_pool);
  953.     ngx_destroy_pool(conf->pool);
  954. }


  957. static ngx_int_t
  958. ‌ngx_init_zone_pool(ngx_cycle_t *cycle, ngx_shm_zone_t *zn)
  959. {
  960.     u_char           *file;
  961.     ngx_slab_pool_t  *sp;

  963.     sp = (ngx_slab_pool_t *) zn->shm.addr;

  965.     if (zn->shm.exists) {

  967.         if (sp == sp->addr) {
  968.             return NGX_OK;
  969.         }

  971. #if (NGX_WIN32)

  973.         /* remap at the required address */

  975.         if (ngx_shm_remap(&zn->shm, sp->addr) != NGX_OK) {
  976.             return NGX_ERROR;
  977.         }

  979.         sp = (ngx_slab_pool_t *) zn->shm.addr;

  981.         if (sp == sp->addr) {
  982.             return NGX_OK;
  983.         }

  985. #endif

  987.         ngx_log_error(NGX_LOG_EMERG, cycle->log, 0,
  988.                       "shared zone \"%V\" has no equal addresses: %p vs %p",
  989.                       &zn->shm.name, sp->addr, sp);
  990.         return NGX_ERROR;
  991.     }

  993.     sp->end = zn->shm.addr + zn->shm.size;
  994.     sp->min_shift = 3;
  995.     sp->addr = zn->shm.addr;

  997. #if (NGX_HAVE_ATOMIC_OPS)

  999.     file = NULL;

  1001. #else

  1003.     file = ngx_pnalloc(cycle->pool,
  1004.                        cycle->lock_file.len + zn->shm.name.len + 1);
  1005.     if (file == NULL) {
  1006.         return NGX_ERROR;
  1007.     }

  1009.     (void) ngx_sprintf(file, "%V%V%Z", &cycle->lock_file, &zn->shm.name);

  1011. #endif

  1013.     if (ngx_shmtx_create(&sp->mutex, &sp->lock, file) != NGX_OK) {
  1014.         return NGX_ERROR;
  1015.     }

  1017.     ngx_slab_init(sp);

  1019.     return NGX_OK;
  1020. }


  1023. ngx_int_t
  1024. ‌ngx_create_pidfile(ngx_str_t *name, ngx_log_t *log)
  1025. {
  1026.     size_t      len;
  1027.     ngx_int_t   rc;
  1028.     ngx_uint_t  create;
  1029.     ngx_file_t  file;
  1030.     u_char      pid[NGX_INT64_LEN + 2];

  1032.     if (ngx_process > NGX_PROCESS_MASTER) {
  1033.         return NGX_OK;
  1034.     }

  1036.     ngx_memzero(&file, sizeof(ngx_file_t));

  1038.     file.name = *name;
  1039.     file.log = log;

  1041.     create = ngx_test_config ? NGX_FILE_CREATE_OR_OPEN : NGX_FILE_TRUNCATE;

  1043.     file.fd = ngx_open_file(file.name.data, NGX_FILE_RDWR,
  1044.                             create, NGX_FILE_DEFAULT_ACCESS);

  1046.     if (file.fd == NGX_INVALID_FILE) {
  1047.         ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  1048.                       ngx_open_file_n " \"%s\" failed", file.name.data);
  1049.         return NGX_ERROR;
  1050.     }

  1052.     rc = NGX_OK;

  1054.     if (!ngx_test_config) {
  1055.         len = ngx_snprintf(pid, NGX_INT64_LEN + 2, "%P%N", ngx_pid) - pid;

  1057.         if (ngx_write_file(&file, pid, len, 0) == NGX_ERROR) {
  1058.             rc = NGX_ERROR;
  1059.         }
  1060.     }

  1062.     if (ngx_close_file(file.fd) == NGX_FILE_ERROR) {
  1063.         ngx_log_error(NGX_LOG_ALERT, log, ngx_errno,
  1064.                       ngx_close_file_n " \"%s\" failed", file.name.data);
  1065.     }

  1067.     return rc;
  1068. }


  1071. void
  1072. ‌ngx_delete_pidfile(ngx_cycle_t *cycle)
  1073. {
  1074.     u_char           *name;
  1075.     ngx_core_conf_t  *ccf;

  1077.     ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);

  1079.     name = ngx_new_binary ? ccf->oldpid.data : ccf->pid.data;

  1081.     if (ngx_delete_file(name) == NGX_FILE_ERROR) {
  1082.         ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
  1083.                       ngx_delete_file_n " \"%s\" failed", name);
  1084.     }
  1085. }


  1088. ngx_int_t
  1089. ‌ngx_signal_process(ngx_cycle_t *cycle, char *sig)
  1090. {
  1091.     ssize_t           n;
  1092.     ngx_pid_t         pid;
  1093.     ngx_file_t        file;
  1094.     ngx_core_conf_t  *ccf;
  1095.     u_char            buf[NGX_INT64_LEN + 2];

  1097.     ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "signal process started");

  1099.     ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);

  1101.     ngx_memzero(&file, sizeof(ngx_file_t));

  1103.     file.name = ccf->pid;
  1104.     file.log = cycle->log;

  1106.     file.fd = ngx_open_file(file.name.data, NGX_FILE_RDONLY,
  1107.                             NGX_FILE_OPEN, NGX_FILE_DEFAULT_ACCESS);

  1109.     if (file.fd == NGX_INVALID_FILE) {
  1110.         ngx_log_error(NGX_LOG_ERR, cycle->log, ngx_errno,
  1111.                       ngx_open_file_n " \"%s\" failed", file.name.data);
  1112.         return 1;
  1113.     }

  1115.     n = ngx_read_file(&file, buf, NGX_INT64_LEN + 2, 0);

  1117.     if (ngx_close_file(file.fd) == NGX_FILE_ERROR) {
  1118.         ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
  1119.                       ngx_close_file_n " \"%s\" failed", file.name.data);
  1120.     }

  1122.     if (n == NGX_ERROR) {
  1123.         return 1;
  1124.     }

  1126.     while (n-- && (buf[n] == CR || buf[n] == LF)) { /* void */ }

  1128.     pid = ngx_atoi(buf, ++n);

  1130.     if (pid == (ngx_pid_t) NGX_ERROR) {
  1131.         ngx_log_error(NGX_LOG_ERR, cycle->log, 0,
  1132.                       "invalid PID number \"%*s\" in \"%s\"",
  1133.                       n, buf, file.name.data);
  1134.         return 1;
  1135.     }

  1137.     return ngx_os_signal_process(cycle, sig, pid);

  1139. }


  1142. static ngx_int_t
  1143. ‌ngx_test_lockfile(u_char *file, ngx_log_t *log)
  1144. {
  1145. #if !(NGX_HAVE_ATOMIC_OPS)
  1146.     ngx_fd_t  fd;

  1148.     fd = ngx_open_file(file, NGX_FILE_RDWR, NGX_FILE_CREATE_OR_OPEN,
  1149.                        NGX_FILE_DEFAULT_ACCESS);

  1151.     if (fd == NGX_INVALID_FILE) {
  1152.         ngx_log_error(NGX_LOG_EMERG, log, ngx_errno,
  1153.                       ngx_open_file_n " \"%s\" failed", file);
  1154.         return NGX_ERROR;
  1155.     }

  1157.     if (ngx_close_file(fd) == NGX_FILE_ERROR) {
  1158.         ngx_log_error(NGX_LOG_ALERT, log, ngx_errno,
  1159.                       ngx_close_file_n " \"%s\" failed", file);
  1160.     }

  1162.     if (ngx_delete_file(file) == NGX_FILE_ERROR) {
  1163.         ngx_log_error(NGX_LOG_ALERT, log, ngx_errno,
  1164.                       ngx_delete_file_n " \"%s\" failed", file);
  1165.     }

  1167. #endif

  1169.     return NGX_OK;
  1170. }


  1173. void
  1174. ‌ngx_reopen_files(ngx_cycle_t *cycle, ngx_uid_t user)
  1175. {
  1176.     ngx_fd_t          fd;
  1177.     ngx_uint_t        i;
  1178.     ngx_list_part_t  *part;
  1179.     ngx_open_file_t  *file;

  1181.     part = &cycle->open_files.part;
  1182.     file = part->elts;

  1184.     for (i = 0; /* void */ ; i++) {

  1186.         if (i >= part->nelts) {
  1187.             if (part->next == NULL) {
  1188.                 break;
  1189.             }
  1190.             part = part->next;
  1191.             file = part->elts;
  1192.             i = 0;
  1193.         }

  1195.         if (file[i].name.len == 0) {
  1196.             continue;
  1197.         }

  1199.         if (file[i].flush) {
  1200.             file[i].flush(&file[i], cycle->log);
  1201.         }

  1203.         fd = ngx_open_file(file[i].name.data, NGX_FILE_APPEND,
  1204.                            NGX_FILE_CREATE_OR_OPEN, NGX_FILE_DEFAULT_ACCESS);

  1206.         ngx_log_debug3(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
  1207.                        "reopen file \"%s\", old:%d new:%d",
  1208.                        file[i].name.data, file[i].fd, fd);

  1210.         if (fd == NGX_INVALID_FILE) {
  1211.             ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1212.                           ngx_open_file_n " \"%s\" failed", file[i].name.data);
  1213.             continue;
  1214.         }

  1216. #if !(NGX_WIN32)
  1217.         if (user != (ngx_uid_t) NGX_CONF_UNSET_UINT) {
  1218.             ngx_file_info_t  fi;

  1220.             if (ngx_file_info(file[i].name.data, &fi) == NGX_FILE_ERROR) {
  1221.                 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1222.                               ngx_file_info_n " \"%s\" failed",
  1223.                               file[i].name.data);

  1225.                 if (ngx_close_file(fd) == NGX_FILE_ERROR) {
  1226.                     ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1227.                                   ngx_close_file_n " \"%s\" failed",
  1228.                                   file[i].name.data);
  1229.                 }

  1231.                 continue;
  1232.             }

  1234.             if (fi.st_uid != user) {
  1235.                 if (chown((const char *) file[i].name.data, user, -1) == -1) {
  1236.                     ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1237.                                   "chown(\"%s\", %d) failed",
  1238.                                   file[i].name.data, user);

  1240.                     if (ngx_close_file(fd) == NGX_FILE_ERROR) {
  1241.                         ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1242.                                       ngx_close_file_n " \"%s\" failed",
  1243.                                       file[i].name.data);
  1244.                     }

  1246.                     continue;
  1247.                 }
  1248.             }

  1250.             if ((fi.st_mode & (S_IRUSR|S_IWUSR)) != (S_IRUSR|S_IWUSR)) {

  1252.                 fi.st_mode |= (S_IRUSR|S_IWUSR);

  1254.                 if (chmod((const char *) file[i].name.data, fi.st_mode) == -1) {
  1255.                     ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1256.                                   "chmod() \"%s\" failed", file[i].name.data);

  1258.                     if (ngx_close_file(fd) == NGX_FILE_ERROR) {
  1259.                         ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1260.                                       ngx_close_file_n " \"%s\" failed",
  1261.                                       file[i].name.data);
  1262.                     }

  1264.                     continue;
  1265.                 }
  1266.             }
  1267.         }

  1269.         if (fcntl(fd, F_SETFD, FD_CLOEXEC) == -1) {
  1270.             ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1271.                           "fcntl(FD_CLOEXEC) \"%s\" failed",
  1272.                           file[i].name.data);

  1274.             if (ngx_close_file(fd) == NGX_FILE_ERROR) {
  1275.                 ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1276.                               ngx_close_file_n " \"%s\" failed",
  1277.                               file[i].name.data);
  1278.             }

  1280.             continue;
  1281.         }
  1282. #endif

  1284.         if (ngx_close_file(file[i].fd) == NGX_FILE_ERROR) {
  1285.             ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno,
  1286.                           ngx_close_file_n " \"%s\" failed",
  1287.                           file[i].name.data);
  1288.         }

  1290.         file[i].fd = fd;
  1291.     }

  1293.     (void) ngx_log_redirect_stderr(cycle);
  1294. }


  1297. ngx_shm_zone_t *
  1298. ‌ngx_shared_memory_add(ngx_conf_t *cf, ngx_str_t *name, size_t size, void *tag)
  1299. {
  1300.     ngx_uint_t        i;
  1301.     ngx_shm_zone_t   *shm_zone;
  1302.     ngx_list_part_t  *part;

  1304.     part = &cf->cycle->shared_memory.part;
  1305.     shm_zone = part->elts;

  1307.     for (i = 0; /* void */ ; i++) {

  1309.         if (i >= part->nelts) {
  1310.             if (part->next == NULL) {
  1311.                 break;
  1312.             }
  1313.             part = part->next;
  1314.             shm_zone = part->elts;
  1315.             i = 0;
  1316.         }

  1318.         if (name->len != shm_zone[i].shm.name.len) {
  1319.             continue;
  1320.         }

  1322.         if (ngx_strncmp(name->data, shm_zone[i].shm.name.data, name->len)
  1323.             != 0)
  1324.         {
  1325.             continue;
  1326.         }

  1328.         if (tag != shm_zone[i].tag) {
  1329.             ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
  1330.                             "the shared memory zone \"%V\" is "
  1331.                             "already declared for a different use",
  1332.                             &shm_zone[i].shm.name);
  1333.             return NULL;
  1334.         }

  1336.         if (shm_zone[i].shm.size == 0) {
  1337.             shm_zone[i].shm.size = size;
  1338.         }

  1340.         if (size && size != shm_zone[i].shm.size) {
  1341.             ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
  1342.                             "the size %uz of shared memory zone \"%V\" "
  1343.                             "conflicts with already declared size %uz",
  1344.                             size, &shm_zone[i].shm.name, shm_zone[i].shm.size);
  1345.             return NULL;
  1346.         }

  1348.         return &shm_zone[i];
  1349.     }

  1351.     shm_zone = ngx_list_push(&cf->cycle->shared_memory);

  1353.     if (shm_zone == NULL) {
  1354.         return NULL;
  1355.     }

  1357.     shm_zone->data = NULL;
  1358.     shm_zone->shm.log = cf->cycle->log;
  1359.     shm_zone->shm.addr = NULL;
  1360.     shm_zone->shm.size = size;
  1361.     shm_zone->shm.name = *name;
  1362.     shm_zone->shm.exists = 0;
  1363.     shm_zone->init = NULL;
  1364.     shm_zone->tag = tag;
  1365.     shm_zone->noreuse = 0;

  1367.     return shm_zone;
  1368. }


  1371. static void
  1372. ‌ngx_clean_old_cycles(ngx_event_t *ev)
  1373. {
  1374.     ngx_uint_t     i, n, found, live;
  1375.     ngx_log_t     *log;
  1376.     ngx_cycle_t  **cycle;

  1378.     log = ngx_cycle->log;
  1379.     ngx_temp_pool->log = log;

  1381.     ngx_log_debug0(NGX_LOG_DEBUG_CORE, log, 0, "clean old cycles");

  1383.     live = 0;

  1385.     cycle = ngx_old_cycles.elts;
  1386.     for (i = 0; i < ngx_old_cycles.nelts; i++) {

  1388.         if (cycle[i] == NULL) {
  1389.             continue;
  1390.         }

  1392.         found = 0;

  1394.         for (n = 0; n < cycle[i]->connection_n; n++) {
  1395.             if (cycle[i]->connections[n].fd != (ngx_socket_t) -1) {
  1396.                 found = 1;

  1398.                 ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, "live fd:%ui", n);

  1400.                 break;
  1401.             }
  1402.         }

  1404.         if (found) {
  1405.             live = 1;
  1406.             continue;
  1407.         }

  1409.         ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, "clean old cycle: %ui", i);

  1411.         ngx_destroy_pool(cycle[i]->pool);
  1412.         cycle[i] = NULL;
  1413.     }

  1415.     ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, "old cycles status: %ui", live);

  1417.     if (live) {
  1418.         ngx_add_timer(ev, 30000);

  1420.     } else {
  1421.         ngx_destroy_pool(ngx_temp_pool);
  1422.         ngx_temp_pool = NULL;
  1423.         ngx_old_cycles.nelts = 0;
  1424.     }
  1425. }


  1428. void
  1429. ‌ngx_set_shutdown_timer(ngx_cycle_t *cycle)
  1430. {
  1431.     ngx_core_conf_t  *ccf;

  1433.     ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);

  1435.     if (ccf->shutdown_timeout) {
  1436.         ngx_shutdown_event.handler = ngx_shutdown_timer_handler;
  1437.         ngx_shutdown_event.data = cycle;
  1438.         ngx_shutdown_event.log = cycle->log;
  1439.         ngx_shutdown_event.cancelable = 1;

  1441.         ngx_add_timer(&ngx_shutdown_event, ccf->shutdown_timeout);
  1442.     }
  1443. }


  1446. static void
  1447. ‌ngx_shutdown_timer_handler(ngx_event_t *ev)
  1448. {
  1449.     ngx_uint_t         i;
  1450.     ngx_cycle_t       *cycle;
  1451.     ngx_connection_t  *c;

  1453.     cycle = ev->data;

  1455.     c = cycle->connections;

  1457.     for (i = 0; i < cycle->connection_n; i++) {

  1459.         if (c[i].fd == (ngx_socket_t) -1
  1460.             || c[i].read == NULL
  1461.             || c[i].read->accept
  1462.             || c[i].read->channel
  1463.             || c[i].read->resolver)
  1464.         {
  1465.             continue;
  1466.         }

  1468.         ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0,
  1469.                        "*%uA shutdown timeout", c[i].number);

  1471.         c[i].close = 1;
  1472.         c[i].error = 1;

  1474.         c[i].read->handler(c[i].read);
  1475.     }
  1476. }

One Level Up Top Level