/unit/src/ |
H A D | nxt_nncq.h | 27 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 D | nxt_app_nncq.h | 27 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 D | nxt_nvbcq.h | 28 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 D | nxt_app_queue.h | 34 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 D | nxt_port_queue.h | 38 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 D | nxt_file_cache.c | 76 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 D | nxt_cache.c | 139 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 D | nxt_cache.h | 117 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 D | nxt_lvlhsh.c | 459 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 D | nxt_cq_test.c | 136 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 D | template.Dockerfile | 13 && 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 D | Dockerfile.perl5.34 | 13 && 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 D | Dockerfile.minimal | 13 && 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 D | Dockerfile.php8.1 | 13 && 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 D | Dockerfile.python3.10 | 13 && 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 D | Dockerfile.jsc11 | 13 && 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 D | Dockerfile.ruby3.1 | 13 && 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 D | Dockerfile.node16 | 13 && 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 D | Dockerfile.go1.18 | 13 && 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 D | unit.spec.in | 80 %setup -q
|