/unit/src/ |
H A D | nxt_random.c | 39 nxt_uint_t i; in nxt_random_start_schedule() local 41 r->i = 0; in nxt_random_start_schedule() 44 for (i = 0; i < 256; i++) { in nxt_random_start_schedule() 45 r->s[i] = i; in nxt_random_start_schedule() 124 val = r->s[r->i]; in nxt_random_add() 130 r->i++; in nxt_random_add() 134 r->i--; in nxt_random_add() 136 r->j = r->i; in nxt_random_add() 165 r->i++; in nxt_random_byte() 166 si = r->s[r->i]; in nxt_random_byte() [all …]
|
H A D | nxt_random.h | 12 uint8_t i; member
|
H A D | nxt_router.c | 135 int i); 1808 for (i = 0; i < n; i++) { in nxt_router_conf_create() 2074 for (i = 0; i < n; i++) { in nxt_router_conf_create() 2128 for (i = 0; i < n; i++) { in nxt_router_conf_create() 2331 for (i = 0; i < exts; i++) { in nxt_router_conf_process_static() 2438 for (i = 0; i < fh->header->length; i++) { in nxt_router_conf_forward_header() 2660 for (i = 0; !nxt_strstr_eq(target, &targets[i]); i++); in nxt_router_application_init() 3456 for (i = tmcf->new_threads; i < threads; i++) { in nxt_router_threads_create() 4645 if (i < 0 && c == -i) { in nxt_router_app_use() 5356 i->field = nxt_list_data(i->part); in nxt_fields_part_first() [all …]
|
H A D | nxt_runtime.c | 566 size_t i; in nxt_runtime_exit() local 577 for (i = 0; i < rt->listen_sockets->nelts; i++) { in nxt_runtime_exit() 580 ls = (nxt_listen_socket_t *) rt->listen_sockets->elts + i; in nxt_runtime_exit() 732 nxt_uint_t i, n; in nxt_runtime_thread_pool_exit() local 751 for (i = 0; i < n; i++) { in nxt_runtime_thread_pool_exit() 753 if (tp == thread_pools[i]) { in nxt_runtime_thread_pool_exit() 754 nxt_array_remove(rt->thread_pools, &thread_pools[i]); in nxt_runtime_thread_pool_exit() 1438 nxt_uint_t i, n; in nxt_runtime_listen_sockets_enable() local 1444 for (i = 0; i < n; i++) { in nxt_runtime_listen_sockets_enable() 1445 if (ls[i].flags == NXT_NONBLOCK) { in nxt_runtime_listen_sockets_enable() [all …]
|
H A D | nxt_script.c | 165 uint32_t i; in nxt_script_info_init() local 171 for (i = 0; i < scripts->nelts; i++) { in nxt_script_info_init() 269 uint32_t i; in nxt_script_info_get_all() local 276 for (i = 0; /* void */; i++) { in nxt_script_info_get_all() 284 all = nxt_conf_create_object(mp, i); in nxt_script_info_get_all() 291 for (i = 0; /* void */; i++) { in nxt_script_info_get_all() 298 nxt_conf_set_member(all, &info->name, info->value, i); in nxt_script_info_get_all() 465 uint32_t i; in nxt_script_store_release() local 470 for (i = 0; i < scripts->nelts; i++) { in nxt_script_store_release() 471 nxt_fd_close(item[i].fd); in nxt_script_store_release()
|
H A D | nxt_select_engine.c | 284 nxt_int_t i; in nxt_select_poll() local 299 for (i = engine->u.select.nfds; i >= 0; i--) { in nxt_select_poll() 300 if (engine->u.select.events[i] != NULL) { in nxt_select_poll() 301 engine->u.select.nfds = i; in nxt_select_poll()
|
H A D | nxt_sha1.c | 161 nxt_uint_t i; in nxt_sha1_body() local 181 for (i = 0; i < 16; i++) { in nxt_sha1_body() 182 words[i] = GET(i); in nxt_sha1_body() 185 for (i = 16; i < 80; i++) { in nxt_sha1_body() 186 words[i] = ROTATE(1, words[i - 3] in nxt_sha1_body() 187 ^ words[i - 8] in nxt_sha1_body() 188 ^ words[i - 14] in nxt_sha1_body() 189 ^ words[i - 16]); in nxt_sha1_body()
|
H A D | nxt_sockaddr.c | 439 nxt_uint_t i, zero_start, last_zero_start; in nxt_inet6_ntop() local 453 for (i = 0; i < 16; i += 2) { in nxt_inet6_ntop() 455 if (addr[i] == 0 && addr[i + 1] == 0) { in nxt_inet6_ntop() 458 last_zero_start = i; in nxt_inet6_ntop() 496 for (i = 0; i < ipv6_bytes; i += 2) { in nxt_inet6_ntop() 498 if (i == zero_start) { in nxt_inet6_ntop() 500 i += (zero_groups - 1) * 2; in nxt_inet6_ntop() 505 p = nxt_sprintf(p, end, "%uxd", (addr[i] << 8) + addr[i + 1]); in nxt_inet6_ntop() 507 if (i < 14) { in nxt_inet6_ntop()
|
H A D | nxt_solaris_sendfilev.c | 95 nxt_int_t i; in nxt_solaris_buf_coalesce() local 98 i = -1; in nxt_solaris_buf_coalesce() 144 if (++i >= NXT_IOBUF_MAX) { in nxt_solaris_buf_coalesce() 148 sfv[i].sfv_fd = fd; in nxt_solaris_buf_coalesce() 149 sfv[i].sfv_flag = 0; in nxt_solaris_buf_coalesce() 150 sfv[i].sfv_off = pos; in nxt_solaris_buf_coalesce() 151 sfv[i].sfv_len = size; in nxt_solaris_buf_coalesce() 154 sfv[i].sfv_len += size; in nxt_solaris_buf_coalesce() 162 i++; in nxt_solaris_buf_coalesce() 166 *nsfv = i; in nxt_solaris_buf_coalesce()
|
H A D | nxt_sprintf.c | 101 double f, i; in nxt_vsprintf() local 401 (void) modf(f, &i); in nxt_vsprintf() 411 frac = (uint64_t) ((f - i) * scale + 0.5); in nxt_vsprintf() 414 i += 1; in nxt_vsprintf() 419 buf = nxt_number(&spf, buf, i); in nxt_vsprintf() 433 f = modf(f, &i); in nxt_vsprintf() 440 f = modf(f, &i); in nxt_vsprintf() 441 *buf++ = (u_char) i + '0'; in nxt_vsprintf()
|
H A D | nxt_status.c | 14 size_t i; in nxt_status_get() local 67 for (i = 0; i < report->apps_count; i++) { in nxt_status_get() 68 app = &report->apps[i]; in nxt_status_get() 78 ret = nxt_conf_set_member_dup(apps, mp, &name, app_obj, i); in nxt_status_get()
|
H A D | nxt_thread_time.c | 64 nxt_uint_t i; in nxt_thread_time_free() local 72 for (i = 0; i < thr->time.nstrings; i++) { in nxt_thread_time_free() 73 nxt_free(tsc[i].string.start); in nxt_thread_time_free() 403 nxt_atomic_uint_t i, nstrings; in nxt_thread_time_string_cache() local 423 for (i = thr->time.nstrings; i < nstrings; i++) { in nxt_thread_time_string_cache() 424 tsc[i].last = -1; in nxt_thread_time_string_cache() 425 tsc[i].string.start = NULL; in nxt_thread_time_string_cache()
|
H A D | nxt_unit.c | 1960 for (i = 0; i < r->fields_count; i++) { in nxt_unit_request_group_dup_fields() 2020 i++; in nxt_unit_request_group_dup_fields() 2155 for (i = 0; i < req->response->fields_count; i++) { in nxt_unit_response_realloc() 3345 for (i = 0; i < iovcnt; i++) { in nxt_unit_websocket_sendv() 3372 for (i = 0; i < iovcnt; i++) { in nxt_unit_websocket_sendv() 3421 uint64_t i, d; in nxt_unit_websocket_read() local 3433 for (i = 0; i < (uint64_t) res; i++) { in nxt_unit_websocket_read() 3434 b[i] ^= ws->mask[ (i + d) % 4 ]; in nxt_unit_websocket_read() 3537 for (i = 0; i < nchunks; i++) { in nxt_unit_mmap_get() 3704 cap = i + 1; in nxt_unit_mmap_at() [all …]
|
H A D | nxt_upstream.c | 21 uint32_t i, n, next; in nxt_upstreams_create() local 53 for (i = 0; i < n; i++) { in nxt_upstreams_create() 56 string = nxt_str_dup(mp, &upstreams->upstream[i].name, &name); in nxt_upstreams_create() 78 uint32_t i, n; in nxt_upstream_find() local 88 for (i = 0; i < n; i++) { in nxt_upstream_find() 89 if (nxt_strstr_eq(&upstream[i].name, name)) { in nxt_upstream_find() 90 action->u.upstream_number = i; in nxt_upstream_find() 105 uint32_t i, n; in nxt_upstreams_joint_create() local 127 for (i = 0; i < n; i++) { in nxt_upstreams_joint_create() 128 up[i] = u[i].proto->joint_create(tmcf, &u[i]); in nxt_upstreams_joint_create() [all …]
|
H A D | nxt_upstream_round_robin.c | 66 for (i = 0; i < n; i++) { in nxt_upstream_round_robin_create() 94 for (i = 0; i < n; i++) { in nxt_upstream_round_robin_create() 104 urr->server[i].sockaddr = sa; in nxt_upstream_round_robin_create() 111 urr->server[i].weight = wt; in nxt_upstream_round_robin_create() 156 for (i = 0; i < n; i++) { in nxt_upstream_round_robin_joint_create() 157 urr->server[i] = urrcf->server[i]; in nxt_upstream_round_robin_joint_create() 180 for (i = 0; i < n; i++) { in nxt_upstream_round_robin_server_get() 182 s[i].current_weight += s[i].effective_weight; in nxt_upstream_round_robin_server_get() 185 if (s[i].effective_weight < s[i].weight) { in nxt_upstream_round_robin_server_get() 186 s[i].effective_weight++; in nxt_upstream_round_robin_server_get() [all …]
|
H A D | nxt_var.c | 116 nxt_uint_t i; in nxt_var_ref_get() local 122 for (i = 0; i < state->var_refs->nelts; i++) { in nxt_var_ref_get() 125 return &ref[i]; in nxt_var_ref_get() 279 for (i = 0; i < n; i++) { in nxt_var_register() 298 nxt_uint_t i; in nxt_var_index_init() local 309 for (i = 0; i < nxt_var_count; i++) { in nxt_var_index_init() 311 vars[i] = decl; in nxt_var_index_init() 505 nxt_uint_t i; in nxt_var_interpreter() local 518 for (i = 0; i < var->vars; i++) { in nxt_var_interpreter() 552 for (i = 0; i < var->vars; i++) { in nxt_var_interpreter() [all …]
|
H A D | nxt_work_queue.c | 122 nxt_uint_t i, n; in nxt_work_queue_allocate() local 137 for (i = 0; i < n; i++) { in nxt_work_queue_allocate() 138 work[i].next = &work[i + 1]; in nxt_work_queue_allocate() 141 work[i].next = NULL; in nxt_work_queue_allocate()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 600 uint32_t i; in nxt_perl_psgi_env_create() local 681 for (i = 0; i < r->fields_count; i++) { in nxt_perl_psgi_env_create() 682 f = r->fields + i; in nxt_perl_psgi_env_create() 817 for (i = 0; i <= array_len; i++) { in nxt_perl_psgi_result_head() 840 for (i = 0; i <= array_len; i += 2) { in nxt_perl_psgi_result_head() 864 long i; in nxt_perl_psgi_result_body() local 878 for (i = 0; i <= av_len(body_array); i++) { in nxt_perl_psgi_result_body() 1277 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_ready_handler() 1369 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_init_threads() 1392 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_join_threads() [all …]
|
/unit/src/python/ |
H A D | nxt_python.c | 296 for (i = 0; /* void */; i++) { in nxt_python_start() 326 for (i = 1; i < targets->count; i++) { in nxt_python_start() 585 uint32_t i; in nxt_python_init_threads() local 623 for (i = 0; i < c->threads - 1; i++) { in nxt_python_init_threads() 640 uint32_t i; in nxt_python_ready_handler() local 650 for (i = 0; i < c->threads - 1; i++) { in nxt_python_ready_handler() 715 uint32_t i; in nxt_python_join_threads() local 725 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads() 745 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads() 799 nxt_int_t i; in nxt_python_atexit() local [all …]
|
H A D | nxt_python_asgi.c | 146 nxt_int_t i; in nxt_python_asgi_init() local 171 for (i = 0; i < nxt_py_targets->count; i++) { in nxt_python_asgi_init() 305 for (i = 0; i < nxt_nitems(handlers); i++) { in nxt_python_asgi_ctx_data_alloc() 770 for (i = 0; i < r->fields_count; i++) { in nxt_py_asgi_create_http_scope() 943 for (i = 0; i < f->value_length; i++) { in nxt_py_asgi_create_subprotocols() 957 for (i = 0; i < f->value_length; ) { in nxt_py_asgi_create_subprotocols() 959 i++; in nxt_py_asgi_create_subprotocols() 976 i++; in nxt_py_asgi_create_subprotocols() 977 } while (i < f->value_length && v[i] == ' '); in nxt_py_asgi_create_subprotocols() 1223 int i; in nxt_py_asgi_enum_headers() local [all …]
|
H A D | nxt_python_asgi.h | 10 typedef PyObject * (*nxt_py_asgi_enum_header_cb)(void *ctx, int i, 42 PyObject *nxt_py_asgi_calc_size(void *data, int i, PyObject *n, PyObject *v); 43 PyObject *nxt_py_asgi_add_field(void *data, int i, PyObject *n, PyObject *v);
|
H A D | nxt_python_asgi_lifespan.c | 103 nxt_int_t i; in nxt_py_asgi_lifespan_startup() local 116 for (i = 0; i < nxt_py_targets->count; i++) { in nxt_py_asgi_lifespan_startup() 117 target = &nxt_py_targets->target[i]; in nxt_py_asgi_lifespan_startup() 124 target_lifespans[i] = lifespan; in nxt_py_asgi_lifespan_startup() 324 nxt_int_t i, ret; in nxt_py_asgi_lifespan_shutdown() local 330 for (i = 0; i < nxt_py_targets->count; i++) { in nxt_py_asgi_lifespan_shutdown() 331 lifespan = (nxt_py_asgi_lifespan_t *)ctx_data->target_lifespans[i]; in nxt_py_asgi_lifespan_shutdown()
|
H A D | nxt_python_wsgi.c | 659 for (i = 0; i < r->fields_count;) { in nxt_python_get_environ() 660 f = r->fields + i; in nxt_python_get_environ() 677 i = j; in nxt_python_get_environ() 822 uint8_t i; in nxt_python_field_name() local 839 for (i = 0; i < len; i++) { in nxt_python_field_name() 840 c = name[i]; in nxt_python_field_name() 862 int i; in nxt_python_field_value() local 880 for (i = 1; i < n; i++) { in nxt_python_field_value() 907 for (i = 1; i < n; i++) { in nxt_python_field_value() 972 for (i = 0; i < fields_count; i++) { in nxt_py_start_resp() [all …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 765 for (i = 0; i < r->fields_count; i++) { in nxt_ruby_read_request() 905 for (i = 0; i < arr_len; i++) { in nxt_ruby_hash_info() 981 for (i = 0; i < arr_len; i++) { in nxt_ruby_hash_add() 994 for (i = 0; i < arr_len; i++) { in nxt_ruby_hash_add() 1260 int i; in nxt_ruby_exception_log() local 1286 for (i = 1; i < RARRAY_LEN(ary); i++) { in nxt_ruby_exception_log() 1345 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_ready_handler() 1457 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1466 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1492 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_join_threads() [all …]
|
/unit/src/test/ |
H A D | nxt_base64_test.c | 14 nxt_uint_t i; in nxt_base64_test() local 72 for (i = 0; i < nxt_nitems(tests); i++) { in nxt_base64_test() 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() 79 if ((size_t) ret != tests[i].dec.length) { in nxt_base64_test() 83 &tests[i].enc, ret, tests[i].dec.length); in nxt_base64_test() 87 ret = nxt_base64_decode(buf, tests[i].enc.start, tests[i].enc.length); in nxt_base64_test() 89 if (!nxt_str_eq(&tests[i].dec, buf, (size_t) ret)) { in nxt_base64_test()
|