/unit/src/ |
H A D | nxt_string.c | 20 s->start = nxt_pointer_to(s, sizeof(nxt_str_t)); in nxt_str_alloc() 47 dst->start = p; in nxt_str_dup() 50 dst->start = nxt_mp_nget(mp, src->length); in nxt_str_dup() 51 if (nxt_slow_path(dst->start == NULL)) { in nxt_str_dup() 56 nxt_memcpy(dst->start, src->start, src->length); in nxt_str_dup() 78 p = nxt_cpymem(dst, src->start, src->length); in nxt_str_cstrz() 341 nxt_str_strip(const u_char *start, u_char *end) in nxt_str_strip() argument 345 for (p = end - 1; p >= start; p--) { in nxt_str_strip() 351 return (p + 1) - start; in nxt_str_strip()
|
H A D | nxt_string.h | 91 NXT_EXPORT size_t nxt_str_strip(const u_char *start, u_char *end); 96 u_char *start; member 108 (str)->start = (u_char *) text; \ 115 (str)->start = NULL; \ 127 && (memcmp((s1)->start, (s2)->start, (s1)->length) == 0)) 132 && (nxt_memcasecmp((s1)->start, (s2)->start, (s1)->length) == 0)) 136 (((s)->length == _length) && (memcmp((s)->start, p, _length) == 0)) 140 (((s)->length >= _length) && (memcmp((s)->start, p, _length) == 0)) 144 (((s)->length == 1) && ((s)->start[0] == c)) 148 (((s)->length != 0) && ((s)->start[0] == c))
|
H A D | nxt_thread.c | 106 nxt_thread_start_t start; in nxt_thread_trampoline() local 116 start = link->start; in nxt_thread_trampoline() 126 start(data); in nxt_thread_trampoline()
|
H A D | nxt_thread.h | 83 nxt_thread_start_t start; member
|
H A D | nxt_thread_pool.c | 89 link->start = nxt_thread_pool_start; in nxt_thread_pool_init() 219 link->start = nxt_thread_pool_loop; in nxt_thread_pool_wait()
|
H A D | nxt_thread_time.c | 73 nxt_free(tsc[i].string.start); in nxt_thread_time_free() 91 link->start = nxt_time_thread; in nxt_time_thread_start() 320 p = tsc->string.start; in nxt_thread_time_string() 332 tsc->string.start = p; in nxt_thread_time_string() 337 tsc->string.length = p - tsc->string.start; in nxt_thread_time_string() 346 return nxt_cpymem(buf, tsc->string.start, tsc->string.length); in nxt_thread_time_string() 408 nxt_prefetch(tsc->string.start); in nxt_thread_time_string_cache() 425 tsc[i].string.start = NULL; in nxt_thread_time_string_cache()
|
H A D | nxt_tstr.c | 100 tstr->str.start = nxt_mp_nget(state->pool, tstr->str.length); in nxt_tstr_compile() 101 if (nxt_slow_path(tstr->str.start == NULL)) { in nxt_tstr_compile() 105 p = nxt_cpymem(tstr->str.start, str->start, str->length); in nxt_tstr_compile() 131 p = memchr(str->start, '$', str->length); in nxt_tstr_compile() 167 p = memchr(str->start, '$', str->length); in nxt_tstr_test()
|
H A D | nxt_tstr.h | 68 p = memchr(str->start, '`', str->length); in nxt_is_tstr() 73 p = memchr(str->start, '$', str->length); in nxt_is_tstr()
|
H A D | nxt_unit.c | 1678 b->buf.start = recv_msg->start; in nxt_unit_process_websocket() 2696 buf->start = NULL; in nxt_unit_mmap_buf_send() 2901 part_start = start; in nxt_unit_response_write_nb() 3361 buf->start[0] = 0; in nxt_unit_websocket_sendv() 3362 buf->start[1] = 0; in nxt_unit_websocket_sendv() 4235 mmap_msg = recv_msg->start; in nxt_unit_mmap_read() 4284 recv_msg->start = start; in nxt_unit_mmap_read() 4288 b->buf.start = start; in nxt_unit_mmap_read() 4289 b->buf.free = start; in nxt_unit_mmap_read() 4352 memset(start, 0xA5, size); in nxt_unit_mmap_release() [all …]
|
H A D | nxt_unit.h | 89 char *start; member 304 int nxt_unit_response_write(nxt_unit_request_info_t *req, const void *start, 308 const void *start, size_t size, size_t min_size); 323 uint8_t last, const void *start, size_t size);
|
H A D | nxt_utf8.c | 73 nxt_utf8_decode(const u_char **start, const u_char *end) in nxt_utf8_decode() argument 77 u = (uint32_t) **start; in nxt_utf8_decode() 80 (*start)++; in nxt_utf8_decode() 84 return nxt_utf8_decode2(start, end); in nxt_utf8_decode() 95 nxt_utf8_decode2(const u_char **start, const u_char *end) in nxt_utf8_decode2() argument 102 p = *start; in nxt_utf8_decode2() 162 *start = p; in nxt_utf8_decode2() 210 nxt_utf8_lowcase(const u_char **start, const u_char *end) in nxt_utf8_lowcase() argument 215 u = (uint32_t) **start; in nxt_utf8_lowcase() 218 (*start)++; in nxt_utf8_lowcase() [all …]
|
H A D | nxt_utf8.h | 20 NXT_EXPORT uint32_t nxt_utf8_decode(const u_char **start, const u_char *end); 21 NXT_EXPORT uint32_t nxt_utf8_decode2(const u_char **start, const u_char *end); 24 NXT_EXPORT uint32_t nxt_utf8_lowcase(const u_char **start, const u_char *end);
|
H A D | nxt_var.c | 333 p = str->start; in nxt_var_compile() 342 if (part.start != NULL) { in nxt_var_compile() 363 p = str->start; in nxt_var_compile() 368 if (part.start != NULL) { in nxt_var_compile() 395 p = str->start; in nxt_var_test() 408 if (part.start != NULL) { in nxt_var_test() 433 p = memchr(start, '$', end - start); in nxt_var_next_part() 435 if (p == start) { in nxt_var_next_part() 456 start = p; in nxt_var_next_part() 482 part->start = start; in nxt_var_next_part() [all …]
|
H A D | nxt_vector.c | 36 if (nxt_fast_path(vector->start != NULL)) { in nxt_vector_init() 43 return vector->start; in nxt_vector_init() 54 proto->free(pool, vector->start); in nxt_vector_destroy() 56 vector->start = NULL; in nxt_vector_destroy() 63 proto->free(pool, vector->start); in nxt_vector_destroy() 77 void *item, *start, *old; in nxt_vector_add() local 96 start = proto->alloc(pool, size); in nxt_vector_add() 97 if (nxt_slow_path(start == NULL)) { in nxt_vector_add() 102 old = vector->start; in nxt_vector_add() 103 vector->start = start; in nxt_vector_add() [all …]
|
H A D | nxt_vector.h | 19 void *start; member 45 nxt_pointer_to((vector)->start, \ 61 return nxt_pointer_to(vector->start, vector->item_size * vector->items); in nxt_vector_remove_last()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 437 p = nxt_cpymem(buf, prefix.start, prefix.length); in nxt_perl_psgi_module_create() 439 nxt_memcpy(p, suffix.start, suffix.length); in nxt_perl_psgi_module_create() 623 (char *) nxt_server.start, nxt_server.length)); in nxt_perl_psgi_env_create() 767 status.start = (u_char *) SvPV(*sv_status, status.length); in nxt_perl_psgi_result_status() 769 space = memchr(status.start, ' ', status.length); in nxt_perl_psgi_result_status() 771 status.length = space - status.start; in nxt_perl_psgi_result_status() 774 return nxt_int_parse(status.start, status.length); in nxt_perl_psgi_result_status() 889 body.start = (u_char *) SvPV(*entry, body.length); in nxt_perl_psgi_result_body() 895 rc = nxt_unit_response_write(req, body.start, body.length); in nxt_perl_psgi_result_body()
|
/unit/src/python/ |
H A D | nxt_python.c | 329 if (probe_proto.start != proto.start) { in nxt_python_start() 422 nxt_memcpy(module_name, str.start, str.length); in nxt_python_set_target() 441 nxt_memcpy(callable, str.start, str.length); in nxt_python_set_target() 497 if (str.start[str.length - 1] == '/') { in nxt_python_set_prefix() 507 target->py_prefix = PyString_FromStringAndSize((char *)str.start, in nxt_python_set_prefix() 515 nxt_memcpy(prefix, str.start, str.length); in nxt_python_set_prefix() 516 target->prefix.start = prefix; in nxt_python_set_prefix() 762 while (pstr->string.start != NULL) { in nxt_python_init_strings() 763 obj = PyString_FromStringAndSize((char *) pstr->string.start, in nxt_python_init_strings() 785 while (pstr->string.start != NULL) { in nxt_python_done_strings() [all …]
|
H A D | nxt_python_asgi.c | 686 && memcmp(prefix.start, p, prefix.length) == 0) in nxt_py_asgi_create_http_scope() 823 addr.start = nxt_unit_sptr_get(sptr); in nxt_py_asgi_create_address() 833 addr.start += prefix_len; in nxt_py_asgi_create_address() 836 v = PyString_FromStringAndSize((const char *) addr.start, addr.length); in nxt_py_asgi_create_address() 937 uint32_t i, n, start; in nxt_py_asgi_create_subprotocols() local 955 start = 0; in nxt_py_asgi_create_subprotocols() 964 if (i - start > 0) { in nxt_py_asgi_create_subprotocols() 965 proto = PyString_FromStringAndSize(v + start, i - start); in nxt_py_asgi_create_subprotocols() 979 start = i; in nxt_py_asgi_create_subprotocols() 982 if (i - start > 0) { in nxt_py_asgi_create_subprotocols() [all …]
|
H A D | nxt_python_asgi_lifespan.c | 479 && memcmp(type_str, startup_complete.start, type_len) == 0) in nxt_py_asgi_lifespan_send() 485 && memcmp(type_str, startup_failed.start, type_len) == 0) in nxt_py_asgi_lifespan_send() 492 && memcmp(type_str, shutdown_complete.start, type_len) == 0) in nxt_py_asgi_lifespan_send() 498 && memcmp(type_str, shutdown_failed.start, type_len) == 0) in nxt_py_asgi_lifespan_send()
|
H A D | nxt_python_asgi_websocket.c | 230 && memcmp(type_str, websocket_accept.start, type_len) == 0) in nxt_py_asgi_websocket_send() 236 && memcmp(type_str, websocket_close.start, type_len) == 0) in nxt_py_asgi_websocket_send() 242 && memcmp(type_str, websocket_send.start, type_len) == 0) in nxt_py_asgi_websocket_send() 336 (const char *) ws_protocol.start, in nxt_py_asgi_websocket_accept()
|
H A D | nxt_python_wsgi.c | 477 obj = PyString_FromStringAndSize((char *) nxt_server.start, in nxt_python_create_environ() 626 && memcmp(prefix.start, path, prefix.length) == 0) in nxt_python_get_environ()
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 161 while (pstr->string.start != NULL) { in nxt_ruby_init_strings() 162 v = rb_str_new_static((char *) pstr->string.start, pstr->string.length); in nxt_ruby_init_strings() 167 (char *) pstr->string.start); in nxt_ruby_init_strings() 190 while (pstr->string.start != NULL) { in nxt_ruby_done_strings() 311 if (c->hooks.start != NULL) { in nxt_ruby_start() 312 path = rb_str_new((const char *) c->hooks.start, in nxt_ruby_start() 537 script = rb_str_new((const char *) rack_init->script->start, in nxt_ruby_rack_parse_script() 565 rb_str_new((const char *) nxt_server.start, in nxt_ruby_rack_env_create()
|
/unit/src/test/ |
H A D | nxt_base64_test.c | 73 ret = nxt_base64_decode(NULL, tests[i].enc.start, tests[i].enc.length); in nxt_base64_test() 75 if (ret == NXT_ERROR && tests[i].dec.start == NULL) { in nxt_base64_test() 87 ret = nxt_base64_decode(buf, tests[i].enc.start, tests[i].enc.length); in nxt_base64_test()
|
H A D | nxt_cq_test.c | 296 worker_create(nxt_worker_info_t *wi, int id, nxt_thread_start_t start) in worker_create() argument 305 link->start = start; in worker_create() 314 start(wi); in worker_create() 343 size_t start, elapsed; in main() local 464 start = elapsed_time(0); in main() 500 elapsed = elapsed_time(start); in main()
|
H A D | nxt_gmtime_test.c | 30 nxt_nsec_t start, end; in nxt_gmtime_test() local 56 start = nxt_thread_monotonic_time(thr); in nxt_gmtime_test() 66 (end - start) / 10000000.0); in nxt_gmtime_test() 70 start = nxt_thread_monotonic_time(thr); in nxt_gmtime_test() 80 (end - start) / 10000000.0); in nxt_gmtime_test()
|