/unit/src/ |
H A D | nxt_timer.c | 236 nxt_rbtree_node_t *node, *next; in nxt_timer_find() local 248 node = next) in nxt_timer_find() 250 next = nxt_rbtree_node_successor(tree, node); in nxt_timer_find() 286 nxt_rbtree_node_t *node, *next; in nxt_timer_expire() local 303 node = next) in nxt_timer_expire() 312 next = nxt_rbtree_node_successor(tree, node); in nxt_timer_expire()
|
H A D | nxt_upstream_round_robin.c | 48 uint32_t i, n, next, wt; in nxt_upstream_round_robin_create() local 64 next = 0; in nxt_upstream_round_robin_create() 67 srvcf = nxt_conf_next_object_member(servers_conf, &name, &next); in nxt_upstream_round_robin_create() 92 next = 0; in nxt_upstream_round_robin_create() 95 srvcf = nxt_conf_next_object_member(servers_conf, &name, &next); in nxt_upstream_round_robin_create()
|
H A D | nxt_vector.c | 142 u_char *next, *last, *end; in nxt_vector_remove() local 150 next = nxt_pointer_to(item, item_size); in nxt_vector_remove() 152 nxt_memmove(item, next, end - next); in nxt_vector_remove()
|
H A D | nxt_solaris_sendfilev.c | 103 for (total = 0; b != NULL && total < limit; b = b->next) { in nxt_solaris_buf_coalesce()
|
H A D | nxt_rbtree.h | 128 nxt_rbtree_node_t **next);
|
H A D | nxt_service.c | 103 goto next; in nxt_service_add() 107 goto next; in nxt_service_add() 114 next: in nxt_service_add()
|
H A D | nxt_queue.c | 19 nxt_queue_link_t *middle, *next; in nxt_queue_middle() local 27 next = middle; in nxt_queue_middle() 32 next = nxt_queue_next(next); in nxt_queue_middle() 34 if (next == nxt_queue_last(queue)) { in nxt_queue_middle() 38 next = nxt_queue_next(next); in nxt_queue_middle() 40 if (next == nxt_queue_last(queue)) { in nxt_queue_middle() 57 nxt_queue_link_t *link, *prev, *next; in nxt_queue_sort() local 67 link = next) in nxt_queue_sort() 70 next = nxt_queue_next(link); in nxt_queue_sort()
|
H A D | nxt_rbtree.c | 199 next = next->left; in nxt_rbtree_find() 202 next = next->right; in nxt_rbtree_find() 205 return next; in nxt_rbtree_find() 234 next = next->left; in nxt_rbtree_find_less_or_equal() 237 retval = next; in nxt_rbtree_find_less_or_equal() 238 next = next->right; in nxt_rbtree_find_less_or_equal() 242 return next; in nxt_rbtree_find_less_or_equal() 272 next = next->left; in nxt_rbtree_find_greater_or_equal() 275 next = next->right; in nxt_rbtree_find_greater_or_equal() 279 return next; in nxt_rbtree_find_greater_or_equal() [all …]
|
H A D | nxt_recvbuf.c | 22 for (b = rb->buf; b != NULL; b = b->next) { in nxt_recvbuf_mem_coalesce() 24 nxt_prefetch(b->next); in nxt_recvbuf_mem_coalesce() 65 nxt_prefetch(b->next); in nxt_recvbuf_update() 80 b = b->next; in nxt_recvbuf_update()
|
H A D | nxt_poll_engine.c | 344 goto next; in nxt_poll_commit_changes() 353 goto next; in nxt_poll_commit_changes() 362 goto next; in nxt_poll_commit_changes() 373 next: in nxt_poll_commit_changes() 555 goto next; in nxt_poll() 572 goto next; in nxt_poll() 629 next: in nxt_poll()
|
H A D | nxt_lib.c | 140 rt->thread_pools = (tp != NULL) ? tp->next : NULL; in nxt_lib_stop()
|
H A D | nxt_list.c | 22 list->part.next = NULL; in nxt_list_create() 49 last->next = NULL; in nxt_list_add() 52 list->last->next = last; in nxt_list_add() 81 if (next->part != NULL) { in nxt_list_next() 82 next->elt++; in nxt_list_next() 84 if (next->elt < next->part->nelts) { in nxt_list_next() 88 next->part = next->part->next; in nxt_list_next() 90 if (next->part != NULL) { in nxt_list_next() 91 next->elt = 0; in nxt_list_next() 96 next->part = nxt_list_part(list); in nxt_list_next() [all …]
|
H A D | nxt_http_error.c | 95 out->next = nxt_http_buf_last(r); in nxt_http_request_send_error_body()
|
H A D | nxt_http_websocket.c | 33 nxt_buf_t *out, *buf, **out_tail, *b, *next; in nxt_http_websocket_client() local 74 out_tail = &buf->next; in nxt_http_websocket_client() 88 next = b->next; in nxt_http_websocket_client() 89 b->next = NULL; in nxt_http_websocket_client() 95 r->ws_frame = next; in nxt_http_websocket_client() 98 b = next; in nxt_http_websocket_client()
|
H A D | nxt_eventport_engine.c | 325 goto next; in nxt_eventport_commit_changes() 337 goto next; in nxt_eventport_commit_changes() 350 next: in nxt_eventport_commit_changes()
|
H A D | nxt_fiber.h | 33 nxt_fiber_t *next; member 53 void nxt_fiber_exit(nxt_task_t *task, nxt_fiber_t *next, void *data);
|
H A D | nxt_epoll_engine.c | 1017 c = lev->next; in nxt_epoll_conn_io_accept4()
|
H A D | nxt_conn_proxy.c | 422 source->read = rb->next; in nxt_conn_proxy_read_process() 452 second = first->next; in nxt_conn_proxy_write_add() 457 first->next = b; in nxt_conn_proxy_write_add() 614 sink->write = wb->next; in nxt_conn_proxy_write_process() 644 second = first->next; in nxt_conn_proxy_read_add() 665 first->next = b; in nxt_conn_proxy_read_add() 691 first->next = NULL; in nxt_conn_proxy_read_add()
|
H A D | nxt_event_conn_job_sendfile.c | 243 nxt_prefetch(b->next); in nxt_event_conn_job_sendfile_completion() 255 b = b->next; in nxt_event_conn_job_sendfile_completion()
|
H A D | nxt_buf_pool.c | 25 bp->free = b->next; in nxt_buf_pool_mem_alloc() 26 b->next = NULL; in nxt_buf_pool_mem_alloc() 65 bp->free = b->next; in nxt_buf_pool_file_alloc() 66 b->next = NULL; in nxt_buf_pool_file_alloc() 105 bp->free = b->next; in nxt_buf_pool_mmap_alloc() 106 b->next = NULL; in nxt_buf_pool_mmap_alloc() 166 b->next = bp->free; in nxt_buf_pool_free() 180 n = b->next; in nxt_buf_pool_destroy()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | UriTemplate.java | 117 Segment candidateSegment = candidateSegments.next(); in match() 118 Segment targetSegment = targetSegments.next(); in match()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 89 …s send messages. The client must wait for the previous message to complete before sending the next.
|
H A D | PerMessageDeflate.java | 57 private volatile Transformation next; field in PerMessageDeflate 248 if (next == null) { in validateRsv() 251 return next.validateRsv(rsv, opCode); in validateRsv() 259 if (next == null) { in validateRsv() 262 return next.validateRsv(rsvNext, opCode); in validateRsv() 295 if (next == null) { in setNext() 296 this.next = t; in setNext() 298 next.setNext(t); in setNext() 308 if (next == null) { in validateRsvBits() 442 if (next == null) { in sendMessagePart() [all …]
|
H A D | AuthenticatorFactory.java | 60 Authenticator auth = auths.next(); in loadAuthenticators()
|
/unit/src/java/javax/websocket/server/ |
H A D | ServerEndpointConfig.java | 174 result = iter.next(); in loadDefault()
|