Lines Matching refs:router

174     nxt_router_t *router, nxt_router_temp_conf_t *tmcf,
194 static void nxt_router_apps_sort(nxt_task_t *task, nxt_router_t *router,
197 static void nxt_router_engines_post(nxt_router_t *router,
340 nxt_router_t *router; in nxt_router_start() local
364 router = nxt_zalloc(sizeof(nxt_router_t)); in nxt_router_start()
365 if (nxt_slow_path(router == NULL)) { in nxt_router_start()
369 nxt_queue_init(&router->engines); in nxt_router_start()
370 nxt_queue_init(&router->sockets); in nxt_router_start()
371 nxt_queue_init(&router->apps); in nxt_router_start()
373 nxt_router = router; in nxt_router_start()
811 tmcf->router_conf->router = nxt_router; in nxt_router_conf_data_handler()
1173 nxt_router_t *router; in nxt_router_conf_apply() local
1255 router = rtcf->router; in nxt_router_conf_apply()
1257 ret = nxt_router_engines_create(task, router, tmcf, interface); in nxt_router_conf_apply()
1267 nxt_router_apps_sort(task, router, tmcf); in nxt_router_conf_apply()
1271 nxt_router_engines_post(router, tmcf); in nxt_router_conf_apply()
1273 nxt_queue_add(&router->sockets, &updating_sockets); in nxt_router_conf_apply()
1274 nxt_queue_add(&router->sockets, &creating_sockets); in nxt_router_conf_apply()
1276 if (router->access_log != rtcf->access_log) { in nxt_router_conf_apply()
1277 nxt_router_access_log_use(&router->lock, rtcf->access_log); in nxt_router_conf_apply()
1279 nxt_router_access_log_release(task, &router->lock, router->access_log); in nxt_router_conf_apply()
1281 router->access_log = rtcf->access_log; in nxt_router_conf_apply()
1324 lock = &rtcf->router->lock; in nxt_router_conf_ready()
1351 nxt_router_t *router; in nxt_router_conf_error() local
1380 router = rtcf->router; in nxt_router_conf_error()
1382 nxt_queue_add(&router->sockets, &keeping_sockets); in nxt_router_conf_error()
1383 nxt_queue_add(&router->sockets, &deleting_sockets); in nxt_router_conf_error()
1385 nxt_queue_add(&router->apps, &tmcf->previous); in nxt_router_conf_error()
1389 nxt_router_access_log_release(task, &router->lock, rtcf->access_log); in nxt_router_conf_error()
1615 nxt_router_t *router; in nxt_router_conf_create() local
1682 router = rtcf->router; in nxt_router_conf_create()
1725 prev = nxt_router_app_find(&router->apps, &name); in nxt_router_conf_create()
2149 nxt_queue_add(&deleting_sockets, &router->sockets); in nxt_router_conf_create()
2150 nxt_queue_init(&router->sockets); in nxt_router_conf_create()
2757 nxt_router_t *router; in nxt_router_listen_socket_find() local
2761 router = tmcf->router_conf->router; in nxt_router_listen_socket_find()
2763 for (qlk = nxt_queue_first(&router->sockets); in nxt_router_listen_socket_find()
2764 qlk != nxt_queue_tail(&router->sockets); in nxt_router_listen_socket_find()
3189 nxt_router_engines_create(nxt_task_t *task, nxt_router_t *router, in nxt_router_engines_create() argument
3207 for (qlk = nxt_queue_first(&router->engines); in nxt_router_engines_create()
3208 qlk != nxt_queue_tail(&router->engines); in nxt_router_engines_create()
3500 nxt_router_apps_sort(nxt_task_t *task, nxt_router_t *router, in nxt_router_apps_sort() argument
3505 nxt_queue_each(app, &router->apps, nxt_app_t, link) { in nxt_router_apps_sort()
3511 nxt_queue_add(&router->apps, &tmcf->previous); in nxt_router_apps_sort()
3512 nxt_queue_add(&router->apps, &tmcf->apps); in nxt_router_apps_sort()
3517 nxt_router_engines_post(nxt_router_t *router, nxt_router_temp_conf_t *tmcf) in nxt_router_engines_post() argument
3534 nxt_queue_insert_tail(&router->engines, &engine->link0); in nxt_router_engines_post()
3691 lock = &skcf->router_conf->router->lock; in nxt_router_listen_socket_create()
3859 lock = &skcf->router_conf->router->lock; in nxt_router_listen_socket_release()
3959 lock = &rtcf->router->lock; in nxt_router_conf_release()