nxt_router.c (136:98eee55fda19) nxt_router.c (138:59fc46dd5e1d)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_router.h>

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

1650 if (nxt_slow_path(port == NULL)) {
1651 // 500 Application port not found
1652 nxt_log_alert(task->log, "application port not found");
1653 }
1654
1655 engine = task->thread->engine;
1656
1657 do {
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_router.h>

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

1650 if (nxt_slow_path(port == NULL)) {
1651 // 500 Application port not found
1652 nxt_log_alert(task->log, "application port not found");
1653 }
1654
1655 engine = task->thread->engine;
1656
1657 do {
1658 req_id = nxt_random(&nxt_random_data);
1658 req_id = nxt_random(&task->thread->random);
1659 } while (nxt_event_engine_request_find(engine, req_id) != NULL);
1660
1661 rc = nxt_conn_request_add(c, req_id);
1662
1663 if (nxt_slow_path(rc == NULL)) {
1664 // 500 Failed to allocate req->conn link
1665 nxt_log_alert(task->log, "failed to allocate req->conn link");
1666 }

--- 199 unchanged lines hidden ---
1659 } while (nxt_event_engine_request_find(engine, req_id) != NULL);
1660
1661 rc = nxt_conn_request_add(c, req_id);
1662
1663 if (nxt_slow_path(rc == NULL)) {
1664 // 500 Failed to allocate req->conn link
1665 nxt_log_alert(task->log, "failed to allocate req->conn link");
1666 }

--- 199 unchanged lines hidden ---