/unit/src/ |
H A D | nxt_thread.c | 22 void *p; in nxt_thread_init_data() local 50 p = nxt_zalloc(tsd->size); in nxt_thread_init_data() 51 if (p == NULL) { in nxt_thread_init_data() 55 err = pthread_setspecific((pthread_key_t) tsd->key, p); in nxt_thread_init_data()
|
H A D | nxt_thread_time.c | 228 u_char *p; in nxt_thread_time_string() local 320 p = tsc->string.start; in nxt_thread_time_string() 322 if (nxt_slow_path(p == NULL)) { in nxt_thread_time_string() 325 p = nxt_zalloc(ts->size); in nxt_thread_time_string() 328 if (p == NULL) { in nxt_thread_time_string() 332 tsc->string.start = p; in nxt_thread_time_string() 335 p = ts->handler(p, &thr->time.now.realtime, tm, ts->size, ts->format); in nxt_thread_time_string() 337 tsc->string.length = p - tsc->string.start; in nxt_thread_time_string()
|
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_tls.h | 100 u_char *nxt_openssl_copy_error(u_char *p, u_char *end);
|
H A D | nxt_tstr.c | 87 u_char *p; in nxt_tstr_compile() local 105 p = nxt_cpymem(tstr->str.start, str->start, str->length); in nxt_tstr_compile() 108 *p = '\0'; in nxt_tstr_compile() 131 p = memchr(str->start, '$', str->length); in nxt_tstr_compile() 133 if (p != NULL) { in nxt_tstr_compile() 153 u_char *p; in nxt_tstr_test() local 167 p = memchr(str->start, '$', str->length); in nxt_tstr_test() 169 if (p != NULL) { in nxt_tstr_test()
|
H A D | nxt_tstr.h | 66 u_char *p; in nxt_is_tstr() local 68 p = memchr(str->start, '`', str->length); in nxt_is_tstr() 69 if (p != NULL) { in nxt_is_tstr() 73 p = memchr(str->start, '$', str->length); in nxt_is_tstr() 74 if (p != NULL) { in nxt_is_tstr()
|
H A D | nxt_unit.c | 1932 for (p = name; p < end; p++) { in nxt_unit_field_hash() 3219 p = dst; in nxt_unit_buf_read() 3231 p = nxt_cpymem(p, buf->free, copy); in nxt_unit_buf_read() 6602 p = nxt_unit_snprint_prefix(p, end, pid, level); in nxt_unit_log() 6605 p += vsnprintf(p, end - p, fmt, ap); in nxt_unit_log() 6646 p = nxt_unit_snprint_prefix(p, end, pid, level); in nxt_unit_req_log() 6651 p += snprintf(p, end - p, "#%"PRIu32": ", req_impl->stream); in nxt_unit_req_log() 6655 p += vsnprintf(p, end - p, fmt, ap); in nxt_unit_req_log() 6697 p += snprintf(p, end - p, in nxt_unit_snprint_prefix() 6703 p += snprintf(p, end - p, in nxt_unit_snprint_prefix() [all …]
|
H A D | nxt_unit.h | 338 void nxt_unit_free(nxt_unit_ctx_t *ctx, void *p);
|
H A D | nxt_unix.h | 282 #define nxt_iobuf_set(iob, p, size) \ argument 284 (iob)->iov_base = (void *) p; \
|
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_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_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_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 …]
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 407 char *buf, *p; in nxt_perl_psgi_module_create() local 437 p = nxt_cpymem(buf, prefix.start, prefix.length); in nxt_perl_psgi_module_create() 438 p = nxt_cpymem(p, script, length); in nxt_perl_psgi_module_create() 439 nxt_memcpy(p, suffix.start, suffix.length); in nxt_perl_psgi_module_create()
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 642 char *p, *target, *query; in nxt_py_asgi_create_http_scope() local 682 p = nxt_unit_sptr_get(&r->path); in nxt_py_asgi_create_http_scope() 691 p = nxt_unit_sptr_get(&r->version); in nxt_py_asgi_create_http_scope() 857 char *p; in nxt_py_asgi_create_ip_address() local 865 p = nxt_unit_sptr_get(sptr); in nxt_py_asgi_create_ip_address() 867 v = PyString_FromStringAndSize(p, len); in nxt_py_asgi_create_ip_address() 1106 PyObject *res, *p; in nxt_py_asgi_quit() local 1113 p = PyLong_FromLong(0); in nxt_py_asgi_quit() 1114 if (nxt_slow_path(p == NULL)) { in nxt_py_asgi_quit() 1120 p, NULL); in nxt_py_asgi_quit() [all …]
|
H A D | nxt_python_asgi_websocket.c | 675 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_suspend_frame() local 697 if (nxt_slow_path(p == NULL)) { in nxt_py_asgi_websocket_suspend_frame() 709 p->frame = frame; in nxt_py_asgi_websocket_suspend_frame() 710 nxt_queue_insert_tail(&ws->pending_frames, &p->link); in nxt_py_asgi_websocket_suspend_frame() 926 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_pending_len() local 931 res += p->frame->payload_len; in nxt_py_asgi_websocket_pending_len() 933 if (p->frame->header->fin) { in nxt_py_asgi_websocket_pending_len() 951 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_pop_frame() local 956 p = nxt_queue_link_data(lnk, nxt_py_asgi_penging_frame_t, link); in nxt_py_asgi_websocket_pop_frame() 958 frame = p->frame; in nxt_py_asgi_websocket_pop_frame() [all …]
|
H A D | nxt_python_wsgi.c | 821 char *p, c; in nxt_python_field_name() local 837 p = nxt_cpymem(p, "HTTP_", 5); in nxt_python_field_name() 852 *p++ = c; in nxt_python_field_name() 877 ptr = p; in nxt_python_field_value() 878 p = nxt_cpymem(p, src, f->value_length); in nxt_python_field_value() 881 p = nxt_cpymem(p, ", ", 2); in nxt_python_field_value() 884 p = nxt_cpymem(p, src, f[i].value_length); in nxt_python_field_value() 886 *p = '\0'; in nxt_python_field_value() 905 p = nxt_cpymem(p, src, f->value_length); in nxt_python_field_value() 908 p = nxt_cpymem(p, ", ", 2); in nxt_python_field_value() [all …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 977 char *field, *p; in nxt_ruby_hash_add() local 992 p = field; in nxt_ruby_hash_add() 997 p = nxt_cpymem(p, RSTRING_PTR(item), RSTRING_LEN(item)); in nxt_ruby_hash_add() 998 p = nxt_cpymem(p, "; ", 2); in nxt_ruby_hash_add()
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 390 u_char *p, *end; in nxt_clone_test_log_handler() local 396 p = msg; in nxt_clone_test_log_handler() 403 p = nxt_vsprintf(p, end, fmt, args); in nxt_clone_test_log_handler() 406 *p++ = '\0'; in nxt_clone_test_log_handler() 417 if (!nxt_str_eq(&tc->errmsg, msg, (nxt_uint_t) (p - msg - 1))) { in nxt_clone_test_log_handler()
|
H A D | nxt_cq_test.c | 134 cas_worker(void *p) in cas_worker() argument 142 wi = p; in cas_worker() 155 faa_worker(void *p) in faa_worker() argument 162 wi = p; in faa_worker() 179 wi = p; in enq_deq_worker() 204 enq_worker(void *p) in enq_worker() argument 211 wi = p; in enq_worker() 225 deq_worker(void *p) in deq_worker() argument 232 wi = p; in deq_worker() 253 wi = p; in wenq_worker() [all …]
|
H A D | nxt_malloc_test.c | 28 static u_char *p[TIMES + 1]; in nxt_malloc_run_test() local 35 p[i] = nxt_malloc(size); in nxt_malloc_run_test() 36 if (p[i] == NULL) { in nxt_malloc_run_test() 40 n = (uintptr_t) p[i]; in nxt_malloc_run_test() 54 nxt_malloc_usable_size(p[i], s); in nxt_malloc_run_test() 56 if (p[i - 1] + s == p[i] || p[i - 1] == p[i] + s) { in nxt_malloc_run_test() 60 nxt_free(p[i]); in nxt_malloc_run_test()
|
H A D | nxt_rbtree1.c | 100 nxt_rbtree1_node_t **p; in nxt_rbtree1_insert_value() local 104 p = (node->key < temp->key) ? &temp->left : &temp->right; in nxt_rbtree1_insert_value() 106 if (*p == sentinel) { in nxt_rbtree1_insert_value() 110 temp = *p; in nxt_rbtree1_insert_value() 113 *p = node; in nxt_rbtree1_insert_value() 125 nxt_rbtree1_node_t **p; in nxt_rbtree1_insert_timer_value() local 138 p = ((nxt_rbtree1_key_int_t) (node->key - temp->key) < 0) in nxt_rbtree1_insert_timer_value() 141 if (*p == sentinel) { in nxt_rbtree1_insert_timer_value() 145 temp = *p; in nxt_rbtree1_insert_timer_value() 148 *p = node; in nxt_rbtree1_insert_timer_value()
|
H A D | nxt_rbtree1_test.c | 161 nxt_rbtree1_node_t **p; in nxt_rbtree1_test_insert_value() local 167 p = (node->key < temp->key) ? &temp->left : &temp->right; in nxt_rbtree1_test_insert_value() 169 if (*p == sentinel) { in nxt_rbtree1_test_insert_value() 173 temp = *p; in nxt_rbtree1_test_insert_value() 176 *p = node; in nxt_rbtree1_test_insert_value()
|
H A D | nxt_sprintf_test.c | 33 u_char *p; in nxt_sprintf_test_double() local 35 p = nxt_sprintf(buf, end, fmt, n); in nxt_sprintf_test_double() 36 *p = '\0'; in nxt_sprintf_test_double()
|
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 …]
|