Searched refs:nxt_atomic_cmp_set (Results 1 – 12 of 12) sorted by relevance
/unit/src/ |
H A D | nxt_atomic.h | 29 #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 D | nxt_nvbcq.h | 42 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 D | nxt_app_nncq.h | 41 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 D | nxt_nncq.h | 41 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 D | nxt_app_queue.h | 71 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 D | nxt_port_memory_int.h | 180 if (nxt_atomic_cmp_set(f, free_val, busy_val) != 0) { in nxt_port_mmap_chk_set_chunk_busy()
|
H A D | nxt_thread.c | 32 if (nxt_atomic_cmp_set(&tsd->key, -1, -2)) { in nxt_thread_init_data()
|
H A D | nxt_thread_pool.c | 214 } while (!nxt_atomic_cmp_set(&tp->threads, threads, threads + 1)); in nxt_thread_pool_wait()
|
H A D | nxt_thread_time.c | 388 if (nxt_atomic_cmp_set(&ts->slot, -1, -2)) { in nxt_thread_time_string_slot()
|
H A D | nxt_port_memory.c | 177 && nxt_atomic_cmp_set(&hdr->oosm, 1, 0)) in nxt_port_mmap_buf_completion()
|
H A D | nxt_unit.c | 4378 && nxt_atomic_cmp_set(&hdr->oosm, 1, 0)) in nxt_unit_mmap_release()
|
/unit/src/test/ |
H A D | nxt_cq_test.c | 147 if (nxt_atomic_cmp_set(&q->counter, c, c + 1)) { in cas_worker()
|