Searched refs:waiting (Results 1 – 7 of 7) sorted by relevance
170 nxt_atomic_uint_t waiting, threads; in nxt_thread_pool_wait() local178 (void) nxt_atomic_fetch_add(&tp->waiting, 1); in nxt_thread_pool_wait()184 waiting = nxt_atomic_fetch_add(&tp->waiting, -1); in nxt_thread_pool_wait()194 (void) nxt_atomic_fetch_add(&tp->waiting, -1); in nxt_thread_pool_wait()201 nxt_log_debug(thr->log, "thread pool awake, waiting: %A", waiting); in nxt_thread_pool_wait()203 if (waiting > 1) { in nxt_thread_pool_wait()
16 nxt_atomic_t waiting; member
163 qw->next = node->waiting; in nxt_file_cache_query_locked()171 node->waiting = qw; in nxt_file_cache_query_locked()292 qw->next = q->node->waiting; in nxt_cache_wake_handler()293 q->node->waiting = qw; in nxt_cache_wake_handler()
271 qw->next = node->waiting; in nxt_cache_node_hold()279 node->waiting = qw; in nxt_cache_node_hold()399 qw->next = q->node->waiting; in nxt_cache_wake_handler()400 q->node->waiting = qw; in nxt_cache_wake_handler()
60 nxt_cache_query_wait_t *waiting; member
42 nxt_uint_t waiting; member531 if (query->waiting == 0) { in nxt_var_query_resolve()543 if (--query->waiting == 0) { in nxt_var_query_handle()
37 futureToSendHandler.timeout=Operation timed out after waiting [{0}] [{1}] to complete95 wsRemoteEndpoint.sendInterrupt=The current thread was interrupted while waiting for a blocking send…