Lines Matching refs:thread
141 pthread_mutex_lock(&c->thread->stats.mutex); in complete_nread_ascii()
142 c->thread->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in complete_nread_ascii()
143 pthread_mutex_unlock(&c->thread->stats.mutex); in complete_nread_ascii()
181 c->thread->cur_sfd = c->sfd; // cuddle sfd for logging. in complete_nread_ascii()
182 …ret = store_item(it, comm, c->thread, &nbytes, &cas, c->cas ? c->cas : get_cas_id(), c->set_stale); in complete_nread_ascii()
431 pthread_mutex_lock(&c->thread->stats.mutex); in try_read_command_asciiauth()
432 c->thread->stats.auth_cmds++; 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()
437 c->thread->stats.auth_cmds++; in try_read_command_asciiauth()
438 c->thread->stats.auth_errors++; in try_read_command_asciiauth()
439 pthread_mutex_unlock(&c->thread->stats.mutex); in try_read_command_asciiauth()
579 it = limited_get(key, nkey, c->thread, exptime, should_touch, DO_UPDATE, &overflow); in process_get_command()
607 pthread_mutex_lock(&c->thread->stats.mutex); in process_get_command()
608 c->thread->stats.get_oom_extstore++; in process_get_command()
609 pthread_mutex_unlock(&c->thread->stats.mutex); in process_get_command()
638 pthread_mutex_lock(&c->thread->stats.mutex); in process_get_command()
640 c->thread->stats.touch_cmds++; in process_get_command()
641 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_get_command()
643 c->thread->stats.lru_hits[it->slabs_clsid]++; in process_get_command()
644 c->thread->stats.get_cmds++; in process_get_command()
646 pthread_mutex_unlock(&c->thread->stats.mutex); in process_get_command()
656 pthread_mutex_lock(&c->thread->stats.mutex); in process_get_command()
658 c->thread->stats.touch_cmds++; in process_get_command()
659 c->thread->stats.touch_misses++; in process_get_command()
661 c->thread->stats.get_misses++; in process_get_command()
662 c->thread->stats.get_cmds++; in process_get_command()
665 pthread_mutex_unlock(&c->thread->stats.mutex); in process_get_command()
861 item *it = limited_get(key, nkey, c->thread, 0, false, DONT_UPDATE, &overflow); in process_meta_command()
897 pthread_mutex_lock(&c->thread->stats.mutex); in process_meta_command()
898 c->thread->stats.meta_cmds++; in process_meta_command()
899 pthread_mutex_unlock(&c->thread->stats.mutex); in process_meta_command()
1124 it = limited_get(key, nkey, c->thread, 0, false, !of.no_update, &overflow); in process_mget_command()
1127 it = limited_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv, &overflow); in process_mget_command()
1278 pthread_mutex_lock(&c->thread->stats.mutex); in process_mget_command()
1279 c->thread->stats.get_oom_extstore++; in process_mget_command()
1280 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mget_command()
1325 do_item_bump(c->thread, it, hv); in process_mget_command()
1333 pthread_mutex_lock(&c->thread->stats.mutex); in process_mget_command()
1335 c->thread->stats.touch_cmds++; in process_mget_command()
1336 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_mget_command()
1338 c->thread->stats.lru_hits[it->slabs_clsid]++; in process_mget_command()
1339 c->thread->stats.get_cmds++; in process_mget_command()
1341 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mget_command()
1345 pthread_mutex_lock(&c->thread->stats.mutex); in process_mget_command()
1347 c->thread->stats.touch_cmds++; in process_mget_command()
1348 c->thread->stats.touch_misses++; in process_mget_command()
1350 c->thread->stats.get_misses++; in process_mget_command()
1351 c->thread->stats.get_cmds++; in process_mget_command()
1354 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mget_command()
1544 pthread_mutex_lock(&c->thread->stats.mutex); in process_mset_command()
1545 c->thread->stats.store_too_large++; in process_mset_command()
1546 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mset_command()
1550 pthread_mutex_lock(&c->thread->stats.mutex); in process_mset_command()
1551 c->thread->stats.store_no_memory++; in process_mset_command()
1552 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mset_command()
1555 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_mset_command()
1560 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_mset_command()
1563 STORAGE_delete(c->thread->storage, it); in process_mset_command()
1667 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_mdelete_command()
1673 pthread_mutex_lock(&c->thread->stats.mutex); in process_mdelete_command()
1674 c->thread->stats.delete_misses++; in process_mdelete_command()
1675 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mdelete_command()
1686 if (do_store_item(new_it, NREAD_SET, c->thread, hv, NULL, NULL, in process_mdelete_command()
1719 pthread_mutex_lock(&c->thread->stats.mutex); in process_mdelete_command()
1720 c->thread->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_mdelete_command()
1721 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mdelete_command()
1726 STORAGE_delete(c->thread->storage, it); in process_mdelete_command()
1734 pthread_mutex_lock(&c->thread->stats.mutex); in process_mdelete_command()
1735 c->thread->stats.delete_misses++; in process_mdelete_command()
1736 pthread_mutex_unlock(&c->thread->stats.mutex); in process_mdelete_command()
1834 switch(do_add_delta(c->thread, key, nkey, incr, of.delta, tmpbuf, &of.req_cas_id, hv, &it)) { in process_marithmetic_command()
1862 if (do_store_item(it, NREAD_ADD, c->thread, hv, NULL, NULL, in process_marithmetic_command()
1874 pthread_mutex_lock(&c->thread->stats.mutex); in process_marithmetic_command()
1876 c->thread->stats.incr_misses++; in process_marithmetic_command()
1878 c->thread->stats.decr_misses++; in process_marithmetic_command()
1880 pthread_mutex_unlock(&c->thread->stats.mutex); in process_marithmetic_command()
2049 pthread_mutex_lock(&c->thread->stats.mutex); in process_update_command()
2050 c->thread->stats.store_too_large++; in process_update_command()
2051 pthread_mutex_unlock(&c->thread->stats.mutex); in process_update_command()
2055 pthread_mutex_lock(&c->thread->stats.mutex); in process_update_command()
2056 c->thread->stats.store_no_memory++; in process_update_command()
2057 pthread_mutex_unlock(&c->thread->stats.mutex); in process_update_command()
2059 LOGGER_LOG(c->thread->l, LOG_MUTATIONS, LOGGER_ITEM_STORE, in process_update_command()
2068 it = item_get(key, nkey, c->thread, DONT_UPDATE); in process_update_command()
2071 STORAGE_delete(c->thread->storage, it); in process_update_command()
2120 it = item_touch(key, nkey, exptime, c->thread); in process_touch_command()
2122 pthread_mutex_lock(&c->thread->stats.mutex); in process_touch_command()
2123 c->thread->stats.touch_cmds++; in process_touch_command()
2124 c->thread->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_touch_command()
2125 pthread_mutex_unlock(&c->thread->stats.mutex); in process_touch_command()
2130 pthread_mutex_lock(&c->thread->stats.mutex); in process_touch_command()
2131 c->thread->stats.touch_cmds++; in process_touch_command()
2132 c->thread->stats.touch_misses++; in process_touch_command()
2133 pthread_mutex_unlock(&c->thread->stats.mutex); in process_touch_command()
2162 switch(add_delta(c->thread, key, nkey, incr, delta, temp, NULL)) { in process_arithmetic_command()
2173 pthread_mutex_lock(&c->thread->stats.mutex); in process_arithmetic_command()
2175 c->thread->stats.incr_misses++; in process_arithmetic_command()
2177 c->thread->stats.decr_misses++; in process_arithmetic_command()
2179 pthread_mutex_unlock(&c->thread->stats.mutex); in process_arithmetic_command()
2222 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_delete_command()
2226 pthread_mutex_lock(&c->thread->stats.mutex); in process_delete_command()
2227 c->thread->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_delete_command()
2228 pthread_mutex_unlock(&c->thread->stats.mutex); in process_delete_command()
2231 STORAGE_delete(c->thread->storage, it); in process_delete_command()
2235 pthread_mutex_lock(&c->thread->stats.mutex); in process_delete_command()
2236 c->thread->stats.delete_misses++; in process_delete_command()
2237 pthread_mutex_unlock(&c->thread->stats.mutex); in process_delete_command()
2550 pthread_mutex_lock(&c->thread->stats.mutex); in process_flush_all_command()
2551 c->thread->stats.flush_cmds++; in process_flush_all_command()
2552 pthread_mutex_unlock(&c->thread->stats.mutex); in process_flush_all_command()
2847 c->thread->cur_sfd = c->sfd; // cuddle sfd for logging. in process_command_ascii()