Home
last modified time | relevance | path

Searched refs:peer (Results 1 – 11 of 11) sorted by relevance

/unit/src/
H A Dnxt_http_proxy.c137 r->peer = peer; in nxt_upstream_proxy_handler()
142 us->peer.http = peer; in nxt_upstream_proxy_handler()
171 peer = us->peer.http; in nxt_http_proxy_upstream_ready()
177 nxt_http_proto[peer->protocol].peer_connect(task, peer); in nxt_http_proxy_upstream_ready()
209 peer = data; in nxt_http_proxy_header_send()
231 peer = data; in nxt_http_proxy_header_sent()
254 peer = data; in nxt_http_proxy_header_read()
309 nxt_http_proto[peer->protocol].peer_read(task, peer); in nxt_http_proxy_send_body()
349 peer = r->peer; in nxt_http_proxy_buf_mem_completion()
382 peer = r->peer; in nxt_http_proxy_error()
[all …]
H A Dnxt_conn_proxy.c62 nxt_conn_t *peer; in nxt_conn_proxy_create() local
93 p->peer = peer; in nxt_conn_proxy_create()
102 nxt_conn_t *peer; in nxt_conn_proxy() local
114 peer = p->peer; in nxt_conn_proxy()
248 peer = obj; in nxt_conn_proxy_connected()
263 nxt_conn_wait(peer); in nxt_conn_proxy_connected()
299 peer = obj; in nxt_conn_proxy_peer_read()
312 peer->read = b; in nxt_conn_proxy_peer_read()
367 peer = obj; in nxt_conn_proxy_peer_read_ready()
558 peer = obj; in nxt_conn_proxy_peer_write_ready()
[all …]
H A Dnxt_port_rpc.c84 lhq->key_hash = nxt_murmur_hash2(peer, sizeof(*peer)); in nxt_port_rpc_lhq_peer()
106 if (peer != -1) { in nxt_port_rpc_register_handler()
142 reg->peer = -1; in nxt_port_rpc_register_handler_ex()
200 if (nxt_slow_path(peer == reg->peer)) { in nxt_port_rpc_ex_set_peer()
204 if (reg->peer != -1) { in nxt_port_rpc_ex_set_peer()
207 reg->peer = -1; in nxt_port_rpc_ex_set_peer()
210 if (peer == -1) { in nxt_port_rpc_ex_set_peer()
214 reg->peer = peer; in nxt_port_rpc_ex_set_peer()
246 reg->peer = -1; in nxt_port_rpc_ex_set_peer()
407 nxt_assert(reg->peer == peer); in nxt_port_rpc_remove_peer()
[all …]
H A Dnxt_h1proto.c2141 r = peer->request; in nxt_h1p_peer_connect()
2224 peer = data; in nxt_h1p_peer_connected()
2239 peer = data; in nxt_h1p_peer_refused()
2383 peer = data; in nxt_h1p_peer_header_sent()
2502 peer = data; in nxt_h1p_peer_header_read_done()
2523 peer->fields = peer->proto.h1->parser.fields; in nxt_h1p_peer_header_read_done()
2664 peer = data; in nxt_h1p_peer_read_done()
2705 peer->body = out; in nxt_h1p_peer_body_process()
2718 peer = data; in nxt_h1p_peer_closed()
2745 peer = data; in nxt_h1p_peer_error()
[all …]
H A Dnxt_port_rpc.h18 nxt_pid_t peer, void *data);
25 void *ex, nxt_pid_t peer);
29 nxt_pid_t peer);
H A Dnxt_stream_module.c77 p->peer->socket.data = p; in nxt_stream_connection_peer()
89 p->peer->remote = up->sockaddr; in nxt_stream_connection_peer()
H A Dnxt_http.h178 nxt_http_peer_t *peer; member
265 void (*peer_connect)(nxt_task_t *task, nxt_http_peer_t *peer);
266 void (*peer_header_send)(nxt_task_t *task, nxt_http_peer_t *peer);
267 void (*peer_header_read)(nxt_task_t *task, nxt_http_peer_t *peer);
268 void (*peer_read)(nxt_task_t *task, nxt_http_peer_t *peer);
269 void (*peer_close)(nxt_task_t *task, nxt_http_peer_t *peer);
H A Dnxt_upstream.h72 } peer; member
H A Dnxt_upstream_source.h54 nxt_upstream_peer_t *peer; member
H A Dnxt_conn.h328 nxt_conn_t *peer; member
H A Dnxt_stream_source.c63 c->remote = us->peer->sockaddr; in nxt_stream_source_connect()