Home
last modified time | relevance | path

Searched refs:i (Results 76 – 100 of 138) sorted by path

123456

/unit/src/
H A Dnxt_random.c39 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 Dnxt_random.h12 uint8_t i; member
H A Dnxt_router.c135 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 Dnxt_runtime.c566 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 Dnxt_script.c165 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 Dnxt_select_engine.c284 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 Dnxt_sha1.c161 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 Dnxt_sockaddr.c439 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 Dnxt_solaris_sendfilev.c95 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 Dnxt_sprintf.c101 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 Dnxt_status.c14 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 Dnxt_thread_time.c64 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 Dnxt_unit.c1960 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 Dnxt_upstream.c21 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 Dnxt_upstream_round_robin.c66 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 Dnxt_var.c116 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 Dnxt_work_queue.c122 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 Dnxt_perl_psgi.c600 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 Dnxt_python.c296 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 Dnxt_python_asgi.c146 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 Dnxt_python_asgi.h10 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 Dnxt_python_asgi_lifespan.c103 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 Dnxt_python_wsgi.c659 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 Dnxt_ruby.c765 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 Dnxt_base64_test.c14 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()

123456