/unit/src/ |
H A D | nxt_http_parse.c | 100 nxt_target_test_char(*p); p++; in nxt_http_parse_target() 201 nxt_method_test_char(*p); p++; in nxt_http_parse_request_line() 233 p++; in nxt_http_parse_request_line() 362 if (p[7] < '0' || p[7] > '9') { in nxt_http_parse_request_line() 372 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 D | nxt_time_parse.c | 39 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 D | nxt_malloc.c | 33 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 D | nxt_utf8.c | 38 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 D | nxt_murmur_hash.c | 14 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 D | nxt_conn_proxy.c | 95 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 D | nxt_log.c | 69 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 D | nxt_parse.c | 29 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 D | nxt_websocket.c | 62 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 D | nxt_mp.c | 392 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 D | nxt_conf.c | 149 ((p)[0] = '\r', (p)[1] = '\n', (p) + 2) 527 while (p < parse->end && *p != '/') { in nxt_conf_path_next_token() 1283 p = nxt_conf_json_skip_space(p, end); in nxt_conf_json_parse() 1313 for (p = start; nxt_fast_path(p != end); p++) { in nxt_conf_json_skip_space() 1850 for (p = start; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_string() 2106 for (p = s; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_number() 2156 for (p = s; nxt_fast_path(p != end); p++) { in nxt_conf_json_parse_number() 2385 p = nxt_conf_json_newline(p); in nxt_conf_json_print_array() 2407 p = nxt_conf_json_newline(p); in nxt_conf_json_print_array() 2481 p = nxt_conf_json_newline(p); in nxt_conf_json_print_object() [all …]
|
H A D | nxt_process_title.c | 119 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 D | nxt_app_log.c | 22 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 D | nxt_utf8.h | 19 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 D | nxt_js.c | 179 p = nxt_cpymem(p, mod->name.start, mod->name.length); in nxt_js_vm_create() 182 p = nxt_cpymem(p, from_str.start, from_str.length); in nxt_js_vm_create() 186 p = nxt_cpymem(p, mod->name.start, mod->name.length); in nxt_js_vm_create() 194 p = nxt_cpymem(p, mod->name.start, mod->name.length); in nxt_js_vm_create() 199 p = nxt_cpymem(p, mod->name.start, mod->name.length); in nxt_js_vm_create() 262 p = start; in nxt_js_add_tpl() 264 p = nxt_cpymem(p, func_str.start, func_str.length); in nxt_js_add_tpl() 265 p = nxt_cpymem(p, str->start, str->length); in nxt_js_add_tpl() 268 p = nxt_cpymem(p, strz_str.start, strz_str.length); in nxt_js_add_tpl() 271 *p++ = '}'; in nxt_js_add_tpl() [all …]
|
H A D | nxt_malloc.h | 15 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 D | nxt_var.c | 333 p = str->start; in nxt_var_compile() 337 p = nxt_var_next_part(p, end, &part); in nxt_var_compile() 381 p = next; in nxt_var_compile() 419 p = next; in nxt_var_test() 436 p++; in nxt_var_next_part() 449 p++; in nxt_var_next_part() 456 start = p; in nxt_var_next_part() 492 return p; in nxt_var_next_part() 556 p = nxt_cpymem(p, &src[last], next - last); in nxt_var_interpreter() 559 p = nxt_cpymem(p, part[i]->start, part[i]->length); in nxt_var_interpreter() [all …]
|
H A D | nxt_sprintf.c | 61 u_char *p; in nxt_sprintf() local 68 return p; in nxt_sprintf() 111 const u_char *p; in nxt_vsprintf() local 147 p = v->start; in nxt_vsprintf() 164 *buf++ = *p++; in nxt_vsprintf() 389 p = nan; in nxt_vsprintf() 483 p = fn; in nxt_vsprintf() 577 u_char *p, *end; in nxt_integer() local 679 *buf++ = *p++; in nxt_integer() 689 u_char *p, *end; in nxt_number() local [all …]
|
H A D | nxt_djb_hash.c | 14 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 D | nxt_file_name.c | 23 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 D | nxt_array.c | 45 void *p; in nxt_array_add() local 63 if (nxt_slow_path(p == NULL)) { in nxt_array_add() 67 nxt_memcpy(p, array->elts, array->size * nalloc); in nxt_array_add() 73 array->elts = p; in nxt_array_add() 77 p = nxt_pointer_to(array->elts, array->size * array->nelts); in nxt_array_add() 80 return p; in nxt_array_add() 87 void *p; in nxt_array_zero_add() local 89 p = nxt_array_add(array); in nxt_array_zero_add() 91 if (nxt_fast_path(p != NULL)) { in nxt_array_zero_add() 92 nxt_memzero(p, array->size); in nxt_array_zero_add() [all …]
|
H A D | nxt_parse.h | 11 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 D | nxt_unit_app_test.c | 215 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 D | port.go | 57 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 D | malloc | 17 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 …]
|