Searched refs:mutex (Results 1 – 18 of 18) sorted by relevance
78 pthread_mutex_t mutex; member88 pthread_mutex_t mutex; member145 pthread_mutex_lock(&e->mutex); in _get_io_thread()158 pthread_mutex_unlock(&e->mutex); in _get_io_thread()179 pthread_mutex_lock(&e->mutex); in extstore_get_stats()502 pthread_mutex_lock(&e->mutex); in _allocate_wbuf()535 pthread_mutex_lock(&p->mutex); in _wbuf_cb()545 pthread_mutex_lock(&e->mutex); in _wbuf_cb()560 pthread_mutex_lock(&e->mutex); in _submit_wbuf()598 pthread_mutex_lock(&e->mutex); in extstore_write_request()[all …]
22 pthread_mutex_init(&ret->mutex, NULL) == -1) { in cache_create()42 pthread_mutex_lock(&cache->mutex); in cache_set_limit()44 pthread_mutex_unlock(&cache->mutex); in cache_set_limit()63 pthread_mutex_destroy(&cache->mutex); in cache_destroy()69 pthread_mutex_lock(&cache->mutex); in cache_alloc()71 pthread_mutex_unlock(&cache->mutex); in cache_alloc()109 pthread_mutex_lock(&cache->mutex); in cache_free()111 pthread_mutex_unlock(&cache->mutex); in cache_free()
195 pthread_mutex_lock(&t->stats.mutex); in proxy_storage_get()197 pthread_mutex_unlock(&t->stats.mutex); in proxy_storage_get()276 pthread_mutex_lock(&t->stats.mutex); in process_get_cmd()294 pthread_mutex_lock(&t->stats.mutex); in process_get_cmd()386 pthread_mutex_lock(&t->stats.mutex); in process_update_cmd()388 pthread_mutex_unlock(&t->stats.mutex); in process_update_cmd()449 pthread_mutex_lock(&t->stats.mutex); in process_arithmetic_cmd()487 pthread_mutex_lock(&t->stats.mutex); in process_delete_cmd()496 pthread_mutex_lock(&t->stats.mutex); in process_delete_cmd()1176 pthread_mutex_lock(&t->stats.mutex); in process_mset_cmd()[all …]
141 pthread_mutex_lock(&c->thread->stats.mutex); in complete_nread_ascii()143 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_nread_ascii()431 pthread_mutex_lock(&c->thread->stats.mutex); in try_read_command_asciiauth()433 pthread_mutex_unlock(&c->thread->stats.mutex); in try_read_command_asciiauth()436 pthread_mutex_lock(&c->thread->stats.mutex); in try_read_command_asciiauth()897 pthread_mutex_lock(&c->thread->stats.mutex); in process_meta_command()899 pthread_mutex_unlock(&c->thread->stats.mutex); in process_meta_command()1333 pthread_mutex_lock(&c->thread->stats.mutex); in process_mget_command()1345 pthread_mutex_lock(&c->thread->stats.mutex); in process_mget_command()2550 pthread_mutex_lock(&c->thread->stats.mutex); in process_flush_all_command()[all …]
364 pthread_mutex_lock(&c->thread->stats.mutex); in complete_update_bin()366 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_update_bin()490 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()498 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_get_or_touch()574 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()582 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_get_or_touch()840 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()856 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()1275 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_flush()1277 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_flush()[all …]
634 pthread_mutex_lock(&l->mutex); in logger_set_flags()636 pthread_mutex_unlock(&l->mutex); in logger_set_flags()729 pthread_mutex_lock(&l->mutex); in logger_thread_read()731 pthread_mutex_unlock(&l->mutex); in logger_thread_read()754 pthread_mutex_lock(&l->mutex); in logger_thread_read()760 pthread_mutex_unlock(&l->mutex); in logger_thread_read()1009 pthread_mutex_init(&l->mutex, NULL); in logger_create()1030 pthread_mutex_lock(&l->mutex); in logger_log()1035 pthread_mutex_unlock(&l->mutex); in logger_log()1064 pthread_mutex_unlock(&l->mutex); in logger_log()[all …]
44 #define WSTAT_L(t) pthread_mutex_lock(&t->stats.mutex);45 #define WSTAT_UL(t) pthread_mutex_unlock(&t->stats.mutex);47 pthread_mutex_lock(&t->stats.mutex); \49 pthread_mutex_unlock(&t->stats.mutex); \52 pthread_mutex_lock(&t->stats.mutex); \54 pthread_mutex_unlock(&t->stats.mutex); \467 pthread_mutex_t mutex; // covers stack. member
24 pthread_mutex_t mutex; member
88 pthread_mutex_t mutex; member1026 pthread_mutex_lock(&t->stats.mutex); in do_item_get()1308 pthread_mutex_init(&b->mutex, NULL); in item_lru_bump_buf_create()1317 pthread_mutex_lock(&b->mutex); in lru_bump_async()1333 pthread_mutex_unlock(&b->mutex); in lru_bump_async()1351 pthread_mutex_lock(&b->mutex); in lru_maintainer_bumps()1353 pthread_mutex_unlock(&b->mutex); in lru_maintainer_bumps()1370 pthread_mutex_lock(&b->mutex); in lru_maintainer_bumps()1372 pthread_mutex_unlock(&b->mutex); in lru_maintainer_bumps()1383 pthread_mutex_lock(&b->mutex); in lru_total_bumps_dropped()[all …]
513 pthread_mutex_lock(&c->thread->stats.mutex); in conn_close_idle()515 pthread_mutex_unlock(&c->thread->stats.mutex); in conn_close_idle()1712 pthread_mutex_lock(&t->stats.mutex); in do_store_item()1714 pthread_mutex_unlock(&t->stats.mutex); in do_store_item()2315 pthread_mutex_lock(&t->stats.mutex);2321 pthread_mutex_unlock(&t->stats.mutex);2429 pthread_mutex_lock(&c->thread->stats.mutex);2431 pthread_mutex_unlock(&c->thread->stats.mutex);2739 pthread_mutex_lock(&c->thread->stats.mutex);2741 pthread_mutex_unlock(&c->thread->stats.mutex);[all …]
377 pthread_mutex_lock(&c->thread->stats.mutex); in storage_get_item()379 pthread_mutex_unlock(&c->thread->stats.mutex); in storage_get_item()413 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()415 pthread_mutex_unlock(&c->thread->stats.mutex); in recache_or_free()422 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()426 pthread_mutex_unlock(&c->thread->stats.mutex); in recache_or_free()447 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()449 pthread_mutex_unlock(&c->thread->stats.mutex); in recache_or_free()
449 if (pthread_mutex_init(&me->stats.mutex, NULL) != 0) { in setup_thread()986 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_reset()1002 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_reset()1014 pthread_mutex_lock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()1042 pthread_mutex_unlock(&threads[ii].stats.mutex); in threadlocal_stats_aggregate()
186 pthread_mutex_t mutex; /* guard for this + *buf */ member
149 pthread_mutex_lock(&t->mutex); in _proxy_event_handler_dequeue()151 pthread_mutex_unlock(&t->mutex); in _proxy_event_handler_dequeue()270 pthread_mutex_lock(&t->mutex); in proxy_event_beconn()272 pthread_mutex_unlock(&t->mutex); in proxy_event_beconn()1478 pthread_mutex_init(&t->mutex, NULL); in proxy_init_event_thread()
369 pthread_mutex_t mutex; member1026 #define THR_STATS_LOCK(t) pthread_mutex_lock(&t->stats.mutex)1027 #define THR_STATS_UNLOCK(t) pthread_mutex_unlock(&t->stats.mutex)
694 pthread_mutex_lock(&thr->stats.mutex); in proxy_thread_loadconf()722 pthread_mutex_unlock(&thr->stats.mutex); in proxy_thread_loadconf()
263 pthread_mutex_lock(&e->mutex); in mcplib_backend_wrap_gc()265 pthread_mutex_unlock(&e->mutex); in mcplib_backend_wrap_gc()590 pthread_mutex_lock(&e->mutex); in _mcplib_make_backendconn()592 pthread_mutex_unlock(&e->mutex); in _mcplib_make_backendconn()
547 pthread_mutex_lock(&e->mutex); in proxy_submit_cb()553 pthread_mutex_unlock(&e->mutex); in proxy_submit_cb()