Lines Matching refs:t
140 static int proxy_storage_get(LIBEVENT_THREAD *t, item *it, mc_resp *resp, in proxy_storage_get() argument
150 io_pending_proxy_t *io = do_cache_alloc(t->io_cache); in proxy_storage_get()
161 io->thread = t; in proxy_storage_get()
168 do_cache_free(t->io_cache, io); in proxy_storage_get()
195 pthread_mutex_lock(&t->stats.mutex); in proxy_storage_get()
196 t->stats.get_extstore++; in proxy_storage_get()
197 pthread_mutex_unlock(&t->stats.mutex); in proxy_storage_get()
228 static void process_get_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, bool return_cas, b… in process_get_cmd() argument
239 item *it = limited_get(key, nkey, t, exptime, should_touch, DO_UPDATE, &overflow); in process_get_cmd()
253 if (proxy_storage_get(t, it, resp, PROXY_STORAGE_GET) != 0) { in process_get_cmd()
254 pthread_mutex_lock(&t->stats.mutex); in process_get_cmd()
255 t->stats.get_oom_extstore++; in process_get_cmd()
256 pthread_mutex_unlock(&t->stats.mutex); in process_get_cmd()
276 pthread_mutex_lock(&t->stats.mutex); in process_get_cmd()
278 t->stats.touch_cmds++; in process_get_cmd()
279 t->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_get_cmd()
281 t->stats.lru_hits[it->slabs_clsid]++; in process_get_cmd()
282 t->stats.get_cmds++; in process_get_cmd()
284 pthread_mutex_unlock(&t->stats.mutex); in process_get_cmd()
294 pthread_mutex_lock(&t->stats.mutex); in process_get_cmd()
296 t->stats.touch_cmds++; in process_get_cmd()
297 t->stats.touch_misses++; in process_get_cmd()
299 t->stats.get_misses++; in process_get_cmd()
300 t->stats.get_cmds++; in process_get_cmd()
302 pthread_mutex_unlock(&t->stats.mutex); in process_get_cmd()
309 static void process_update_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, int comm, bool … in process_update_cmd() argument
358 pthread_mutex_lock(&t->stats.mutex); in process_update_cmd()
359 t->stats.store_too_large++; in process_update_cmd()
360 pthread_mutex_unlock(&t->stats.mutex); in process_update_cmd()
364 pthread_mutex_lock(&t->stats.mutex); in process_update_cmd()
365 t->stats.store_no_memory++; in process_update_cmd()
366 pthread_mutex_unlock(&t->stats.mutex); in process_update_cmd()
374 it = item_get(key, nkey, t, DONT_UPDATE); in process_update_cmd()
377 STORAGE_delete(t->storage, it); in process_update_cmd()
386 pthread_mutex_lock(&t->stats.mutex); in process_update_cmd()
387 t->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in process_update_cmd()
388 pthread_mutex_unlock(&t->stats.mutex); in process_update_cmd()
398 …int ret = store_item(it, comm, t, NULL, NULL, (settings.use_cas) ? get_cas_id() : 0, CAS_NO_STALE); in process_update_cmd()
420 static void process_arithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp, const bool … in process_arithmetic_cmd() argument
426 assert(t != NULL); in process_arithmetic_cmd()
438 switch(add_delta(t, key, nkey, incr, delta, temp, NULL)) { in process_arithmetic_cmd()
449 pthread_mutex_lock(&t->stats.mutex); in process_arithmetic_cmd()
451 t->stats.incr_misses++; in process_arithmetic_cmd()
453 t->stats.decr_misses++; in process_arithmetic_cmd()
455 pthread_mutex_unlock(&t->stats.mutex); in process_arithmetic_cmd()
464 static void process_delete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_delete_cmd() argument
470 assert(t != NULL); in process_delete_cmd()
483 it = item_get_locked(key, nkey, t, DONT_UPDATE, &hv); in process_delete_cmd()
487 pthread_mutex_lock(&t->stats.mutex); in process_delete_cmd()
488 t->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_delete_cmd()
489 pthread_mutex_unlock(&t->stats.mutex); in process_delete_cmd()
492 STORAGE_delete(t->storage, it); in process_delete_cmd()
496 pthread_mutex_lock(&t->stats.mutex); in process_delete_cmd()
497 t->stats.delete_misses++; in process_delete_cmd()
498 pthread_mutex_unlock(&t->stats.mutex); in process_delete_cmd()
505 static void process_touch_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_touch_cmd() argument
512 assert(t != NULL); in process_touch_cmd()
525 it = item_touch(key, nkey, exptime, t); in process_touch_cmd()
527 pthread_mutex_lock(&t->stats.mutex); in process_touch_cmd()
528 t->stats.touch_cmds++; in process_touch_cmd()
529 t->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_touch_cmd()
530 pthread_mutex_unlock(&t->stats.mutex); in process_touch_cmd()
535 pthread_mutex_lock(&t->stats.mutex); in process_touch_cmd()
536 t->stats.touch_cmds++; in process_touch_cmd()
537 t->stats.touch_misses++; in process_touch_cmd()
538 pthread_mutex_unlock(&t->stats.mutex); in process_touch_cmd()
747 static void process_mget_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mget_cmd() argument
759 assert(t != NULL); in process_mget_cmd()
786 it = limited_get(key, nkey, t, 0, false, !of.no_update, &overflow); in process_mget_cmd()
789 it = limited_get_locked(key, nkey, t, DONT_UPDATE, &hv, &overflow); in process_mget_cmd()
940 if (proxy_storage_get(t, it, resp, PROXY_STORAGE_MG) != 0) { in process_mget_cmd()
941 pthread_mutex_lock(&t->stats.mutex); in process_mget_cmd()
942 t->stats.get_oom_extstore++; in process_mget_cmd()
943 pthread_mutex_unlock(&t->stats.mutex); in process_mget_cmd()
988 do_item_bump(t, it, hv); in process_mget_cmd()
996 pthread_mutex_lock(&t->stats.mutex); in process_mget_cmd()
998 t->stats.touch_cmds++; in process_mget_cmd()
999 t->stats.slab_stats[ITEM_clsid(it)].touch_hits++; in process_mget_cmd()
1001 t->stats.lru_hits[it->slabs_clsid]++; in process_mget_cmd()
1002 t->stats.get_cmds++; in process_mget_cmd()
1004 pthread_mutex_unlock(&t->stats.mutex); in process_mget_cmd()
1006 pthread_mutex_lock(&t->stats.mutex); in process_mget_cmd()
1008 t->stats.touch_cmds++; in process_mget_cmd()
1009 t->stats.touch_misses++; in process_mget_cmd()
1011 t->stats.get_misses++; in process_mget_cmd()
1012 t->stats.get_cmds++; in process_mget_cmd()
1014 pthread_mutex_unlock(&t->stats.mutex); in process_mget_cmd()
1055 static void process_mset_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mset_cmd() argument
1066 assert(t != NULL); in process_mset_cmd()
1139 pthread_mutex_lock(&t->stats.mutex); in process_mset_cmd()
1140 t->stats.store_too_large++; in process_mset_cmd()
1141 pthread_mutex_unlock(&t->stats.mutex); in process_mset_cmd()
1144 pthread_mutex_lock(&t->stats.mutex); in process_mset_cmd()
1145 t->stats.store_no_memory++; in process_mset_cmd()
1146 pthread_mutex_unlock(&t->stats.mutex); in process_mset_cmd()
1151 it = item_get_locked(key, nkey, t, DONT_UPDATE, &hv); in process_mset_cmd()
1154 STORAGE_delete(t->storage, it); in process_mset_cmd()
1176 pthread_mutex_lock(&t->stats.mutex); in process_mset_cmd()
1177 t->stats.slab_stats[ITEM_clsid(it)].set_cmds++; in process_mset_cmd()
1178 pthread_mutex_unlock(&t->stats.mutex); in process_mset_cmd()
1190 …int ret = store_item(it, comm, t, &nbytes, &cas, of.has_cas_in ? of.cas_id_in : get_cas_id(), set_… in process_mset_cmd()
1265 static void process_mdelete_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_mdelete_cmd() argument
1273 assert(t != NULL); in process_mdelete_cmd()
1318 it = item_get_locked(key, nkey, t, DONT_UPDATE, &hv); in process_mdelete_cmd()
1322 pthread_mutex_lock(&t->stats.mutex); in process_mdelete_cmd()
1323 t->stats.delete_misses++; in process_mdelete_cmd()
1324 pthread_mutex_unlock(&t->stats.mutex); in process_mdelete_cmd()
1335 if (do_store_item(new_it, NREAD_SET, t, hv, NULL, NULL, in process_mdelete_cmd()
1367 pthread_mutex_lock(&t->stats.mutex); in process_mdelete_cmd()
1368 t->stats.slab_stats[ITEM_clsid(it)].delete_hits++; in process_mdelete_cmd()
1369 pthread_mutex_unlock(&t->stats.mutex); in process_mdelete_cmd()
1374 STORAGE_delete(t->storage, it); in process_mdelete_cmd()
1382 pthread_mutex_lock(&t->stats.mutex); in process_mdelete_cmd()
1383 t->stats.delete_misses++; in process_mdelete_cmd()
1384 pthread_mutex_unlock(&t->stats.mutex); in process_mdelete_cmd()
1410 static void process_marithmetic_cmd(LIBEVENT_THREAD *t, mcp_parser_t *pr, mc_resp *resp) { in process_marithmetic_cmd() argument
1416 assert(t != NULL); in process_marithmetic_cmd()
1479 switch(do_add_delta(t, key, nkey, incr, of.delta, tmpbuf, &of.req_cas_id, hv, &it)) { in process_marithmetic_cmd()
1508 if (do_store_item(it, NREAD_ADD, t, hv, NULL, &cas, in process_marithmetic_cmd()
1520 pthread_mutex_lock(&t->stats.mutex); in process_marithmetic_cmd()
1522 t->stats.incr_misses++; in process_marithmetic_cmd()
1524 t->stats.decr_misses++; in process_marithmetic_cmd()
1526 pthread_mutex_unlock(&t->stats.mutex); in process_marithmetic_cmd()
1658 LIBEVENT_THREAD *t = rctx->c->thread; in mcplib_internal_run() local
1667 process_mget_cmd(t, pr, resp); in mcplib_internal_run()
1670 process_mset_cmd(t, pr, resp); in mcplib_internal_run()
1673 process_mdelete_cmd(t, pr, resp); in mcplib_internal_run()
1676 process_marithmetic_cmd(t, pr, resp); in mcplib_internal_run()
1679 process_get_cmd(t, pr, resp, _NO_CAS, _NO_TOUCH); in mcplib_internal_run()
1682 process_get_cmd(t, pr, resp, _DO_CAS, _NO_TOUCH); in mcplib_internal_run()
1685 process_get_cmd(t, pr, resp, _NO_CAS, _DO_TOUCH); in mcplib_internal_run()
1688 process_get_cmd(t, pr, resp, _DO_CAS, _DO_TOUCH); in mcplib_internal_run()
1691 process_update_cmd(t, pr, resp, NREAD_SET, _NO_CAS); in mcplib_internal_run()
1694 process_update_cmd(t, pr, resp, NREAD_ADD, _NO_CAS); in mcplib_internal_run()
1697 process_update_cmd(t, pr, resp, NREAD_APPEND, _NO_CAS); in mcplib_internal_run()
1700 process_update_cmd(t, pr, resp, NREAD_PREPEND, _NO_CAS); in mcplib_internal_run()
1703 process_update_cmd(t, pr, resp, NREAD_CAS, _DO_CAS); in mcplib_internal_run()
1706 process_update_cmd(t, pr, resp, NREAD_REPLACE, _DO_CAS); in mcplib_internal_run()
1709 process_arithmetic_cmd(t, pr, resp, true); in mcplib_internal_run()
1712 process_arithmetic_cmd(t, pr, resp, false); in mcplib_internal_run()
1715 process_delete_cmd(t, pr, resp); in mcplib_internal_run()
1718 process_touch_cmd(t, pr, resp); in mcplib_internal_run()
1721 resp_free(t, resp); in mcplib_internal_run()
1748 r->thread = t; in mcplib_internal_run()
1756 t->proxy_vm_extra_kb++; in mcplib_internal_run()