Home
last modified time | relevance | path

Searched refs:waiting (Results 1 – 8 of 8) sorted by relevance

/unit/src/
H A Dnxt_thread_pool.c170 nxt_atomic_uint_t waiting, threads; in nxt_thread_pool_wait() local
178 (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()
H A Dnxt_thread_pool.h16 nxt_atomic_t waiting; member
H A Dnxt_tstr.c39 nxt_uint_t waiting; member
298 if (query->waiting == 0) { in nxt_tstr_query_resolve()
312 if (--query->waiting == 0) { in nxt_tstr_query_handle()
H A Dnxt_file_cache.c163 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()
H A Dnxt_cache.c271 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()
H A Dnxt_cache.h60 nxt_cache_query_wait_t *waiting; member
H A Dnxt_var.c33 nxt_uint_t waiting; member
/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties37 futureToSendHandler.timeout=Operation timed out after waiting [{0}] [{1}] to complete
95 wsRemoteEndpoint.sendInterrupt=The current thread was interrupted while waiting for a blocking send…