Home
last modified time | relevance | path

Searched refs:end (Results 1 – 25 of 162) sorted by last modified time

1234567

/unit/src/
H A Dnxt_var.c117 u_char *p, *end; in nxt_var_decl_get() local
132 while (p < end) { in nxt_var_decl_get()
138 if (p == end) { in nxt_var_decl_get()
344 end = p + str->length; in nxt_var_compile()
346 while (p < end) { in nxt_var_compile()
375 while (p < end) { in nxt_var_compile()
406 end = p + str->length; in nxt_var_test()
408 while (p < end) { in nxt_var_test()
448 if (p == end) { in nxt_var_next_part()
468 while (p < end) { in nxt_var_next_part()
[all …]
H A Dnxt_router.c106 nxt_router_temp_conf_t *tmcf, u_char *start, u_char *end);
961 b->mem.free = b->mem.end; in nxt_router_status_handler()
976 p = b->mem.end; in nxt_router_status_handler()
1539 u_char *start, u_char *end) in nxt_router_conf_create() argument
2770 out->mem.free = nxt_sprintf(out->mem.free, out->mem.end, in nxt_router_listen_socket_error()
5172 nxt_http_field_t *end = nxt_list_data(i->part); in nxt_fields_next() local
5174 end += i->part->nelts; in nxt_fields_next()
5177 if (i->field < end) { in nxt_fields_next()
5190 u_char *pos, *end, *p, c; in nxt_router_prepare_msg() local
5349 end = field->name + field->name_length; in nxt_router_prepare_msg()
[all …]
H A Dnxt_http_static.c761 u_char ch, *p, *end; in nxt_http_static_extract_extension() local
763 end = path->start + path->length; in nxt_http_static_extract_extension()
764 p = end; in nxt_http_static_extract_extension()
781 exten->length = end - p; in nxt_http_static_extract_extension()
H A Dnxt_http_variables.c482 nxt_http_name_value_t *nv, *end; in nxt_http_var_cookie() local
496 end = nv + cookies->nelts; in nxt_http_var_cookie()
498 while (nv < end) { in nxt_http_var_cookie()
H A Dnxt_http_route.c1050 p = end - 1; in nxt_http_route_pattern_create()
1065 end = p; in nxt_http_route_pattern_create()
1082 while (p != end) { in nxt_http_route_pattern_create()
1126 u_char *start, *end; in nxt_http_route_decode_str() local
1247 while (match < end) { in nxt_http_route_resolve()
1472 while (route < end) { in nxt_http_route_find()
1576 while (test < end) { in nxt_http_route_match()
1641 while (rule < end) { in nxt_http_route_ruleset()
1940 while (nv < end) { in nxt_http_route_test_argument()
2018 while (nv < end) { in nxt_http_route_test_cookie()
[all …]
H A Dnxt_http_js.c154 nxt_http_name_value_t *nv, *start, *end; in nxt_http_js_ext_get_arg() local
174 end = start + args->nelts; in nxt_http_js_ext_get_arg()
176 for (nv = start; nv < end; nv++) { in nxt_http_js_ext_get_arg()
238 nxt_http_name_value_t *nv, *start, *end; in nxt_http_js_ext_get_cookie() local
258 end = start + cookies->nelts; in nxt_http_js_ext_get_cookie()
260 for (nv = start; nv < end; nv++) { in nxt_http_js_ext_get_cookie()
H A Dnxt_http_request.c33 const u_char *end);
35 const u_char *end);
625 u_char *p, *end; in nxt_http_request_header_send() local
885 end = start + r->args->length; in nxt_http_arguments_parse()
973 length = end - start; in nxt_http_argument()
1039 for (p = start; p < end; p++) { in nxt_http_cookie_parse()
1099 while (start < end && end[-1] == ' ') { end--; } in nxt_http_cookie()
1101 nv->value_length = end - start; in nxt_http_cookie()
1138 goto end; in nxt_http_field_hash()
1144 end = start + name->length; in nxt_http_field_hash()
[all …]
H A Dnxt_conf.h103 nxt_conf_value_t *nxt_conf_json_parse(nxt_mp_t *mp, u_char *start, u_char *end,
H A Dnxt_conf_validation.c1338 u_char *p, *end; in nxt_conf_vldt_error() local
1344 end = nxt_vsprintf(error, error + NXT_MAX_ERROR_STR, fmt, args); in nxt_conf_vldt_error()
1347 size = end - error; in nxt_conf_vldt_error()
2041 u_char *p, *end; in nxt_conf_vldt_match_encoded_patterns_set_member() local
2053 end = nxt_decode_uri(p, name->start, name->length); in nxt_conf_vldt_match_encoded_patterns_set_member()
2054 if (nxt_slow_path(end == NULL)) { in nxt_conf_vldt_match_encoded_patterns_set_member()
2091 u_char *p, *end; in nxt_conf_vldt_match_encoded_pattern() local
2112 end = nxt_decode_uri(p, pattern.start, pattern.length); in nxt_conf_vldt_match_encoded_pattern()
2113 if (nxt_slow_path(end == NULL)) { in nxt_conf_vldt_match_encoded_pattern()
H A Dnxt_main_process.c25 u_char *end; member
720 u_char *p, *end; in nxt_main_process_title() local
724 end = title + sizeof(title) - 1; in nxt_main_process_title()
733 if (p < end) { in nxt_main_process_title()
1046 ls.end = message + sizeof(message); in nxt_main_port_socket_handler()
1062 size = ls.end - ls.start; in nxt_main_port_socket_handler()
1104 ls->end = nxt_sprintf(ls->start, ls->end, in nxt_main_listening_socket()
1112 ls->end = nxt_sprintf(ls->start, ls->end, in nxt_main_listening_socket()
1124 ls->end = nxt_sprintf(ls->start, ls->end, in nxt_main_listening_socket()
1171 ls->end = nxt_sprintf(ls->start, ls->end, "bind(\\\"%*s\\\") failed %E", in nxt_main_listening_socket()
[all …]
H A Dnxt_string.h85 NXT_EXPORT u_char *nxt_memstrn(const u_char *s, const u_char *end,
87 NXT_EXPORT u_char *nxt_memcasestrn(const u_char *s, const u_char *end,
89 NXT_EXPORT u_char *nxt_rmemstrn(const u_char *s, const u_char *end,
91 NXT_EXPORT size_t nxt_str_strip(const u_char *start, u_char *end);
H A Dnxt_string.c251 while (s < end) { in nxt_memstrn()
287 while (s < end) { in nxt_memcasestrn()
319 s1 = end - length; in nxt_rmemstrn()
522 u_char *end, ch; in nxt_decode_uri() local
527 end = src + length; in nxt_decode_uri()
529 while (src < end) { in nxt_decode_uri()
557 u_char *end, ch; in nxt_decode_uri_plus() local
598 u_char *end; in nxt_encode_uri() local
713 for (end = src + length; src < end; src++) { in nxt_is_complex_uri_encoded()
753 u_char *end, *p; in nxt_base64_decode() local
[all …]
H A Dnxt_sockaddr.c232 u_char *p, *start, *end, *octet; in nxt_sockaddr_text() local
240 end = start + sa->length; in nxt_sockaddr_text()
444 if (buf + max_inet6_length > end) { in nxt_inet6_ntop()
647 u_char *p, *start, *end; in nxt_sockaddr_inet6_parse() local
661 p = end + 1; in nxt_sockaddr_inet6_parse()
776 u_char c, *end; in nxt_inet_addr() local
788 end = buf + length; in nxt_inet_addr()
790 while (buf < end) { in nxt_inet_addr()
833 end = buf + length; in nxt_inet6_addr()
846 while (buf < end) { in nxt_inet6_addr()
[all …]
H A Dnxt_http_route_addr.c71 u_char *end; in nxt_http_route_addr_pattern_parse() local
82 end = addr.start + addr.length; in nxt_http_route_addr_pattern_parse()
91 port.length = end - port.start; in nxt_http_route_addr_pattern_parse()
180 inet6->end.s6_addr[i] = 0; in nxt_http_route_addr_pattern_parse()
220 inet->end = nxt_inet_addr(delim + 1, in nxt_http_route_addr_pattern_parse()
281 base->port.end = 65535; in nxt_http_route_addr_pattern_parse()
300 base->port.end = ret; in nxt_http_route_addr_pattern_parse()
309 base->port.end = ret; in nxt_http_route_addr_pattern_parse()
321 u_char *end; in nxt_valid_ipv6_blocks() local
324 end = c + len; in nxt_valid_ipv6_blocks()
[all …]
H A Dnxt_openssl.c465 goto end;
474 goto end;
478 goto end;
491 goto end;
509 goto end;
514 goto end;
519 goto end;
528 end:
1629 u_char *p, *end; local
1738 u_char *p, *end; local
[all …]
H A Dnxt_http_parse.c11 u_char **pos, const u_char *end);
13 u_char **pos, const u_char *end);
101 while (p != end) { in nxt_http_parse_target()
161 const u_char *end) in nxt_http_parse_request_line() argument
202 while (p != end) { in nxt_http_parse_request_line()
354 if (p == end) { in nxt_http_parse_request_line()
482 const u_char *end) in nxt_http_parse_unusual_target() argument
520 const u_char *end) in nxt_http_parse_field_name() argument
627 const u_char *end) in nxt_http_parse_field_value() argument
752 switch (end - p) { in nxt_http_lookup_field_end()
[all …]
H A Dnxt_controller.c567 u_char *end; in nxt_controller_conf_send() local
602 end = nxt_conf_json_print(mem, conf, NULL); in nxt_controller_conf_send()
606 size = end - (u_char *) mem; in nxt_controller_conf_send()
2075 u_char *end; in nxt_controller_conf_store() local
2098 end = nxt_conf_json_print(mem, conf, NULL); in nxt_controller_conf_store()
2102 size = end - (u_char *) mem; in nxt_controller_conf_store()
2281 b->mem.free = nxt_sprintf(b->mem.free, b->mem.end, "%uz", in nxt_controller_response()
H A Dnxt_h1proto.c981 b->mem.end = NULL; in nxt_h1p_request_body_read()
1059 b->mem.free = b->mem.end - body_rest; in nxt_h1p_conn_request_body_read()
1077 b->mem.end = NULL; in nxt_h1p_conn_request_body_read()
1537 header->mem.free = nxt_sprintf(header->mem.free, header->mem.end, in nxt_h1p_chunk_create()
H A Dnxt_conf.c96 u_char *end; member
337 end = nxt_sprintf(p, end, "%L", value); in nxt_conf_set_member_integer()
338 *end = '\0'; in nxt_conf_set_member_integer()
509 u_char *p, *start, *end; in nxt_conf_path_next_token() local
1255 if (nxt_slow_path(p == end)) { in nxt_conf_json_parse()
1274 if (nxt_slow_path(p != end)) { in nxt_conf_json_parse()
1440 if (p == end) { in nxt_conf_json_parse_value()
1441 return end; in nxt_conf_json_parse_value()
2182 end = NULL; in nxt_conf_json_parse_number()
2197 if (nxt_slow_path(end == NULL || *end != '\0')) { in nxt_conf_json_parse_number()
[all …]
H A Dnxt_application.c209 u_char *p, *end; in nxt_discovery_modules() local
291 end = b->mem.end; in nxt_discovery_modules()
297 p = nxt_sprintf(p, end, "{\"type\": %d, \"version\": \"%V\", " in nxt_discovery_modules()
303 p = nxt_sprintf(p, end, in nxt_discovery_modules()
319 if (nxt_slow_path(p > end)) { in nxt_discovery_modules()
974 u_char *p, *end, *version; in nxt_app_lang_module() local
980 end = name->start + name->length; in nxt_app_lang_module()
981 version = end; in nxt_app_lang_module()
983 for (p = name->start; p < end; p++) { in nxt_app_lang_module()
1001 version_length = end - version; in nxt_app_lang_module()
H A Dnxt_unit.c1927 const char *p, *end; in nxt_unit_field_hash() local
1930 end = name + name_length; in nxt_unit_field_hash()
2697 buf->end = NULL; in nxt_unit_mmap_buf_send()
4347 u_char *p, *end; in nxt_unit_mmap_release() local
4354 end = p + size; in nxt_unit_mmap_release()
4358 while (p < end) { in nxt_unit_mmap_release()
6609 p = end; in nxt_unit_log()
6659 p = end; in nxt_unit_req_log()
6696 p += snprintf(p, end - p, in nxt_unit_snprint_prefix()
6702 p += snprintf(p, end - p, in nxt_unit_snprint_prefix()
[all …]
H A Dnxt_fs_mount.c84 u_char *data, *p, *end; in nxt_fs_mount() local
161 end = data - 1; in nxt_fs_mount()
164 p = end + 1; in nxt_fs_mount()
165 end = nxt_strchr(p, '='); in nxt_fs_mount()
166 if (end == NULL) { in nxt_fs_mount()
170 *end = '\0'; in nxt_fs_mount()
173 iov[iovlen].iov_len = (end - p) + 1; in nxt_fs_mount()
177 p = end + 1; in nxt_fs_mount()
179 end = nxt_strchr(p, ','); in nxt_fs_mount()
180 if (end != NULL) { in nxt_fs_mount()
[all …]
H A Dnxt_fs.c14 char *start, *end, *dst; in nxt_fs_mkdir_all() local
23 start = end = (char *) dir; in nxt_fs_mkdir_all()
30 end = strchr(start, '/'); in nxt_fs_mkdir_all()
31 if (end == NULL) { in nxt_fs_mkdir_all()
32 end = ((char *)dir + dirlen); in nxt_fs_mkdir_all()
35 dst = nxt_cpymem(dst, start, end - start); in nxt_fs_mkdir_all()
44 start = end; in nxt_fs_mkdir_all()
/unit/src/test/
H A Dnxt_http_parse_test.c638 buf.end = request->start + request->length; in nxt_http_parse_test_run()
646 } while (buf.free < buf.end && rc == NXT_AGAIN); in nxt_http_parse_test_run()
657 nxt_nsec_t start, end; in nxt_http_parse_test_bench() local
667 buf.end = request->start + request->length; in nxt_http_parse_test_bench()
685 buf.free = buf.end; in nxt_http_parse_test_bench()
705 end = nxt_thread_monotonic_time(thr); in nxt_http_parse_test_bench()
709 name, (end - start) / 1000000000.0); in nxt_http_parse_test_bench()
/unit/test/unit/applications/
H A Dwebsockets.py202 end = min(pos + chopsize, frame_len)
204 sock.sendall(frame[pos:end])
206 end = frame_len
207 pos = end
222 end = min(pos + fragmention_size, message_len)
223 fin = end == message_len
224 self.frame_write(sock, op_code, message[pos:end], fin=fin, **kwargs)
226 pos = end

1234567