Home
last modified time | relevance | path

Searched refs:us (Results 1 – 13 of 13) sorted by relevance

/unit/src/
H A Dnxt_http_proxy.c19 nxt_upstream_server_t *us);
21 nxt_upstream_server_t *us);
23 nxt_upstream_server_t *us);
122 nxt_upstream_server_t *us; in nxt_upstream_proxy_handler() local
142 us->peer.http = peer; in nxt_upstream_proxy_handler()
143 peer->server = us; in nxt_upstream_proxy_handler()
145 us->upstream = upstream; in nxt_upstream_proxy_handler()
162 us->state->ready(task, us); in nxt_http_proxy_server_get()
171 peer = us->peer.http; in nxt_http_proxy_upstream_ready()
173 peer->protocol = us->protocol; in nxt_http_proxy_upstream_ready()
[all …]
H A Dnxt_upstream_round_robin.c33 nxt_upstream_server_t *us);
165 nxt_upstream_round_robin_server_get(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_upstream_round_robin_server_get() argument
175 round_robin = us->upstream->type.round_robin; in nxt_upstream_round_robin_server_get()
195 us->state->error(task, us); in nxt_upstream_round_robin_server_get()
200 us->sockaddr = best->sockaddr; in nxt_upstream_round_robin_server_get()
201 us->protocol = best->protocol; in nxt_upstream_round_robin_server_get()
202 us->server.round_robin = best; in nxt_upstream_round_robin_server_get()
204 us->state->ready(task, us); in nxt_upstream_round_robin_server_get()
H A Dnxt_http_source.c58 us->protocol_source = hs; in nxt_http_source_handler()
66 hs->header_in.hash = us->header_hash; in nxt_http_source_handler()
67 hs->upstream = us; in nxt_http_source_handler()
70 stream = us->stream; in nxt_http_source_handler()
78 us->stream = stream; in nxt_http_source_handler()
79 stream->upstream = us; in nxt_http_source_handler()
400 hs = us->protocol_source; in nxt_http_source_content_length()
419 hs = us->protocol_source; in nxt_http_source_transfer_encoding()
432 nxt_upstream_source_t *us; in nxt_http_source_header_ready() local
435 us = hs->upstream; in nxt_http_source_header_ready()
[all …]
H A Dnxt_upstream.h18 nxt_upstream_server_t *us);
20 nxt_upstream_server_t *us);
32 nxt_upstream_server_t *us);
H A Dnxt_fastcgi_source.c132 us->protocol_source = fs; in nxt_fastcgi_source_handler()
134 fs->header_in.list = nxt_list_create(us->buffers.mem_pool, 8, in nxt_fastcgi_source_handler()
140 fs->header_in.hash = us->header_hash; in nxt_fastcgi_source_handler()
141 fs->upstream = us; in nxt_fastcgi_source_handler()
144 stream = us->stream; in nxt_fastcgi_source_handler()
152 us->stream = stream; in nxt_fastcgi_source_handler()
153 stream->upstream = us; in nxt_fastcgi_source_handler()
171 fs->record.parse.mem_pool = us->buffers.mem_pool; in nxt_fastcgi_source_handler()
626 fs = us->protocol_source; in nxt_fastcgi_source_status()
636 nxt_fastcgi_source_content_length(nxt_upstream_source_t *us, in nxt_fastcgi_source_content_length() argument
[all …]
H A Dnxt_upstream_source.h34 nxt_upstream_source_t *us, nxt_name_value_t *nv);
77 NXT_EXPORT nxt_int_t nxt_upstream_name_value_ignore(nxt_upstream_source_t *us,
H A Dnxt_stream_source.c40 nxt_upstream_source_t *us; in nxt_stream_source_connect() local
44 us = stream->upstream; in nxt_stream_source_connect()
46 if (nxt_slow_path(!nxt_buf_pool_obtainable(&us->buffers))) { in nxt_stream_source_connect()
49 us->buffers.max, us->buffers.size / 1024); in nxt_stream_source_connect()
53 c = nxt_event_conn_create(us->buffers.mem_pool, thr->log); in nxt_stream_source_connect()
61 nxt_conn_work_queue_set(c, us->work_queue); in nxt_stream_source_connect()
63 c->remote = us->peer->sockaddr; in nxt_stream_source_connect()
H A Dnxt_http_source.h42 nxt_upstream_source_t *us, nxt_http_source_request_create_t request_create);
H A Dnxt_upstream_source.c68 nxt_upstream_name_value_ignore(nxt_upstream_source_t *us, nxt_name_value_t *nv) in nxt_upstream_name_value_ignore() argument
H A Dnxt_fastcgi_source.h85 nxt_upstream_source_t *us,
/unit/pkg/deb/
H A DMakefile188 cd debuild/$(SRCDIR) && debuild -us -uc
261 cd debuild-$*/$(SRCDIR) && debuild -us -uc
/unit/src/test/
H A Dnxt_cq_test.c42 elapsed_time(size_t us) in elapsed_time() argument
48 return t.tv_sec * 1000000 + t.tv_usec - us; in elapsed_time()
/unit/
H A DREADME.md180 - For security issues, [email us](security-alert@nginx.org), mentioning