Home
last modified time | relevance | path

Searched refs:p (Results 1 – 25 of 146) sorted by relevance

123456

/unit/src/
H A Dnxt_http_parse.c102 nxt_target_test_char(*p); p++; in nxt_http_parse_target()
203 nxt_method_test_char(*p); p++; in nxt_http_parse_request_line()
235 p++; in nxt_http_parse_request_line()
364 if (p[7] < '0' || p[7] > '9') { in nxt_http_parse_request_line()
374 if (p[5] < '0' || p[5] > '9') { in nxt_http_parse_request_line()
578 nxt_field_name_test_char(*p); p++; in nxt_http_parse_field_name()
655 p = nxt_http_lookup_field_end(p, end); in nxt_http_parse_field_value()
688 while (p[-1] == ' ' || p[-1] == '\t') { in nxt_http_parse_field_value()
754 nxt_field_end_test_char(*p); p++; in nxt_http_lookup_field_end()
757 nxt_field_end_test_char(*p); p++; in nxt_http_lookup_field_end()
[all …]
H A Dnxt_time_parse.c39 c = *p++; in nxt_time_parse()
56 p++; in nxt_time_parse()
71 p += 2; in nxt_time_parse()
88 p++; in nxt_time_parse()
94 month = p[1] == 'a' ? 0 : p[2] == 'n' ? 5 : 6; in nxt_time_parse()
129 p += 3; in nxt_time_parse()
143 p += 4; in nxt_time_parse()
156 p += 2; in nxt_time_parse()
201 p += 2; in nxt_time_parse()
211 p += 2; in nxt_time_parse()
[all …]
H A Dnxt_malloc.c33 void *p; in nxt_malloc() local
35 p = malloc(size); in nxt_malloc()
45 return p; in nxt_malloc()
52 void *p; in nxt_zalloc() local
60 return p; in nxt_zalloc()
103 nxt_free(p); in nxt_lvlhsh_free()
110 nxt_free(void *p) in nxt_free() argument
114 free(p); in nxt_free()
139 return p; in nxt_memalign()
155 void *p; in nxt_memalign() local
[all …]
H A Dnxt_utf8.c38 return p; in nxt_utf8_encode()
44 return p; in nxt_utf8_encode()
51 return p; in nxt_utf8_encode()
59 return p; in nxt_utf8_encode()
100 const u_char *p; in nxt_utf8_decode2() local
102 p = *start; in nxt_utf8_decode2()
103 u = (uint32_t) *p; in nxt_utf8_decode2()
140 p++; in nxt_utf8_decode2()
145 c = *p++; in nxt_utf8_decode2()
245 end = p + len; in nxt_utf8_length()
[all …]
H A Dnxt_murmur_hash.c14 const u_char *p; in nxt_murmur_hash2() local
17 p = data; in nxt_murmur_hash2()
21 k = p[0]; in nxt_murmur_hash2()
22 k |= p[1] << 8; in nxt_murmur_hash2()
33 p += 4; in nxt_murmur_hash2()
45 h ^= p[0]; in nxt_murmur_hash2()
66 p = data; in nxt_murmur_hash2_uint32()
68 k = p[0]; in nxt_murmur_hash2_uint32()
69 k |= p[1] << 8; in nxt_murmur_hash2_uint32()
70 k |= p[2] << 16; in nxt_murmur_hash2_uint32()
[all …]
H A Dnxt_conn_proxy.c95 return p; in nxt_conn_proxy_create()
151 p = data; in nxt_conn_proxy_client_buffer_alloc()
211 p = data; in nxt_conn_proxy_peer_connect()
249 p = data; in nxt_conn_proxy_connected()
502 sink = (source == p->client) ? p->peer : p->client; in nxt_conn_proxy_read()
713 sink = (source == p->client) ? p->peer : p->client; in nxt_conn_proxy_close()
864 if (!p->connected || p->delayed) { in nxt_conn_proxy_shutdown()
885 b = (source == p->client) ? p->client_buffer : p->peer_buffer; in nxt_conn_proxy_shutdown()
920 source = (sink == p->client) ? p->peer : p->client; in nxt_conn_proxy_write_error()
977 p->retain, p->client->socket.fd, p->peer->socket.fd); in nxt_conn_proxy_completion()
[all …]
H A Dnxt_log.c69 u_char *p, *end; in nxt_log_handler() local
76 p = msg; in nxt_log_handler()
80 p = nxt_cpystrn(p, nxt_log_prefix, end - p); in nxt_log_handler()
81 *p++ = ':'; in nxt_log_handler()
82 *p++ = ' '; in nxt_log_handler()
86 syslogmsg = p; in nxt_log_handler()
89 p = nxt_sprintf(p, end, (log->ident != 0) ? "[%V] *%D " : "[%V] ", in nxt_log_handler()
93 p = nxt_vsprintf(p, end, fmt, args); in nxt_log_handler()
97 p = log->ctx_handler(log->ctx, p, end); in nxt_log_handler()
101 p = end - nxt_length("\n"); in nxt_log_handler()
[all …]
H A Dnxt_stream_module.c61 nxt_conn_proxy_t *p; in nxt_stream_connection_peer() local
71 p = nxt_conn_proxy_create(c); in nxt_stream_connection_peer()
76 p->client->socket.data = p; in nxt_stream_connection_peer()
77 p->peer->socket.data = p; in nxt_stream_connection_peer()
79 p->client_buffer_size = 1024; in nxt_stream_connection_peer()
80 p->peer_buffer_size = 4096; in nxt_stream_connection_peer()
82 p->connect_timeout = 7000; in nxt_stream_connection_peer()
83 p->reconnect_timeout = 500; in nxt_stream_connection_peer()
111 nxt_conn_proxy(task, p); in nxt_stream_connection_peer()
124 nxt_event_conn_proxy_t *p; in nxt_stream_connection_close() local
[all …]
H A Dnxt_parse.c29 c = *p++; in nxt_int_parse()
228 p = s->start; in nxt_str_int_parse()
232 c = *p; in nxt_str_int_parse()
248 p++; in nxt_str_int_parse()
254 s->start = p; in nxt_str_int_parse()
276 p = *start; in nxt_number_parse()
280 c = *p; in nxt_number_parse()
302 p++; in nxt_number_parse()
323 for (p++; p < end; p++) { in nxt_number_parse()
324 c = *p; in nxt_number_parse()
[all …]
H A Dnxt_websocket.c62 p = h->payload_len; in nxt_websocket_frame_header_size()
66 if (p == 126) { in nxt_websocket_frame_header_size()
68 } else if (p == 127) { in nxt_websocket_frame_header_size()
87 p = h->payload_len; in nxt_websocket_frame_payload_len()
89 if (p == 126) { in nxt_websocket_frame_payload_len()
91 } else if (p == 127) { in nxt_websocket_frame_payload_len()
95 return p; in nxt_websocket_frame_payload_len()
106 p = data; in nxt_websocket_frame_init()
110 return p + 2; in nxt_websocket_frame_init()
116 return p + 4; in nxt_websocket_frame_init()
[all …]
H A Dnxt_conf.c148 ((p)[0] = '\r', (p)[1] = '\n', (p) + 2)
502 while (p < parse->end && *p != '/') { in nxt_conf_path_next_token()
1258 p = nxt_conf_json_skip_space(p, end); in nxt_conf_json_parse()
1288 for (p = start; nxt_fast_path(p != end); p++) { in nxt_conf_json_skip_space()
1825 for (p = start; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_string()
2081 for (p = s; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_number()
2131 for (p = s; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_number()
2360 p = nxt_conf_json_newline(p); in nxt_conf_json_print_array()
2382 p = nxt_conf_json_newline(p); in nxt_conf_json_print_array()
2456 p = nxt_conf_json_newline(p); in nxt_conf_json_print_object()
[all …]
H A Dnxt_mp.c392 void *p; in nxt_mp_alloc() local
411 return p; in nxt_mp_alloc()
418 void *p; in nxt_mp_zalloc() local
426 return p; in nxt_mp_zalloc()
464 return p; in nxt_mp_align()
471 void *p; in nxt_mp_zalign() local
479 return p; in nxt_mp_zalign()
530 p = NULL; in nxt_mp_alloc_small()
590 return p; in nxt_mp_alloc_small()
640 return p; in nxt_mp_get_small()
[all …]
H A Dnxt_process_title.c119 p = nxt_malloc(strings_size); in nxt_process_arguments()
120 if (p == NULL) { in nxt_process_arguments()
146 argv[i] = p; in nxt_process_arguments()
147 p += size; in nxt_process_arguments()
176 env[i] = p; in nxt_process_arguments()
177 p += size; in nxt_process_arguments()
192 u_char *p, *start, *end; in nxt_process_title() local
225 p = nxt_sprintf(p, end, " ("); in nxt_process_title()
228 p = nxt_sprintf(p, end, "%s ", nxt_process_argv[i]); in nxt_process_title()
232 *(p - 1) = ')'; in nxt_process_title()
[all …]
H A Dnxt_app_log.c22 u_char *p, *end; in nxt_log_time_handler() local
41 syslogmsg = p; in nxt_log_time_handler()
60 p = nxt_sprintf(p, end, id, &nxt_log_levels[level], nxt_pid, in nxt_log_time_handler()
63 p = nxt_sprintf(p, end, "[%V] %PI#%PT ", &nxt_log_levels[level], nxt_pid, in nxt_log_time_handler()
68 p = nxt_sprintf(p, end, "*%D ", log->ident); in nxt_log_time_handler()
72 p = nxt_vsprintf(p, end, fmt, args); in nxt_log_time_handler()
76 p = log->ctx_handler(log->ctx, p, end); in nxt_log_time_handler()
79 if (p > end - nxt_length("\n")) { in nxt_log_time_handler()
80 p = end - nxt_length("\n"); in nxt_log_time_handler()
83 *p++ = '\n'; in nxt_log_time_handler()
[all …]
H A Dnxt_utf8.h19 NXT_EXPORT u_char *nxt_utf8_encode(u_char *p, uint32_t u);
25 NXT_EXPORT ssize_t nxt_utf8_length(const u_char *p, size_t len);
26 NXT_EXPORT nxt_bool_t nxt_utf8_is_valid(const u_char *p, size_t len);
32 nxt_utf8_next(const u_char *p, const u_char *end) in nxt_utf8_next() argument
36 c = *p++; in nxt_utf8_next()
45 c = *p; in nxt_utf8_next()
48 return p; in nxt_utf8_next()
51 p++; in nxt_utf8_next()
53 } while (p < end); in nxt_utf8_next()
56 return p; in nxt_utf8_next()
H A Dnxt_malloc.h15 NXT_EXPORT void *nxt_realloc(void *p, size_t size)
23 NXT_EXPORT void nxt_free(void *p);
27 #define nxt_free(p) \ argument
28 free(p)
56 #define nxt_malloc_usable_size(p, size) \ argument
57 size = malloc_usable_size(p)
81 #define nxt_malloc_usable_size(p, size) \ argument
82 size = malloc_usable_size(p)
101 #define nxt_malloc_usable_size(p, size) \ argument
108 #define nxt_malloc_usable_size(p, size) argument
H A Dnxt_sockaddr.c302 p = nxt_sprintf(start, end, "unix:%s", p); in nxt_sockaddr_text()
307 p = nxt_sprintf(start, end, "unix:%s", p); in nxt_sockaddr_text()
323 p = nxt_sprintf(p, end, ":%d", ntohs(port)); in nxt_sockaddr_text()
448 p[0], p[1], p[2], p[3], in nxt_sockaddr_ntop()
452 p[0], p[1], p[2], p[3]); in nxt_sockaddr_ntop()
469 p = nxt_sprintf(p, end, "]:%d", in nxt_sockaddr_ntop()
493 p = nxt_sprintf(buf, end, "unix:%s", p); in nxt_sockaddr_ntop()
559 p = buf; in nxt_inet6_ntop()
593 p = nxt_sprintf(p, end, "%ud.%ud.%ud.%ud", in nxt_inet6_ntop()
827 p++; in nxt_sockaddr_inet_parse()
[all …]
H A Dnxt_var.c250 p = nxt_var_next_part(p, end - p, &part, &is_var); in nxt_var_compile()
284 next = nxt_var_next_part(p, end - p, &part, &is_var); in nxt_var_compile()
299 p = next; in nxt_var_compile()
318 next = nxt_var_next_part(p, end - p, &part, &is_var); in nxt_var_test()
338 p = next; in nxt_var_test()
359 p++; in nxt_var_next_part()
372 p++; in nxt_var_next_part()
393 p++; in nxt_var_next_part()
612 p = nxt_cpymem(p, &src[last], next - last); in nxt_var_query_finish()
615 p = nxt_cpymem(p, part[j]->start, part[j]->length); in nxt_var_query_finish()
[all …]
H A Dnxt_djb_hash.c14 const u_char *p; in nxt_djb_hash() local
16 p = data; in nxt_djb_hash()
20 hash = nxt_djb_hash_add(hash, *p++); in nxt_djb_hash()
33 const u_char *p; in nxt_djb_hash_lowcase() local
35 p = data; in nxt_djb_hash_lowcase()
39 c = *p++; in nxt_djb_hash_lowcase()
H A Dnxt_file_name.c23 u_char ch, *p; in nxt_file_name_create() local
63 p = va_arg(args, u_char *); in nxt_file_name_create()
65 if (nxt_fast_path(p != NULL)) { in nxt_file_name_create()
66 while (*p != '\0') { in nxt_file_name_create()
67 p++; in nxt_file_name_create()
152 p = va_arg(args, u_char *); in nxt_file_name_create()
154 if (nxt_fast_path(p != NULL)) { in nxt_file_name_create()
155 while (*p != '\0') { in nxt_file_name_create()
156 *dst++ = (nxt_file_name_t) (*p++); in nxt_file_name_create()
168 p = va_arg(args, u_char *); in nxt_file_name_create()
[all …]
H A Dnxt_sprintf.c61 u_char *p; in nxt_sprintf() local
68 return p; in nxt_sprintf()
100 u_char *p; in nxt_vsprintf() local
146 p = v->start; in nxt_vsprintf()
475 p = fn; in nxt_vsprintf()
568 u_char *p, *end; in nxt_integer() local
612 start = p - 9; in nxt_integer()
627 *(--p) = '0'; in nxt_integer()
670 *buf++ = *p++; in nxt_integer()
680 u_char *p, *end; in nxt_number() local
[all …]
H A Dnxt_parse.h11 NXT_EXPORT nxt_int_t nxt_int_parse(const u_char *p, size_t len);
12 NXT_EXPORT ssize_t nxt_size_t_parse(const u_char *p, size_t len);
13 NXT_EXPORT ssize_t nxt_size_parse(const u_char *p, size_t len);
14 NXT_EXPORT nxt_off_t nxt_off_t_parse(const u_char *p, size_t len);
20 NXT_EXPORT nxt_time_t nxt_time_parse(const u_char *p, size_t len);
21 NXT_EXPORT nxt_int_t nxt_term_parse(const u_char *p, size_t len,
/unit/src/test/
H A Dnxt_unit_app_test.c215 p = copy(p, METHOD, nxt_length(METHOD)); in greeting_app_request_handler()
219 p = copy(p, PROTOCOL, nxt_length(PROTOCOL)); in greeting_app_request_handler()
223 p = copy(p, REMOTE_ADDR, nxt_length(REMOTE_ADDR)); in greeting_app_request_handler()
227 p = copy(p, LOCAL_ADDR, nxt_length(LOCAL_ADDR)); in greeting_app_request_handler()
231 p = copy(p, TARGET, nxt_length(TARGET)); in greeting_app_request_handler()
235 p = copy(p, PATH, nxt_length(PATH)); in greeting_app_request_handler()
240 p = copy(p, QUERY, nxt_length(QUERY)); in greeting_app_request_handler()
245 p = copy(p, FIELDS, nxt_length(FIELDS)); in greeting_app_request_handler()
250 p = copy(p, FIELD_PAD, nxt_length(FIELD_PAD)); in greeting_app_request_handler()
252 p = copy(p, FIELD_SEP, nxt_length(FIELD_SEP)); in greeting_app_request_handler()
[all …]
/unit/go/
H A Dport.go57 port_registry_.m[p.key] = p
64 if p.rcv != nil {
65 p.rcv.Close()
68 if p.snd != nil {
69 p.snd.Close()
102 id: int(p.id.id),
110 p.in_fd = -1
111 p.out_fd = -1
131 id: int(p.id.id),
153 if p == nil {
[all …]
/unit/auto/
H A Dmalloc17 void *p;
22 free(p);
40 void *p;
43 if (p == NULL)
46 free(p);
63 void *p;
65 p = malloc(4096);
86 void *p;
129 void *p;
132 if (p == 0)
[all …]

123456