Searched refs:queue (Results 1 - 25 of 41) sorted by relevance

12

/tldk/app/nginx/src/core/
H A Dngx_queue.c13 * find the middle queue element if the queue has odd number of elements
14 * or the first element of the queue's second part otherwise
18 ngx_queue_middle(ngx_queue_t *queue) argument
22 middle = ngx_queue_head(queue);
24 if (middle == ngx_queue_last(queue)) {
28 next = ngx_queue_head(queue);
35 if (next == ngx_queue_last(queue)) {
41 if (next == ngx_queue_last(queue)) {
51 ngx_queue_sort(ngx_queue_t *queue, argument
[all...]
H A Dngx_queue.h107 ngx_queue_t *ngx_queue_middle(ngx_queue_t *queue);
108 void ngx_queue_sort(ngx_queue_t *queue,
H A Dngx_thread_pool.c31 ngx_thread_pool_queue_t queue; member in struct:ngx_thread_pool_s
120 ngx_thread_pool_queue_init(&tp->queue);
247 "thread pool \"%V\" queue overflow: %i tasks waiting",
262 *tp->queue.last = task;
263 tp->queue.last = &task->next;
314 while (tp->queue.first == NULL) {
323 task = tp->queue.first;
324 tp->queue.first = task->next;
326 if (tp->queue.first == NULL) {
327 tp->queue
[all...]
H A Dngx_open_file_cache.h58 ngx_queue_t queue; member in struct:ngx_cached_open_file_s
H A Dngx_resolver.c68 ngx_queue_t *queue);
83 ngx_queue_t *queue);
348 ngx_queue_remove(&rn->queue);
623 ngx_queue_remove(&rn->queue);
627 ngx_queue_insert_head(expire_queue, &rn->queue);
756 ngx_queue_remove(&rn->queue);
884 ngx_queue_insert_head(resend_queue, &rn->queue);
979 ngx_queue_remove(&rn->queue);
983 ngx_queue_insert_head(expire_queue, &rn->queue);
1031 ngx_queue_remove(&rn->queue);
1238 ngx_resolver_expire(ngx_resolver_t *r, ngx_rbtree_t *tree, ngx_queue_t *queue) argument
1506 ngx_resolver_resend(ngx_resolver_t *r, ngx_rbtree_t *tree, ngx_queue_t *queue) argument
[all...]
H A Dngx_open_file_cache.c107 file = ngx_queue_data(q, ngx_cached_open_file_t, queue);
215 ngx_queue_remove(&file->queue);
430 ngx_queue_insert_head(&cache->expire_queue, &file->queue);
1043 ngx_queue_remove(&file->queue);
1045 ngx_queue_insert_head(&cache->expire_queue, &file->queue);
1118 file = ngx_queue_data(q, ngx_cached_open_file_t, queue);
1235 ngx_queue_remove(&file->queue);
H A Dngx_connection.h159 ngx_queue_t queue; member in struct:ngx_connection_s
H A Dngx_resolver.h94 ngx_queue_t queue; member in struct:__anon60
/tldk/app/nginx/src/event/
H A Dngx_event_posted.h21 ngx_queue_insert_tail(q, &(ev)->queue); \
34 ngx_queue_remove(&(ev)->queue); \
H A Dngx_event_posted.c26 ev = ngx_queue_data(q, ngx_event_t, queue);
/tldk/app/nginx/conf/
H A Dnginx-tldk.conf68 dev 0 port 0 queue 0;
81 dev 0 port 0 queue 1;
/tldk/app/nginx/src/http/modules/
H A Dngx_http_upstream_keepalive_module.c28 ngx_queue_t queue; member in struct:__anon244
144 /* allocate cache items and add to free queue */
156 ngx_queue_insert_head(&kcf->free, &cached[i].queue);
236 item = ngx_queue_data(q, ngx_http_upstream_keepalive_cache_t, queue);
325 item = ngx_queue_data(q, ngx_http_upstream_keepalive_cache_t, queue);
333 item = ngx_queue_data(q, ngx_http_upstream_keepalive_cache_t, queue);
418 ngx_queue_remove(&item->queue);
419 ngx_queue_insert_head(&conf->free, &item->queue);
H A Dngx_http_limit_req_module.c17 ngx_queue_t queue; member in struct:__anon160
29 ngx_queue_t queue; member in struct:__anon161
397 ngx_queue_remove(&lr->queue);
398 ngx_queue_insert_head(&ctx->sh->queue, &lr->queue);
462 ngx_queue_insert_head(&ctx->sh->queue, &lr->queue);
563 if (ngx_queue_empty(&ctx->sh->queue)) {
567 q = ngx_queue_last(&ctx->sh->queue);
569 lr = ngx_queue_data(q, ngx_http_limit_req_node_t, queue);
[all...]
/tldk/app/nginx/src/http/
H A Dngx_http_cache.h41 ngx_queue_t queue; member in struct:__anon264
148 ngx_queue_t queue; member in struct:__anon266
H A Dngx_http_file_cache.c146 ngx_queue_init(&cache->sh->queue);
833 ngx_queue_remove(&fcn->queue);
917 ngx_queue_insert_head(&cache->sh->queue, &fcn->queue);
1647 ngx_queue_remove(&fcn->queue);
1729 for (q = ngx_queue_last(&cache->sh->queue);
1730 q != ngx_queue_sentinel(&cache->sh->queue);
1733 fcn = ngx_queue_data(q, ngx_http_file_cache_node_t, queue);
1799 if (ngx_queue_empty(&cache->sh->queue)) {
1804 q = ngx_queue_last(&cache->sh->queue);
[all...]
/tldk/test/gtest/
H A Dtest_common.h96 typen_rx_callback(dpdk_port_t port, __rte_unused uint16_t queue,
/tldk/examples/l4fwd/
H A Dpkt.c531 __rte_unused uint16_t queue,
599 type0_udp_rx_callback(dpdk_port_t port, __rte_unused uint16_t queue, argument
674 NETBE_TRACE("%s(port=%u, queue=%u, nb_pkts=%u): "
676 __func__, port, queue, nb_pkts, x);
686 __rte_unused uint16_t queue,
740 type1_udp_rx_callback(dpdk_port_t port, __rte_unused uint16_t queue, argument
799 NETBE_TRACE("%s(port=%u, queue=%u, nb_pkts=%u): "
801 __func__, port, queue, nb_pkts, x);
810 typen_tcp_arp_rx_callback(dpdk_port_t port, uint16_t queue, argument
819 RTE_SET_USED(queue);
530 type0_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, void *user_param) argument
685 type1_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, void *user_param) argument
837 typen_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, void *user_param) argument
858 typen_udp_rx_callback(dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, void *user_param) argument
[all...]
/tldk/app/nginx/src/event/modules/
H A Dngx_poll_module.c245 ngx_queue_t *queue; local
374 queue = ev->accept ? &ngx_posted_accept_events
377 ngx_post_event(ev, queue);
H A Dngx_select_module.c218 ngx_queue_t *queue; local
334 queue = ev->accept ? &ngx_posted_accept_events
337 ngx_post_event(ev, queue);
H A Dngx_win32_select_module.c225 ngx_queue_t *queue; local
325 queue = ev->accept ? &ngx_posted_accept_events
328 ngx_post_event(ev, queue);
H A Dngx_devpoll_module.c350 ngx_queue_t *queue; local
500 queue = rev->accept ? &ngx_posted_accept_events
503 ngx_post_event(rev, queue);
H A Dngx_eventport_module.c445 ngx_queue_t *queue; local
564 queue = rev->accept ? &ngx_posted_accept_events
567 ngx_post_event(rev, queue);
/tldk/app/nginx/src/tldk/
H A Dbe.c307 queue_id = ctx->dev[i].queue;
323 "%s: rx queue=%u setup failed with error "
332 "%s: tx queue=%u setup failed with error "
862 __rte_unused uint16_t queue,
927 __rte_unused uint16_t queue,
977 __rte_unused uint16_t queue,
1027 cb = rte_eth_add_rx_callback(td->cf.port, td->cf.queue,
1057 __func__, i, tcx->dev[i].cf.port, tcx->dev[i].cf.queue);
1076 dev->cf.queue, pkt, RTE_DIM(pkt));
1082 dev->cf.queue,
861 type0_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, __rte_unused void *user_param) argument
926 type1_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, void *user_param) argument
976 typen_tcp_rx_callback(__rte_unused dpdk_port_t port, __rte_unused uint16_t queue, struct rte_mbuf *pkt[], uint16_t nb_pkts, __rte_unused uint16_t max_pkts, __rte_unused void *user_param) argument
[all...]
/tldk/app/nginx/src/http/v2/
H A Dngx_http_v2.h156 ngx_queue_t queue; member in struct:ngx_http_v2_node_s
186 ngx_queue_t queue; member in struct:ngx_http_v2_stream_s
/tldk/lib/libtle_l4p/
H A Dtle_event.h23 #include <sys/queue.h>
59 * event queue creation parameters.
63 uint32_t max_events; /**< max number of events in queue. */
67 * create event queue.
69 * Parameters used to create and initialise the queue.
71 * Pointer to new event queue structure,
80 * Destroy given event queue.
83 * event queue to destroy
88 * allocate a new event within given event queue.
90 * event queue t
[all...]

Completed in 19 milliseconds

12