Home
last modified time | relevance | path

Searched refs:q (Results 1 – 20 of 20) sorted by relevance

/unit/src/
H A Dnxt_nncq.h27 return q->head; in nxt_nncq_head()
34 return q->tail; in nxt_nncq_tail()
91 q->head = NXT_NNCQ_SIZE; in nxt_nncq_init()
93 q->tail = NXT_NNCQ_SIZE; in nxt_nncq_init()
104 t = nxt_nncq_tail(q); in nxt_nncq_enqueue()
105 j = nxt_nncq_map(q, t); in nxt_nncq_enqueue()
106 e = q->entries[j]; in nxt_nncq_enqueue()
127 nxt_nncq_tail_cmp_inc(q, t); in nxt_nncq_enqueue()
138 h = nxt_nncq_head(q); in nxt_nncq_dequeue()
139 j = nxt_nncq_map(q, h); in nxt_nncq_dequeue()
[all …]
H A Dnxt_app_nncq.h27 return q->head; in nxt_app_nncq_head()
34 return q->tail; in nxt_app_nncq_tail()
93 q->head = NXT_APP_NNCQ_SIZE; in nxt_app_nncq_init()
94 nxt_memzero((void *) q->entries, in nxt_app_nncq_init()
96 q->tail = NXT_APP_NNCQ_SIZE; in nxt_app_nncq_init()
107 t = nxt_app_nncq_tail(q); in nxt_app_nncq_enqueue()
108 j = nxt_app_nncq_map(q, t); in nxt_app_nncq_enqueue()
109 e = q->entries[j]; in nxt_app_nncq_enqueue()
141 h = nxt_app_nncq_head(q); in nxt_app_nncq_dequeue()
142 j = nxt_app_nncq_map(q, h); in nxt_app_nncq_dequeue()
[all …]
H A Dnxt_nvbcq.h28 return q->head; in nxt_nvbcq_head()
35 return q->tail; in nxt_nvbcq_tail()
72 q->head = 0; in nxt_nvbcq_init()
78 q->tail = NXT_NVBCQ_SIZE; in nxt_nvbcq_init()
87 t = nxt_nvbcq_tail(q); in nxt_nvbcq_enqueue()
91 i = nxt_nvbcq_map(q, t); in nxt_nvbcq_enqueue()
101 h = nxt_nvbcq_head(q); in nxt_nvbcq_enqueue()
118 h = nxt_nvbcq_head(q); in nxt_nvbcq_dequeue()
122 i = nxt_nvbcq_map(q, h); in nxt_nvbcq_dequeue()
123 e = q->entries[i]; in nxt_nvbcq_dequeue()
[all …]
H A Dnxt_app_queue.h34 nxt_app_queue_init(nxt_app_queue_t volatile *q) in nxt_app_queue_init() argument
38 nxt_app_nncq_init(&q->free_items); in nxt_app_queue_init()
39 nxt_app_nncq_init(&q->queue); in nxt_app_queue_init()
42 nxt_app_nncq_enqueue(&q->free_items, i); in nxt_app_queue_init()
45 q->notified = 0; in nxt_app_queue_init()
57 i = nxt_app_nncq_dequeue(&q->free_items); in nxt_app_queue_send()
69 nxt_app_nncq_enqueue(&q->queue, i); in nxt_app_queue_send()
84 q->notified = 0; in nxt_app_queue_notification_received()
107 i = nxt_app_nncq_dequeue(&q->queue); in nxt_app_queue_recv()
108 if (i == nxt_app_nncq_empty(&q->queue)) { in nxt_app_queue_recv()
[all …]
H A Dnxt_port_queue.h38 nxt_nncq_init(&q->free_items); in nxt_port_queue_init()
39 nxt_nncq_init(&q->queue); in nxt_port_queue_init()
42 nxt_nncq_enqueue(&q->free_items, i); in nxt_port_queue_init()
45 q->nitems = 0; in nxt_port_queue_init()
56 i = nxt_nncq_dequeue(&q->free_items); in nxt_port_queue_send()
67 nxt_nncq_enqueue(&q->queue, i); in nxt_port_queue_send()
69 i = nxt_atomic_fetch_add(&q->nitems, 1); in nxt_port_queue_send()
84 i = nxt_nncq_dequeue(&q->queue); in nxt_port_queue_recv()
85 if (i == nxt_nncq_empty(&q->queue)) { in nxt_port_queue_recv()
94 nxt_nncq_enqueue(&q->free_items, i); in nxt_port_queue_recv()
[all …]
H A Dnxt_file_cache.c76 hkey.key_hash = nxt_murmur_hash2(q->key_data, q->key_len); in nxt_file_cache_query()
89 handler(q); in nxt_file_cache_query()
140 q->node = node; in nxt_file_cache_query_locked()
187 q->stale = 0; in nxt_cache_node_test()
189 node = q->node; in nxt_cache_node_test()
219 q->stale = 1; in nxt_cache_node_test()
243 q = data; in nxt_cache_wait_handler()
268 q = ev->data; in nxt_cache_timeout_handler()
270 q->state->timeout_handler(q); in nxt_cache_timeout_handler()
283 q = qw->query; in nxt_cache_wake_handler()
[all …]
H A Dnxt_cache.c139 lhq.key_hash = nxt_murmur_hash2(q->key_data, q->key_len); in nxt_cache_query()
171 if (q->hold) { in nxt_cache_query_locked()
186 q->node = node; in nxt_cache_query_locked()
194 q->stale = 1; in nxt_cache_query_locked()
246 q->node = node; in nxt_cache_node_hold()
270 qw->query = q; in nxt_cache_node_hold()
292 q->stale = 0; in nxt_cache_node_test()
294 node = q->node; in nxt_cache_node_test()
325 q->stale = 1; in nxt_cache_node_test()
387 q = qw->query; in nxt_cache_wake_handler()
[all …]
H A Dnxt_cache.h117 NXT_EXPORT void nxt_cache_query(nxt_cache_t *cache, nxt_cache_query_t *q);
118 NXT_EXPORT void nxt_cache_release(nxt_cache_t *cache, nxt_cache_query_t *q);
119 NXT_EXPORT nxt_int_t nxt_cache_update(nxt_cache_t *cache, nxt_cache_query_t *q);
H A Dnxt_lvlhsh.c459 nxt_lvlhsh_query_t q; in nxt_lvlhsh_convert_bucket_to_level() local
490 q.proto = proto; in nxt_lvlhsh_convert_bucket_to_level()
491 q.pool = lhq->pool; in nxt_lvlhsh_convert_bucket_to_level()
492 q.value = nxt_lvlhsh_entry_value(e); in nxt_lvlhsh_convert_bucket_to_level()
494 q.key_hash = key; in nxt_lvlhsh_convert_bucket_to_level()
496 ret = nxt_lvlhsh_level_convertion_insert(&q, &lvl, key >> shift, nlvl); in nxt_lvlhsh_convert_bucket_to_level()
/unit/src/test/
H A Dnxt_cq_test.c136 nxt_cq_t *q; in cas_worker() local
141 q = pgq; in cas_worker()
145 c = q->counter; in cas_worker()
157 nxt_cq_t *q; in faa_worker() local
161 q = pgq; in faa_worker()
174 nxt_cq_t *q; in enq_deq_worker() local
178 q = pgq; in enq_deq_worker()
210 q = pgq; in enq_worker()
231 q = pgq; in deq_worker()
252 q = pgq; in wenq_worker()
[all …]
/unit/pkg/docker/
H A Dtemplate.Dockerfile13 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.perl5.3413 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.minimal13 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.php8.113 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.python3.1013 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.jsc1113 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.ruby3.113 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
52 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.node1613 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
54 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
H A DDockerfile.go1.1813 && DEB_HOST_MULTIARCH="$(dpkg-architecture -q DEB_HOST_MULTIARCH)" \
54 mv /tmp/libunit.a /usr/lib/$(dpkg-architecture -q DEB_HOST_MULTIARCH)/libunit.a; \
/unit/pkg/rpm/
H A Dunit.spec.in80 %setup -q