Home
last modified time | relevance | path

Searched refs:start (Results 101 – 125 of 158) sorted by path

1234567

/unit/src/
H A Dnxt_string.c20 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 Dnxt_string.h91 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 Dnxt_thread.c106 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 Dnxt_thread.h83 nxt_thread_start_t start; member
H A Dnxt_thread_pool.c89 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 Dnxt_thread_time.c73 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 Dnxt_tstr.c100 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 Dnxt_tstr.h68 p = memchr(str->start, '`', str->length); in nxt_is_tstr()
73 p = memchr(str->start, '$', str->length); in nxt_is_tstr()
H A Dnxt_unit.c1678 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 Dnxt_unit.h89 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 Dnxt_utf8.c73 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 Dnxt_utf8.h20 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 Dnxt_var.c333 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 Dnxt_vector.c36 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 Dnxt_vector.h19 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 Dnxt_perl_psgi.c437 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 Dnxt_python.c329 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 Dnxt_python_asgi.c686 && 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 Dnxt_python_asgi_lifespan.c479 && 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 Dnxt_python_asgi_websocket.c230 && 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 Dnxt_python_wsgi.c477 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 Dnxt_ruby.c161 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 Dnxt_base64_test.c73 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 Dnxt_cq_test.c296 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 Dnxt_gmtime_test.c30 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()

1234567