nxt_stream_module.c (65:10688b89aa16) nxt_stream_module.c (493:745222d540a2)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

60 nxt_conn_t *c;
61 nxt_conn_proxy_t *p;
62
63 c = up->data;
64
65 up->sockaddr->type = SOCK_STREAM;
66
67 nxt_log_debug(c->socket.log, "stream connection peer %*s",
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_runtime.h>

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

60 nxt_conn_t *c;
61 nxt_conn_proxy_t *p;
62
63 c = up->data;
64
65 up->sockaddr->type = SOCK_STREAM;
66
67 nxt_log_debug(c->socket.log, "stream connection peer %*s",
68 up->sockaddr->length, nxt_sockaddr_start(up->sockaddr));
68 (size_t) up->sockaddr->length,
69 nxt_sockaddr_start(up->sockaddr));
69
70 p = nxt_conn_proxy_create(c);
71 if (nxt_slow_path(p == NULL)) {
72 goto fail;
73 }
74
75 p->client->socket.data = p;
76 p->peer->socket.data = p;

--- 54 unchanged lines hidden ---
70
71 p = nxt_conn_proxy_create(c);
72 if (nxt_slow_path(p == NULL)) {
73 goto fail;
74 }
75
76 p->client->socket.data = p;
77 p->peer->socket.data = p;

--- 54 unchanged lines hidden ---