nxt_runtime.c (54:8c3dfaedd423) nxt_runtime.c (62:5e1efcc7b740)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 483 unchanged lines hidden (view full) ---

492 task, rt, engine);
493 }
494}
495
496
497static void
498nxt_runtime_close_idle_connections(nxt_event_engine_t *engine)
499{
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 483 unchanged lines hidden (view full) ---

492 task, rt, engine);
493 }
494}
495
496
497static void
498nxt_runtime_close_idle_connections(nxt_event_engine_t *engine)
499{
500 nxt_conn_t *c;
500 nxt_queue_t *idle;
501 nxt_queue_link_t *link, *next;
501 nxt_queue_t *idle;
502 nxt_queue_link_t *link, *next;
502 nxt_event_conn_t *c;
503
504 nxt_debug(&engine->task, "close idle connections");
505
506 idle = &engine->idle_connections;
507
508 for (link = nxt_queue_head(idle);
509 link != nxt_queue_tail(idle);
510 link = next)
511 {
512 next = nxt_queue_next(link);
503
504 nxt_debug(&engine->task, "close idle connections");
505
506 idle = &engine->idle_connections;
507
508 for (link = nxt_queue_head(idle);
509 link != nxt_queue_tail(idle);
510 link = next)
511 {
512 next = nxt_queue_next(link);
513 c = nxt_queue_link_data(link, nxt_event_conn_t, link);
513 c = nxt_queue_link_data(link, nxt_conn_t, link);
514
515 if (!c->socket.read_ready) {
516 nxt_queue_remove(link);
514
515 if (!c->socket.read_ready) {
516 nxt_queue_remove(link);
517 nxt_event_conn_close(engine, c);
517 nxt_conn_close(engine, c);
518 }
519 }
520}
521
522
523static void
524nxt_runtime_exit(nxt_task_t *task, void *obj, void *data)
525{

--- 1256 unchanged lines hidden --- 		518 }
519 }
520}
521
522
523static void
524nxt_runtime_exit(nxt_task_t *task, void *obj, void *data)
525{

--- 1256 unchanged lines hidden ---