Home
last modified time | relevance | path

Searched refs:nxt_atomic_cmp_set (Results 1 – 12 of 12) sorted by relevance

/unit/src/
H A Dnxt_atomic.h29 #define nxt_atomic_cmp_set(lock, cmp, set) \ macro
42 nxt_atomic_cmp_set(lock, 0, 1)
79 #define nxt_atomic_cmp_set(lock, cmp, set) \ macro
122 nxt_atomic_cmp_set(lock, 0, 1)
174 nxt_atomic_cmp_set(nxt_atomic_t *lock, nxt_atomic_int_t cmp, in nxt_atomic_cmp_set() function
201 nxt_atomic_cmp_set(nxt_atomic_t *lock, nxt_atomic_int_t cmp, in nxt_atomic_cmp_set() function
250 if (nxt_atomic_cmp_set(lock, 0, 1)) { in nxt_atomic_try_lock()
H A Dnxt_nvbcq.h42 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_nvbcq_tail_cmp_inc()
94 && nxt_atomic_cmp_set(&q->entries[i], NXT_NVBCQ_SIZE, val)) in nxt_nvbcq_enqueue()
126 && nxt_atomic_cmp_set(&q->entries[i], e, NXT_NVBCQ_SIZE)) in nxt_nvbcq_dequeue()
128 nxt_atomic_cmp_set(&q->head, h, h + 1); in nxt_nvbcq_dequeue()
H A Dnxt_app_nncq.h41 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_app_nncq_tail_cmp_inc()
125 if (nxt_atomic_cmp_set(&q->entries[j], e, n)) { in nxt_app_nncq_enqueue()
156 if (nxt_atomic_cmp_set(&q->head, h, h + 1)) { in nxt_app_nncq_dequeue()
H A Dnxt_nncq.h41 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_nncq_tail_cmp_inc()
122 if (nxt_atomic_cmp_set(&q->entries[j], e, n)) { in nxt_nncq_enqueue()
153 if (nxt_atomic_cmp_set(&q->head, h, h + 1)) { in nxt_nncq_dequeue()
H A Dnxt_app_queue.h71 n = nxt_atomic_cmp_set(&q->notified, 0, 1); in nxt_app_queue_send()
96 return nxt_atomic_cmp_set(&qi->tracking, tracking, 0); in nxt_app_queue_cancel()
H A Dnxt_port_memory_int.h180 if (nxt_atomic_cmp_set(f, free_val, busy_val) != 0) { in nxt_port_mmap_chk_set_chunk_busy()
H A Dnxt_thread.c32 if (nxt_atomic_cmp_set(&tsd->key, -1, -2)) { in nxt_thread_init_data()
H A Dnxt_thread_pool.c214 } while (!nxt_atomic_cmp_set(&tp->threads, threads, threads + 1)); in nxt_thread_pool_wait()
H A Dnxt_thread_time.c388 if (nxt_atomic_cmp_set(&ts->slot, -1, -2)) { in nxt_thread_time_string_slot()
H A Dnxt_port_memory.c177 && nxt_atomic_cmp_set(&hdr->oosm, 1, 0)) in nxt_port_mmap_buf_completion()
H A Dnxt_unit.c4378 && nxt_atomic_cmp_set(&hdr->oosm, 1, 0)) in nxt_unit_mmap_release()
/unit/src/test/
H A Dnxt_cq_test.c147 if (nxt_atomic_cmp_set(&q->counter, c, c + 1)) { in cas_worker()