/unit/src/ |
H A D | nxt_var.c | 151 hash = decl->field_hash(fields->mem_pool, &str); in nxt_var_decl_get() 156 f = nxt_var_field_add(fields, &str, (uint32_t) hash); in nxt_var_decl_get() 185 field = fields->elts; in nxt_var_field_add() 187 for (i = 0; i < fields->nelts; i++) { in nxt_var_field_add() 195 field = nxt_array_add(fields); in nxt_var_field_add() 202 field->index = fields->nelts - 1; in nxt_var_field_add() 209 nxt_var_field_get(nxt_array_t *fields, uint16_t index) in nxt_var_field_get() argument 214 field = fields->elts; in nxt_var_field_get() 215 nfields = fields->nelts; in nxt_var_field_get() 379 decl = nxt_var_decl_get(&part, fields, &index); in nxt_var_compile() [all …]
|
H A D | nxt_var.h | 45 nxt_var_field_t *nxt_var_field_get(nxt_array_t *fields, uint16_t index); 47 nxt_var_t *nxt_var_compile(nxt_str_t *str, nxt_mp_t *mp, nxt_array_t *fields); 48 nxt_int_t nxt_var_test(nxt_str_t *str, nxt_array_t *fields, u_char *error);
|
H A D | nxt_http_error.c | 43 r->resp.fields = nxt_list_create(r->mem_pool, 8, sizeof(nxt_http_field_t)); in nxt_http_request_error() 44 if (nxt_slow_path(r->resp.fields == NULL)) { in nxt_http_request_error() 48 content_type = nxt_list_zero_add(r->resp.fields); in nxt_http_request_error()
|
H A D | nxt_unit_response.h | 23 nxt_unit_field_t fields[]; member
|
H A D | nxt_http_request.c | 16 nxt_http_forward_t *forward, nxt_array_t *fields); 261 if (nxt_slow_path(r->resp.fields == NULL)) { in nxt_http_request_create() 371 nxt_list_each(f, r->fields) { in nxt_http_request_forward() 379 fields = nxt_array_add(client_ip_fields); in nxt_http_request_forward() 380 if (nxt_slow_path(fields == NULL)) { in nxt_http_request_forward() 384 *fields = f; in nxt_http_request_forward() 421 f = (nxt_http_field_t **) fields->elts; in nxt_http_request_forward_client_ip() 423 i = fields->nelts; in nxt_http_request_forward_client_ip() 643 server = nxt_list_zero_add(r->resp.fields); in nxt_http_request_header_send() 656 date = nxt_list_zero_add(r->resp.fields); in nxt_http_request_header_send() [all …]
|
H A D | nxt_http_parse.h | 51 nxt_list_t *fields; member 127 nxt_int_t nxt_http_fields_process(nxt_list_t *fields, nxt_lvlhsh_t *hash,
|
H A D | nxt_unit_request.h | 50 nxt_unit_field_t fields[]; member
|
H A D | nxt_http.h | 108 nxt_list_t *fields; member 122 nxt_list_t *fields; member 157 nxt_list_t *fields; member
|
H A D | nxt_http_parse.c | 112 rp->fields = nxt_list_create(mp, 8, sizeof(nxt_http_field_t)); in nxt_http_parse_request_init() 113 if (nxt_slow_path(rp->fields == NULL)) { in nxt_http_parse_request_init() 798 field = nxt_list_add(rp->fields); in nxt_http_parse_field_end() 1260 nxt_http_fields_process(nxt_list_t *fields, nxt_lvlhsh_t *hash, void *ctx) in nxt_http_fields_process() argument 1265 nxt_list_each(field, fields) { in nxt_http_fields_process()
|
H A D | nxt_http_js.c | 202 nxt_list_each(f, r->fields) { in nxt_http_js_ext_get_header() 236 nxt_list_each(f, r->fields) { in nxt_http_js_ext_keys_header()
|
H A D | nxt_php_sapi.c | 1190 f = r->fields + r->content_type_field; 1196 f = r->fields + r->cookie_field; 1202 f = r->fields + r->authorization_field; 1507 f_end = r->fields + r->fields_count; 1508 for (f = r->fields; f < f_end; f++) { 1516 f = r->fields + r->content_length_field; 1523 f = r->fields + r->content_type_field;
|
H A D | nxt_http_proxy.c | 260 nxt_list_each(field, peer->fields) { in nxt_http_proxy_header_read() 267 f = nxt_list_add(r->resp.fields); in nxt_http_proxy_header_read()
|
H A D | nxt_h1proto.c | 666 r->fields = h1p->parser.fields; in nxt_h1p_header_process() 668 ret = nxt_http_fields_process(r->fields, &nxt_h1p_fields_hash, r); in nxt_h1p_header_process() 1317 nxt_list_each(field, r->resp.fields) { in nxt_h1p_request_header_send() 1338 nxt_list_each(field, r->resp.fields) { in nxt_h1p_request_header_send() 1609 if (r->fields == NULL) { in nxt_h1p_conn_request_error() 1645 if (r->fields == NULL) { in nxt_h1p_conn_request_timeout() 2280 nxt_list_each(field, r->fields) { in nxt_h1p_peer_header_send() 2303 nxt_list_each(field, r->fields) { in nxt_h1p_peer_header_send() 2533 peer->fields = peer->proto.h1->parser.fields; in nxt_h1p_peer_header_read_done() 2535 ret = nxt_http_fields_process(peer->fields, in nxt_h1p_peer_header_read_done()
|
H A D | nxt_unit.c | 1948 nxt_unit_field_t *fields, f; in nxt_unit_request_group_dup_fields() local 1958 fields = r->fields; in nxt_unit_request_group_dup_fields() 1963 switch (fields[i].hash) { in nxt_unit_request_group_dup_fields() 1996 if (fields[i].hash != fields[j].hash in nxt_unit_request_group_dup_fields() 1997 || fields[i].name_length != fields[j].name_length in nxt_unit_request_group_dup_fields() 2005 f = fields[j]; in nxt_unit_request_group_dup_fields() 2009 fields[j] = fields[j - 1]; in nxt_unit_request_group_dup_fields() 2015 fields[j] = f; in nxt_unit_request_group_dup_fields() 2152 f = resp->fields; in nxt_unit_response_realloc() 2155 src = req->response->fields + i; in nxt_unit_response_realloc() [all …]
|
H A D | nxt_http_static.c | 519 field = nxt_list_zero_add(r->resp.fields); in nxt_http_static_send_ready() 536 field = nxt_list_zero_add(r->resp.fields); in nxt_http_static_send_ready() 565 field = nxt_list_zero_add(r->resp.fields); in nxt_http_static_send_ready() 613 field = nxt_list_zero_add(r->resp.fields); in nxt_http_static_send_ready()
|
/unit/test/unit/ |
H A D | http.py | 295 def form_encode(self, fields): argument 298 for _, value in fields.items(): 304 body, content_type = self.multipart_encode(fields) 307 body, content_type = self.form_url_encode(fields) 311 def form_url_encode(self, fields): argument 313 f'{name}={value}' for name, value in fields.items() 317 def multipart_encode(self, fields): argument 322 for field, value in fields.items():
|
/unit/go/ |
H A D | response.go | 67 fields := 0 72 fields++ 77 C.nxt_unit_response_init(r.c_req, C.uint16_t(code), C.uint32_t(fields),
|
H A D | request.go | 80 fields := get_fields(req) 82 for i := 0; i < len(fields); i++ { 83 f := &fields[i]
|
H A D | nxt_cgo_lib.h | 18 NXT_FIELDS_OFFSET = offsetof(nxt_unit_request_t, fields)
|
/unit/src/java/ |
H A D | nxt_jni_Request.c | 287 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeader() 307 return nxt_java_newHeaderNamesEnumeration(env, r->fields, r->fields_count); in nxt_java_Request_getHeaderNames() 326 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeaders() 332 f = r->fields + r->fields_count; in nxt_java_Request_getHeaders() 335 return nxt_java_newHeadersEnumeration(env, r->fields, r->fields_count, in nxt_java_Request_getHeaders() 336 f - r->fields); in nxt_java_Request_getHeaders() 359 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getIntHeader() 448 f = r->fields + r->content_type_field; in nxt_java_Request_getContentType() 606 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerName() 634 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerPort()
|
H A D | nxt_jni_Response.c | 396 f = resp->fields + resp->fields_count; in nxt_java_add_int_header() 449 res = nxt_java_findHeader(resp->fields, in nxt_java_Response_containsHeader() 450 resp->fields + resp->fields_count, in nxt_java_Response_containsHeader() 488 f = nxt_java_findHeader(req->response->fields, in nxt_java_Response_getHeader() 520 return nxt_java_newHeaderNamesEnumeration(env, req->response->fields, in nxt_java_Response_getHeaderNames() 557 f = nxt_java_findHeader(resp->fields, resp->fields + resp->fields_count, in nxt_java_Response_getHeaders() 563 f = resp->fields + resp->fields_count; in nxt_java_Response_getHeaders() 567 f - resp->fields); in nxt_java_Response_getHeaders() 681 f = resp->fields; in nxt_java_response_set_header() 803 f = resp->fields; in nxt_java_response_remove_header() [all …]
|
/unit/src/test/ |
H A D | nxt_http_parse_test.c | 34 nxt_http_parse_test_fields_t fields; member 337 { .fields = { NXT_OK, 1 } } 346 { .fields = { NXT_ERROR, 1 } } 353 { .fields = { NXT_ERROR, 0 } } 562 rp.discard_unsafe_fields = test->data.fields.discard_unsafe_fields; in nxt_http_parse_test() 693 if (nxt_slow_path(nxt_http_fields_process(rp.fields, hash, NULL) in nxt_http_parse_test_bench() 801 rc = nxt_http_fields_process(rp->fields, &nxt_http_test_fields_hash, NULL); in nxt_http_parse_test_fields() 803 if (rc != data->fields.result) { in nxt_http_parse_test_fields() 807 request, rc, data->fields.result); in nxt_http_parse_test_fields()
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 766 f = r->fields + i; in nxt_ruby_read_request() 774 f = r->fields + r->content_length_field; in nxt_ruby_read_request() 781 f = r->fields + r->content_type_field; in nxt_ruby_read_request() 828 uint32_t fields; member 854 headers_info.fields = 0; in nxt_ruby_rack_result_headers() 865 headers_info.fields, headers_info.size); in nxt_ruby_rack_result_headers() 911 headers_info->fields++; in nxt_ruby_hash_info() 919 headers_info->fields++; in nxt_ruby_hash_info()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 682 f = r->fields + i; in nxt_perl_psgi_env_create() 690 f = r->fields + r->content_length_field; in nxt_perl_psgi_env_create() 697 f = r->fields + r->content_type_field; in nxt_perl_psgi_env_create() 788 uint32_t fields, size; in nxt_perl_psgi_result_head() local 814 fields = 0; in nxt_perl_psgi_result_head() 831 fields++; in nxt_perl_psgi_result_head() 835 rc = nxt_unit_response_init(req, status, fields, size); in nxt_perl_psgi_result_head()
|
/unit/src/python/ |
H A D | nxt_python_wsgi.c | 660 f = r->fields + i; in nxt_python_get_environ() 664 f2 = r->fields + j; in nxt_python_get_environ() 681 f = r->fields + r->content_length_field; in nxt_python_get_environ() 688 f = r->fields + r->content_type_field; in nxt_python_get_environ() 1081 if (pctx->req->response->fields[i].hash == NXT_UNIT_HASH_CONTENT_LENGTH) { in nxt_python_response_add_field()
|