Home
last modified time | relevance | path

Searched refs:next (Results 1 – 25 of 86) sorted by last modified time

1234

/unit/src/
H A Dnxt_runtime.c473 nxt_queue_link_t *link, *next; in nxt_runtime_close_idle_connections() local
481 link = next) in nxt_runtime_close_idle_connections()
483 next = nxt_queue_next(link); in nxt_runtime_close_idle_connections()
1297 goto next; in nxt_runtime_listen_sockets_create()
1305 next: in nxt_runtime_listen_sockets_create()
1400 if (process->link.next != NULL) { in nxt_runtime_process_release()
1406 child->link.next = NULL; in nxt_runtime_process_release()
H A Dnxt_process.c1007 nxt_queue_link_t *link, *next; in nxt_process_quit() local
1019 link = next) in nxt_process_quit()
1021 next = nxt_queue_next(link); in nxt_process_quit()
H A Dnxt_application.c901 uint32_t next; in nxt_app_set_environment() local
906 next = 0; in nxt_app_set_environment()
909 value_obj = nxt_conf_next_object_member(environment, &name, &next); in nxt_app_set_environment()
1196 process->link.next = NULL; in nxt_proto_process_remove()
H A Dnxt_var.c336 u_char *p, *end, *next, *src; in nxt_var_compile() local
398 subs[n].length = next - p; in nxt_var_compile()
404 p = next; in nxt_var_compile()
414 u_char *p, *end, *next; in nxt_var_test() local
425 if (next == NULL) { in nxt_var_test()
443 p = next; in nxt_var_test()
571 size_t length, last, next; in nxt_var_query() local
631 next = subs[i].position; in nxt_var_query()
633 if (next != last) { in nxt_var_query()
634 p = nxt_cpymem(p, &src[last], next - last); in nxt_var_query()
[all …]
H A Dnxt_router.c544 next = b->next; in nxt_router_msg_cancel()
545 b->next = NULL; in nxt_router_msg_cancel()
566 lnk->next = NULL; in nxt_queue_chk_remove()
1531 next = 0; in nxt_router_conf_create()
1791 next = 0; in nxt_router_conf_create()
2041 next = 0; in nxt_router_conf_process_static()
3301 next = work->next; in nxt_router_engine_post()
3885 next = b->next; in nxt_router_response_ready_handler()
3891 b = next; in nxt_router_response_ready_handler()
4044 b = b->next; in nxt_router_req_headers_ack_handler()
[all …]
H A Dnxt_http_static.c797 next = &out; in nxt_http_static_body_handler()
813 *next = b; in nxt_http_static_body_handler()
814 next = &b->next; in nxt_http_static_body_handler()
829 out = b->next; in nxt_http_static_body_handler()
848 nxt_buf_t *b, *fb, *next; in nxt_http_static_buf_completion() local
880 next = b->next; in nxt_http_static_buf_completion()
890 b->next = NULL; in nxt_http_static_buf_completion()
898 if (next != NULL) { in nxt_http_static_buf_completion()
899 b = next; in nxt_http_static_buf_completion()
908 next = b->next; in nxt_http_static_buf_completion()
[all …]
H A Dnxt_http_request.c730 nxt_buf_t *b, *next; in nxt_http_request_mem_buf_completion() local
737 next = b->next; in nxt_http_request_mem_buf_completion()
742 b = next; in nxt_http_request_mem_buf_completion()
H A Dnxt_conf_validation.c61 nxt_conf_vldt_object_t *next; member
69 #define NXT_CONF_VLDT_NEXT(next) { .u.members = next } argument
H A Dnxt_http_route.c238 uint32_t i, n, next; in nxt_http_routes_create() local
260 next = 0; in nxt_http_routes_create()
263 route_conf = nxt_conf_next_object_member(routes_conf, &name, &next); in nxt_http_routes_create()
730 uint32_t i, n, next; in nxt_http_route_ruleset_create() local
747 next = 0; in nxt_http_route_ruleset_create()
756 rule_cv = nxt_conf_next_object_member(ruleset_cv, &name, &next); in nxt_http_route_ruleset_create()
H A Dnxt_conf.h88 nxt_conf_value_t *value, nxt_str_t *name, uint32_t *next);
H A Dnxt_controller.c1676 uint32_t next; in nxt_controller_cert_in_use() local
1686 next = 0; in nxt_controller_cert_in_use()
1689 listener = nxt_conf_next_object_member(listeners, &str, &next); in nxt_controller_cert_in_use()
2089 b->next = body; in nxt_controller_response()
H A Dnxt_unit.c209 nxt_unit_mmap_buf_t *next; member
789 mmap_buf->next = *head; in nxt_unit_mmap_buf_insert()
791 if (mmap_buf->next != NULL) { in nxt_unit_mmap_buf_insert()
792 mmap_buf->next->prev = &mmap_buf->next; in nxt_unit_mmap_buf_insert()
805 prev = &(*prev)->next; in nxt_unit_mmap_buf_insert_tail()
819 if (mmap_buf->next != NULL) { in nxt_unit_mmap_buf_unlink()
824 *prev = mmap_buf->next; in nxt_unit_mmap_buf_unlink()
1423 b = b->next; in nxt_unit_process_req_body()
1428 b->next->prev = &b->next; in nxt_unit_process_req_body()
2840 return &mmap_buf->next->buf; in nxt_unit_buf_next()
[all …]
H A Dnxt_string.c452 u_char next, last; in nxt_strvers_match() local
460 next = version[length]; in nxt_strvers_match()
462 if (next == '\0') { in nxt_strvers_match()
468 if (nxt_isdigit(last) != nxt_isdigit(next)) { in nxt_strvers_match()
H A Dnxt_port_socket.c173 msg.link.next = NULL; in nxt_port_socket_write2()
259 if (b->next != NULL) { in nxt_port_can_enqueue_buf()
622 nxt_buf_t *next; in nxt_port_buf_completion() local
672 next = b->next; in nxt_port_buf_completion()
673 b->next = NULL; in nxt_port_buf_completion()
674 b = next; in nxt_port_buf_completion()
1292 next = b->next; in nxt_port_read_msg_process()
1294 b = next; in nxt_port_read_msg_process()
1315 b->next = NULL; in nxt_port_buf_alloc()
1364 next = b->next; in nxt_port_error_handler()
[all …]
H A Dnxt_mp.c314 nxt_rbtree_node_t *node, *next; in nxt_mp_destroy() local
322 next_work = work->next; in nxt_mp_destroy()
329 next = nxt_rbtree_root(&mp->blocks); in nxt_mp_destroy()
331 while (next != nxt_rbtree_sentinel(&mp->blocks)) { in nxt_mp_destroy()
333 node = nxt_rbtree_destroy_next(&mp->blocks, &next); in nxt_mp_destroy()
600 nxt_queue_link_t *link, *next; in nxt_mp_get_small() local
606 link = next) in nxt_mp_get_small()
608 next = nxt_queue_next(link); in nxt_mp_get_small()
1052 work->next = mp->cleanup; in nxt_mp_cleanup()
H A Dnxt_conf.c715 uint32_t *next) in nxt_conf_next_object_member() argument
725 n = *next; in nxt_conf_next_object_member()
733 *next = n + 1; in nxt_conf_next_object_member()
H A Dnxt_h1proto.c1412 b = in->next; in nxt_h1p_complete_buffers()
1413 in->next = NULL; in nxt_h1p_complete_buffers()
1417 next = b->next; in nxt_h1p_complete_buffers()
1418 b->next = NULL; in nxt_h1p_complete_buffers()
1422 b = next; in nxt_h1p_complete_buffers()
1484 out = out->next; in nxt_h1p_request_send()
1512 tail->next = b; in nxt_h1p_chunk_create()
1524 prev = &b->next; in nxt_h1p_chunk_create()
1536 header->next = out; in nxt_h1p_chunk_create()
1919 out->next = last; in nxt_h1p_idle_response()
[all …]
H A Dnxt_port_rpc.c230 reg->stream, reg->peer, reg->link.next); in nxt_port_rpc_ex_set_peer()
239 reg->stream, reg->peer, reg->link.next); in nxt_port_rpc_ex_set_peer()
268 if (reg->link.next == &reg->link) { in nxt_port_rpc_remove_from_peers()
272 "registration (%p)", stream, reg->peer, reg->link.next); in nxt_port_rpc_remove_from_peers()
278 "registration (%p)", stream, reg->peer, reg->link.next); in nxt_port_rpc_remove_from_peers()
281 lhq.value = reg->link.next; in nxt_port_rpc_remove_from_peers()
293 "registration (%p)", stream, reg->peer, reg->link.next); in nxt_port_rpc_remove_from_peers()
416 if (peer_link == peer_link->next) { in nxt_port_rpc_remove_peer()
422 nxt_assert(peer_link->next->prev == peer_link); in nxt_port_rpc_remove_peer()
423 nxt_assert(peer_link->prev->next == peer_link); in nxt_port_rpc_remove_peer()
[all …]
H A Dnxt_port_memory.c122 nxt_buf_t *b, *next; in nxt_port_mmap_buf_completion() local
188 next = b->next; in nxt_port_mmap_buf_completion()
194 if (next != NULL) { in nxt_port_mmap_buf_completion()
195 b = next; in nxt_port_mmap_buf_completion()
733 bmem = bmem->next; in nxt_port_mmap_write()
773 for (b = msg->buf; b != NULL; b = b->next) { in nxt_port_mmap_read()
793 pb = &(*pb)->next; in nxt_port_mmap_read()
810 for (/* void */; b != NULL; b = b->next) { in nxt_port_mmap_get_method()
H A Dnxt_openssl.c348 last && bundle->next == NULL) in nxt_openssl_server_init()
429 if (bundle->next != NULL) { in nxt_openssl_server_init()
1145 bundle = bundle->next;
H A Dnxt_work_queue.h39 nxt_work_t *next; member
50 nxt_work_queue_chunk_t *next; member
56 nxt_work_t *next; member
H A Dnxt_source.h25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
29 task, next, out); \
32 (next)->filter(task, (next)->context, out); \
H A Dnxt_mem_zone.c47 nxt_mem_zone_page_t *next; member
537 slot->pages = page->next; in nxt_mem_zone_alloc_small()
539 page->next = NULL; in nxt_mem_zone_alloc_small()
556 page->next = NULL; in nxt_mem_zone_alloc_small()
864 page->next = slot->pages; in nxt_mem_zone_free_chunk()
882 for (pg = slot->pages; pg != NULL; pg = pg->next) { in nxt_mem_zone_free_chunk()
885 *ppg = page->next; in nxt_mem_zone_free_chunk()
889 ppg = &pg->next; in nxt_mem_zone_free_chunk()
909 page->next = NULL; in nxt_mem_zone_free_pages()
913 next_page = nxt_queue_link_data(page->link.next, nxt_mem_zone_page_t, link); in nxt_mem_zone_free_pages()
/unit/test/
H A Dtest_ruby_application.py240 return next(
/unit/src/test/
H A Dnxt_rbtree1_test.c229 nxt_rbtree1_node_t *next, *sentinel; in nxt_rbtree1_test_find() local
231 next = tree->root; in nxt_rbtree1_test_find()
234 while (next != sentinel) { in nxt_rbtree1_test_find()
235 nxt_prefetch(next->left); in nxt_rbtree1_test_find()
236 nxt_prefetch(next->right); in nxt_rbtree1_test_find()
238 n = nxt_rbtree1_test_compare(node, next); in nxt_rbtree1_test_find()
241 next = next->left; in nxt_rbtree1_test_find()
244 next = next->right; in nxt_rbtree1_test_find()
247 return next; in nxt_rbtree1_test_find()

1234