Searched refs:peer (Results 1 – 8 of 8) sorted by relevance
/unit/src/ |
H A D | nxt_http_proxy.c | 137 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 D | nxt_conn_proxy.c | 62 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 D | nxt_port_rpc.c | 84 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 D | nxt_h1proto.c | 2151 r = peer->request; in nxt_h1p_peer_connect() 2234 peer = data; in nxt_h1p_peer_connected() 2249 peer = data; in nxt_h1p_peer_refused() 2393 peer = data; in nxt_h1p_peer_header_sent() 2512 peer = data; in nxt_h1p_peer_header_read_done() 2533 peer->fields = peer->proto.h1->parser.fields; in nxt_h1p_peer_header_read_done() 2674 peer = data; in nxt_h1p_peer_read_done() 2715 peer->body = out; in nxt_h1p_peer_body_process() 2728 peer = data; in nxt_h1p_peer_closed() 2755 peer = data; in nxt_h1p_peer_error() [all …]
|
H A D | nxt_port_rpc.h | 18 nxt_pid_t peer, void *data); 25 void *ex, nxt_pid_t peer); 29 nxt_pid_t peer);
|
H A D | nxt_http.h | 183 nxt_http_peer_t *peer; member 276 void (*peer_connect)(nxt_task_t *task, nxt_http_peer_t *peer); 277 void (*peer_header_send)(nxt_task_t *task, nxt_http_peer_t *peer); 278 void (*peer_header_read)(nxt_task_t *task, nxt_http_peer_t *peer); 279 void (*peer_read)(nxt_task_t *task, nxt_http_peer_t *peer); 280 void (*peer_close)(nxt_task_t *task, nxt_http_peer_t *peer);
|
H A D | nxt_upstream.h | 72 } peer; member
|
H A D | nxt_conn.h | 328 nxt_conn_t *peer; member
|