Lines Matching refs:it
1570 enum store_item_type do_store_item(item *it, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *… in do_store_item() argument
1571 char *key = ITEM_key(it); in do_store_item()
1572 item *old_it = do_item_get(key, it->nkey, hv, t, DONT_UPDATE); in do_store_item()
1586 uint64_t it_cas = ITEM_get_cas(it); in do_store_item()
1617 it->exptime = old_it->exptime; in do_store_item()
1618 it->it_flags |= ITEM_STALE; in do_store_item()
1620 it->it_flags |= ITEM_TOKEN_SENT; in do_store_item()
1636 (unsigned long long)ITEM_get_cas(it)); in do_store_item()
1658 …new_it = do_item_alloc(key, it->nkey, flags, old_it->exptime, it->nbytes + old_it->nbytes - 2 /* C… in do_store_item()
1664 if (_store_item_copy_data(comm, old_it, new_it, it) == -1) { in do_store_item()
1670 it = new_it; in do_store_item()
1674 *nbytes = it->nbytes; in do_store_item()
1686 item_replace(old_it, it, hv, cas_in); in do_store_item()
1697 if (ITEM_get_cas(it) != 0) { in do_store_item()
1724 do_item_link(it, hv, cas_in); in do_store_item()
1730 *cas = ITEM_get_cas(it); in do_store_item()
1733 stored, comm, ITEM_key(it), it->nkey, it->nbytes, it->exptime, in do_store_item()
1734 ITEM_clsid(it), t->cur_sfd); in do_store_item()
2220 item *it; in limited_get() local
2222 it = item_touch(key, nkey, exptime, t); in limited_get()
2224 it = item_get(key, nkey, t, do_update); in limited_get()
2226 if (it && it->refcount > IT_REFCOUNT_LIMIT) { in limited_get()
2227 item_remove(it); in limited_get()
2228 it = NULL; in limited_get()
2233 return it; in limited_get()
2241 item *it; in limited_get_locked() local
2242 it = item_get_locked(key, nkey, t, do_update, hv); in limited_get_locked()
2243 if (it && it->refcount > IT_REFCOUNT_LIMIT) { in limited_get_locked()
2244 do_item_remove(it); in limited_get_locked()
2245 it = NULL; in limited_get_locked()
2251 return it; in limited_get_locked()
2273 item *it; local
2275 it = do_item_get(key, nkey, hv, t, DONT_UPDATE);
2276 if (!it) {
2283 if (it->nbytes <= 2 || (it->it_flags & (ITEM_CHUNKED|ITEM_HDR)) != 0) {
2285 if (it->nbytes <= 2 || (it->it_flags & (ITEM_CHUNKED)) != 0) {
2287 do_item_remove(it);
2291 if (cas != NULL && *cas != 0 && ITEM_get_cas(it) != *cas) {
2292 do_item_remove(it);
2296 ptr = ITEM_data(it);
2299 do_item_remove(it);
2317 t->stats.slab_stats[ITEM_clsid(it)].incr_hits++;
2319 t->stats.slab_stats[ITEM_clsid(it)].decr_hits++;
2328 if (res + 2 <= it->nbytes && it->refcount == 2) { /* replace in-place */
2334 item_stats_sizes_remove(it);
2335 ITEM_set_cas(it, (settings.use_cas) ? get_cas_id() : 0);
2336 item_stats_sizes_add(it);
2337 memcpy(ITEM_data(it), buf, res);
2338 memset(ITEM_data(it) + res, ' ', it->nbytes - res - 2);
2339 do_item_update(it);
2340 } else if (it->refcount > 1) {
2343 FLAGS_CONV(it, flags);
2344 new_it = do_item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, res + 2);
2346 do_item_remove(it);
2351 item_replace(it, new_it, hv, (settings.use_cas) ? get_cas_id() : 0);
2354 ITEM_set_cas(it, (settings.use_cas) ? ITEM_get_cas(new_it) : 0);
2362 if (it->refcount == 1)
2363 do_item_remove(it);
2368 *cas = ITEM_get_cas(it); /* swap the incoming CAS value */
2371 *it_ret = it;
2373 do_item_remove(it); /* release our reference */