Home
last modified time | relevance | path

Searched refs:p (Results 126 – 150 of 159) sorted by path

1234567

/unit/src/
H A Dnxt_thread.c22 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 Dnxt_thread_time.c228 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 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_tls.h100 u_char *nxt_openssl_copy_error(u_char *p, u_char *end);
H A Dnxt_tstr.c87 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 Dnxt_tstr.h66 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 Dnxt_unit.c1932 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 Dnxt_unit.h338 void nxt_unit_free(nxt_unit_ctx_t *ctx, void *p);
H A Dnxt_unix.h282 #define nxt_iobuf_set(iob, p, size) \ argument
284 (iob)->iov_base = (void *) p; \
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_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_var.c333 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 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 …]
/unit/src/perl/
H A Dnxt_perl_psgi.c407 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 Dnxt_python_asgi.c642 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 Dnxt_python_asgi_websocket.c675 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 Dnxt_python_wsgi.c821 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 Dnxt_ruby.c977 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 Dnxt_clone_test.c390 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 Dnxt_cq_test.c134 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 Dnxt_malloc_test.c28 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 Dnxt_rbtree1.c100 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 Dnxt_rbtree1_test.c161 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 Dnxt_sprintf_test.c33 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 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 …]

1234567