Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_upstream.h30 nxt_router_temp_conf_t *tmcf, nxt_upstream_t *upstream);
55 nxt_upstream_t upstream[0]; member
62 nxt_upstream_t *upstream; member
78 nxt_upstream_t *upstream);
H A Dnxt_upstream.c56 string = nxt_str_dup(mp, &upstreams->upstream[i].name, &name); in nxt_upstreams_create()
62 &upstreams->upstream[i]); in nxt_upstreams_create()
79 nxt_upstream_t *upstream; in nxt_upstream_find() local
85 upstream = &upstreams->upstream[0]; in nxt_upstream_find()
89 if (nxt_strstr_eq(&upstream[i].name, name)) { in nxt_upstream_find()
125 u = &upstreams->upstream[0]; in nxt_upstreams_joint_create()
H A Dnxt_upstream_round_robin.c31 nxt_router_temp_conf_t *tmcf, nxt_upstream_t *upstream);
44 nxt_conf_value_t *upstream_conf, nxt_upstream_t *upstream) in nxt_upstream_round_robin_create() argument
115 upstream->proto = &nxt_upstream_round_robin_proto; in nxt_upstream_round_robin_create()
116 upstream->type.round_robin = urr; in nxt_upstream_round_robin_create()
124 nxt_upstream_t *upstream) in nxt_upstream_round_robin_joint_create() argument
139 *u = *upstream; in nxt_upstream_round_robin_joint_create()
141 urrcf = upstream->type.round_robin; in nxt_upstream_round_robin_joint_create()
175 round_robin = us->upstream->type.round_robin; in nxt_upstream_round_robin_server_get()
H A Dnxt_http_source.c67 hs->upstream = us; in nxt_http_source_handler()
79 stream->upstream = us; in nxt_http_source_handler()
144 ret = nxt_buf_pool_mem_alloc(&hs->upstream->buffers, 0); in nxt_http_source_request_create()
149 b = hs->upstream->buffers.current; in nxt_http_source_request_create()
150 hs->upstream->buffers.current = NULL; in nxt_http_source_request_create()
363 if (unv->handler(hs->upstream, nv) != NXT_OK) { in nxt_http_source_header_line_process()
435 us = hs->upstream; in nxt_http_source_header_ready()
484 hs->upstream->state->ready_handler(hs); in nxt_http_source_header_ready()
562 b->data = hs->upstream->data; in nxt_http_source_body_filter()
588 hs->upstream->buffers.max, hs->upstream->buffers.size); in nxt_http_source_sync_buffer()
[all …]
H A Dnxt_fastcgi_source.c141 fs->upstream = us; in nxt_fastcgi_source_handler()
153 stream->upstream = us; in nxt_fastcgi_source_handler()
217 b = fs->upstream->buffers.current; in nxt_fastcgi_request_create()
218 fs->upstream->buffers.current = NULL; in nxt_fastcgi_request_create()
533 fs->upstream->buffers.max, fs->upstream->buffers.size); in nxt_fastcgi_source_sync_buffer()
585 if (unv->handler(fs->upstream, nv) == NXT_OK) { in nxt_fastcgi_source_header_process()
672 fs->upstream->state->ready_handler(fs); in nxt_fastcgi_source_header_ready()
695 b->data = fs->upstream->data; in nxt_fastcgi_source_body_filter()
721 b->data = fs->upstream->data; in nxt_fastcgi_source_last_buf()
736 fs = stream->upstream->protocol_source; in nxt_fastcgi_source_error()
[all …]
H A Dnxt_stream_source.c44 us = stream->upstream; in nxt_stream_source_connect()
182 buffers = &stream->upstream->buffers; in nxt_stream_source_read_ready()
265 stream->upstream->work_queue, in nxt_stream_source_read_done()
273 stream->upstream->work_queue, in nxt_stream_source_read_done()
296 b = nxt_buf_mem_alloc(stream->upstream->buffers.mem_pool, 0, 0); in nxt_stream_source_process_buffers()
374 if (size >= 256 || size >= stream->upstream->buffers.size) { in nxt_stream_source_buf_completion()
383 stream->upstream->work_queue, in nxt_stream_source_buf_completion()
391 nxt_buf_free(stream->upstream->buffers.mem_pool, b); in nxt_stream_source_buf_completion()
430 b = nxt_buf_sync_alloc(stream->upstream->buffers.mem_pool, in nxt_stream_source_closed()
H A Dnxt_http_proxy.c95 action->u.upstream = up; in nxt_http_proxy_init()
109 u = action->u.upstream; in nxt_http_proxy()
119 nxt_upstream_t *upstream) in nxt_upstream_proxy_handler() argument
145 us->upstream = upstream; in nxt_upstream_proxy_handler()
146 upstream->proto->get(task, us); in nxt_upstream_proxy_handler()
157 proxy = us->upstream->type.proxy; in nxt_http_proxy_server_get()
H A Dnxt_stream_source.h19 nxt_upstream_source_t *upstream; member
H A Dnxt_stream_module.c37 if (rt->upstream.length != 0) { in nxt_stream_connection_init()
38 up->addr = rt->upstream; in nxt_stream_connection_init()
H A Dnxt_http_source.h25 nxt_upstream_source_t *upstream; member
H A Dnxt_fastcgi_source.h66 nxt_upstream_source_t *upstream; member
H A Dnxt_http.h246 nxt_upstream_t *upstream; member
393 nxt_http_request_t *r, nxt_upstream_t *upstream);
/unit/
H A DCHANGES418 *) Feature: fractional weights support for upstream servers.