| /unit/src/ |
| H A D | nxt_atomic.h | 30 __sync_bool_compare_and_swap(lock, cmp, set)
34 __sync_lock_test_and_set(lock, set)
42 nxt_atomic_cmp_set(lock, 0, 1)
46 __sync_lock_release(lock)
80 atomic_add_swap(lock, set)
118 nxt_atomic_cmp_set(lock, 0, 1)
122 *lock = 0;
182 __fetch_and_swaplp(lock, set)
209 __fetch_and_swap(lock, set)
244 nxt_atomic_try_lock(nxt_atomic_t *lock) in nxt_atomic_try_lock() argument
[all …]
|
| H A D | nxt_spinlock.c | 63 nxt_thread_spin_lock(nxt_thread_spinlock_t *lock) in nxt_thread_spin_lock() argument
67 nxt_thread_log_debug("spin_lock(%p) enter", lock); in nxt_thread_spin_lock()
73 if (nxt_fast_path(nxt_atomic_try_lock(lock))) { in nxt_thread_spin_lock()
81 if (*lock == 0) { in nxt_thread_spin_lock()
92 nxt_thread_spin_trylock(nxt_thread_spinlock_t *lock) in nxt_thread_spin_trylock() argument
94 nxt_thread_log_debug("spin_trylock(%p) enter", lock); in nxt_thread_spin_trylock()
96 if (nxt_fast_path(nxt_atomic_try_lock(lock))) { in nxt_thread_spin_trylock()
100 nxt_thread_log_debug("spin_trylock(%p) failed", lock); in nxt_thread_spin_trylock()
107 nxt_thread_spin_unlock(nxt_thread_spinlock_t *lock) in nxt_thread_spin_unlock() argument
109 nxt_atomic_release(lock); in nxt_thread_spin_unlock()
[all …]
|
| H A D | nxt_spinlock.h | 14 NXT_EXPORT void nxt_thread_spin_lock(nxt_thread_spinlock_t *lock);
15 NXT_EXPORT nxt_bool_t nxt_thread_spin_trylock(nxt_thread_spinlock_t *lock);
16 NXT_EXPORT void nxt_thread_spin_unlock(nxt_thread_spinlock_t *lock);
|
| H A D | nxt_log_moderation.c | 28 nxt_thread_spin_lock(&mod->lock); in nxt_log_moderate_allow()
58 nxt_thread_spin_unlock(&mod->lock); in nxt_log_moderate_allow()
84 nxt_thread_spin_lock(&mod->lock); in nxt_log_moderate_timer_handler()
91 nxt_thread_spin_unlock(&mod->lock); in nxt_log_moderate_timer_handler()
|
| H A D | nxt_work_queue.c | 232 nxt_thread_spin_lock(&lwq->lock); in nxt_locked_work_queue_add()
243 nxt_thread_spin_unlock(&lwq->lock); in nxt_locked_work_queue_add()
258 nxt_thread_spin_lock(&lwq->lock); in nxt_locked_work_queue_pop()
280 nxt_thread_spin_unlock(&lwq->lock); in nxt_locked_work_queue_pop()
294 nxt_thread_spin_lock(&lwq->lock); in nxt_locked_work_queue_move()
301 nxt_thread_spin_unlock(&lwq->lock); in nxt_locked_work_queue_move()
|
| H A D | nxt_lib.c | 137 nxt_thread_spin_lock(&rt->lock); in nxt_lib_stop()
142 nxt_thread_spin_unlock(&rt->lock); in nxt_lib_stop()
|
| H A D | nxt_log_moderation.h | 15 nxt_thread_spinlock_t lock; member
|
| H A D | nxt_mem_zone.c | 73 nxt_thread_spinlock_t lock; member
478 nxt_thread_spin_lock(&zone->lock); in nxt_mem_zone_align()
486 nxt_thread_spin_lock(&zone->lock); in nxt_mem_zone_align()
491 nxt_thread_spin_unlock(&zone->lock); in nxt_mem_zone_align()
784 nxt_thread_spin_lock(&zone->lock); in nxt_mem_zone_free()
809 nxt_thread_spin_unlock(&zone->lock); in nxt_mem_zone_free()
|
| H A D | nxt_cache.h | 17 nxt_thread_spinlock_t lock; member
|
| H A D | nxt_work_queue.h | 78 nxt_thread_spinlock_t lock; member
|
| H A D | nxt_thread_pool.c | 74 nxt_thread_spin_lock(&tp->work_queue.lock); in nxt_thread_pool_init()
108 nxt_thread_spin_unlock(&tp->work_queue.lock); in nxt_thread_pool_init()
|
| H A D | nxt_router.c | 1195 nxt_thread_spinlock_t *lock; in nxt_router_conf_ready() local
1207 lock = &rtcf->router->lock; in nxt_router_conf_ready()
1209 nxt_thread_spin_lock(lock); in nxt_router_conf_ready()
3481 lock = &skcf->router_conf->router->lock; in nxt_router_listen_socket_create()
3483 nxt_thread_spin_lock(lock); in nxt_router_listen_socket_create()
3642 lock = &skcf->router_conf->router->lock; in nxt_router_listen_socket_release()
3644 nxt_thread_spin_lock(lock); in nxt_router_listen_socket_release()
3714 lock = &rtcf->router->lock; in nxt_router_conf_release()
3716 nxt_thread_spin_lock(lock); in nxt_router_conf_release()
3974 nxt_thread_spin_lock(lock); in nxt_router_access_log_use()
[all …]
|
| H A D | nxt_router.h | 31 nxt_thread_spinlock_t lock; member
|
| H A D | nxt_file_cache.c | 497 nxt_thread_spin_lock(&cache->lock); in nxt_file_cache_lock()
506 nxt_thread_spin_unlock(&cache->lock); in nxt_file_cache_unlock()
|
| H A D | nxt_cache.c | 115 nxt_thread_spin_lock(&cache->lock); in nxt_cache_lock()
124 nxt_thread_spin_unlock(&cache->lock); in nxt_cache_unlock()
|
| H A D | nxt_openssl.c | 247 nxt_thread_mutex_t *lock; in nxt_openssl_lock() local
249 lock = &nxt_openssl_locks[type]; in nxt_openssl_lock()
252 (void) nxt_thread_mutex_lock(lock); in nxt_openssl_lock()
255 (void) nxt_thread_mutex_unlock(lock); in nxt_openssl_lock()
|
| /unit/auto/ |
| H A D | threads | 86 pthread_spinlock_t lock;
88 if (pthread_spin_init(&lock, PTHREAD_PROCESS_PRIVATE) != 0)
90 if (pthread_spin_lock(&lock) != 0)
92 if (pthread_spin_unlock(&lock) != 0)
94 if (pthread_spin_destroy(&lock) != 0)
113 pthread_spinlock_t lock = 0;
116 if (pthread_spin_trylock(&lock) != 0)
118 if (pthread_spin_unlock(&lock) != 0)
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | AsyncChannelGroupUtil.java | 44 private static final Object lock = new Object(); field in AsyncChannelGroupUtil
53 synchronized (lock) { in register()
64 synchronized (lock) { in unregister()
|