Lines Matching refs:c
34 conn *c; member
77 void process_extstore_stats(ADD_STAT add_stats, void *c) { in process_extstore_stats() argument
109 void storage_stats(ADD_STAT add_stats, void *c) { in storage_stats() argument
148 conn *c = p->c; in _storage_get_item_cb() local
189 if (c->protocol == binary_prot) { in _storage_get_item_cb()
249 int storage_get_item(conn *c, item *it, mc_resp *resp) { in storage_get_item() argument
256 io_queue_t *q = conn_io_queue_get(c, IO_QUEUE_EXTSTORE); in storage_get_item()
276 io_pending_storage_t *p = do_cache_alloc(c->thread->io_cache); in storage_get_item()
283 p->noreply = c->noreply; in storage_get_item()
284 p->thread = c->thread; in storage_get_item()
305 do_cache_free(c->thread->io_cache, p); in storage_get_item()
322 do_cache_free(c->thread->io_cache, p); in storage_get_item()
337 int iovtotal = (c->protocol == binary_prot) ? it->nbytes - 2 : it->nbytes; in storage_get_item()
348 p->c = c; in storage_get_item()
377 pthread_mutex_lock(&c->thread->stats.mutex); in storage_get_item()
378 c->thread->stats.get_extstore++; in storage_get_item()
379 pthread_mutex_unlock(&c->thread->stats.mutex); in storage_get_item()
397 conn *c = p->c; in recache_or_free() local
401 assert(c != NULL); in recache_or_free()
410 io_queue_t *q = conn_io_queue_get(c, p->io_queue_type); in recache_or_free()
413 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()
414 c->thread->stats.get_aborted_extstore++; 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()
423 c->thread->stats.miss_from_extstore++; in recache_or_free()
425 c->thread->stats.badcrc_from_extstore++; in recache_or_free()
426 pthread_mutex_unlock(&c->thread->stats.mutex); in recache_or_free()
438 c->recache_counter++ % settings.ext_recache_rate == 0) { in recache_or_free()
445 STORAGE_delete(c->thread->storage, h_it); in recache_or_free()
447 pthread_mutex_lock(&c->thread->stats.mutex); in recache_or_free()
448 c->thread->stats.recache_from_extstore++; in recache_or_free()
449 pthread_mutex_unlock(&c->thread->stats.mutex); in recache_or_free()
468 io_queue_t *q = conn_io_queue_get(pending->c, pending->io_queue_type); in storage_return_cb()
471 conn_worker_readd(pending->c); in storage_return_cb()