Lines Matching refs:thread

294     switch(add_delta(c->thread, key, nkey, c->cmd == PROTOCOL_BINARY_CMD_INCREMENT,  in complete_incr_bin()
326 c->thread->cur_sfd = c->sfd; // for store_item logging. in complete_incr_bin()
328 …if (store_item(it, NREAD_ADD, c->thread, NULL, &cas, (settings.use_cas) ? get_cas_id() : 0, CAS_NO… in complete_incr_bin()
341 pthread_mutex_lock(&c->thread->stats.mutex); in complete_incr_bin()
343 c->thread->stats.incr_misses++; in complete_incr_bin()
345 c->thread->stats.decr_misses++; in complete_incr_bin()
347 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_incr_bin()
364 pthread_mutex_lock(&c->thread->stats.mutex); in complete_update_bin()
365 c->thread->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in complete_update_bin()
366 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_update_bin()
385 c->thread->cur_sfd = c->sfd; // for store_item logging. in complete_update_bin()
386 …ret = store_item(it, c->cmd, c->thread, NULL, &cas, (settings.use_cas) ? get_cas_id() : 0, CAS_NO_… in complete_update_bin()
480 it = item_touch(key, nkey, realtime(exptime), c->thread); in process_bin_get_or_touch()
482 it = item_get(key, nkey, c->thread, DO_UPDATE); in process_bin_get_or_touch()
490 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()
492 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
493 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_bin_get_or_touch()
495 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
496 c->thread->stats.lru_hits[it->slabs_clsid]++; in process_bin_get_or_touch()
498 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_get_or_touch()
532 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_get_or_touch()
533 c->thread->stats.get_oom_extstore++; in process_bin_get_or_touch()
534 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()
576 c->thread->stats.touch_cmds++; in process_bin_get_or_touch()
577 c->thread->stats.touch_misses++; in process_bin_get_or_touch()
579 c->thread->stats.get_cmds++; in process_bin_get_or_touch()
580 c->thread->stats.get_misses++; 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()
841 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
842 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
856 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
857 c->thread->stats.auth_cmds++; in process_bin_complete_sasl_auth()
858 c->thread->stats.auth_errors++; in process_bin_complete_sasl_auth()
859 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_complete_sasl_auth()
892 c->thread->cur_sfd = c->sfd; // cuddle sfd for logging. in dispatch_bin_command()
1134 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_bin_update()
1141 it = item_get(key, nkey, c->thread, DONT_UPDATE); in process_bin_update()
1144 STORAGE_delete(c->thread->storage, it); in process_bin_update()
1275 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_flush()
1276 c->thread->stats.flush_cmds++; in process_bin_flush()
1277 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_flush()
1303 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_bin_delete()
1308 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_delete()
1309 c->thread->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_bin_delete()
1310 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_delete()
1312 STORAGE_delete(c->thread->storage, it); in process_bin_delete()
1320 pthread_mutex_lock(&c->thread->stats.mutex); in process_bin_delete()
1321 c->thread->stats.delete_misses++; in process_bin_delete()
1322 pthread_mutex_unlock(&c->thread->stats.mutex); in process_bin_delete()