Lines Matching refs:nkey
1054 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1058 MEMCACHED_COMMAND_REPLACE(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1062 MEMCACHED_COMMAND_APPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1066 MEMCACHED_COMMAND_PREPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1070 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
1074 MEMCACHED_COMMAND_CAS(c->sfd, ITEM_key(it), it->nkey, it->nbytes, in complete_nread_ascii()
1248 size_t nkey; in complete_incr_bin() local
1264 nkey = c->binary_header.request.keylen; in complete_incr_bin()
1270 for (i = 0; i < nkey; i++) { in complete_incr_bin()
1282 switch(add_delta(c, key, nkey, c->cmd == PROTOCOL_BINARY_CMD_INCREMENT, in complete_incr_bin()
1307 it = item_alloc(key, nkey, 0, realtime(req->message.body.expiration), in complete_incr_bin()
1384 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1388 MEMCACHED_COMMAND_REPLACE(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1392 MEMCACHED_COMMAND_APPEND(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1396 MEMCACHED_COMMAND_PREPEND(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1400 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
1439 size_t nkey = c->binary_header.request.keylen; in process_bin_get_or_touch() local
1449 if (fwrite(key, 1, nkey, stderr)) {} in process_bin_get_or_touch()
1457 it = item_touch(key, nkey, realtime(exptime), c); in process_bin_get_or_touch()
1459 it = item_get(key, nkey, c); in process_bin_get_or_touch()
1479 MEMCACHED_COMMAND_TOUCH(c->sfd, ITEM_key(it), it->nkey, in process_bin_get_or_touch()
1482 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_bin_get_or_touch()
1489 bodylen += nkey; in process_bin_get_or_touch()
1490 keylen = nkey; in process_bin_get_or_touch()
1501 add_iov(c, ITEM_key(it), nkey); in process_bin_get_or_touch()
1529 MEMCACHED_COMMAND_TOUCH(c->sfd, key, nkey, -1, 0); in process_bin_get_or_touch()
1531 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_bin_get_or_touch()
1540 0, nkey, nkey); in process_bin_get_or_touch()
1541 memcpy(ofs, key, nkey); in process_bin_get_or_touch()
1542 add_iov(c, ofs, nkey); in process_bin_get_or_touch()
1553 stats_prefix_record_get(key, nkey, NULL != it); in process_bin_get_or_touch()
1668 size_t nkey = c->binary_header.request.keylen; in process_bin_stat() local
1673 for (ii = 0; ii < nkey; ++ii) { in process_bin_stat()
1679 if (nkey == 0) { in process_bin_stat()
1708 if (get_stats(subcommand, nkey, &append_stats, c)) { in process_bin_stat()
1857 int nkey = c->binary_header.request.keylen; in process_bin_sasl_auth() local
1858 int vlen = c->binary_header.request.bodylen - nkey; in process_bin_sasl_auth()
1860 if (nkey > MAX_SASL_MECH_LEN) { in process_bin_sasl_auth()
1869 item *it = item_alloc(key, nkey, 0, 0, vlen); in process_bin_sasl_auth()
1893 int nkey = c->binary_header.request.keylen; in process_bin_complete_sasl_auth() local
1894 int vlen = c->binary_header.request.bodylen - nkey; in process_bin_complete_sasl_auth()
1896 char mech[nkey+1]; in process_bin_complete_sasl_auth()
1897 memcpy(mech, ITEM_key((item*)c->item), nkey); in process_bin_complete_sasl_auth()
1898 mech[nkey] = 0x00; in process_bin_complete_sasl_auth()
2173 int nkey; in process_bin_update() local
2181 nkey = c->binary_header.request.keylen; in process_bin_update()
2187 vlen = c->binary_header.request.bodylen - (nkey + c->binary_header.request.extlen); in process_bin_update()
2198 for (ii = 0; ii < nkey; ++ii) { in process_bin_update()
2207 stats_prefix_record_set(key, nkey); in process_bin_update()
2210 it = item_alloc(key, nkey, req->message.body.flags, in process_bin_update()
2215 if (! item_size_ok(nkey, req->message.body.flags, vlen + 2)) { in process_bin_update()
2226 NULL, status, 0, key, nkey); in process_bin_update()
2231 it = item_get(key, nkey, c); in process_bin_update()
2272 int nkey; in process_bin_append_prepend() local
2279 nkey = c->binary_header.request.keylen; in process_bin_append_prepend()
2280 vlen = c->binary_header.request.bodylen - nkey; in process_bin_append_prepend()
2287 stats_prefix_record_set(key, nkey); in process_bin_append_prepend()
2290 it = item_alloc(key, nkey, 0, 0, vlen+2); in process_bin_append_prepend()
2293 if (! item_size_ok(nkey, 0, vlen + 2)) { in process_bin_append_prepend()
2366 size_t nkey = c->binary_header.request.keylen; in process_bin_delete() local
2373 for (ii = 0; ii < nkey; ++ii) { in process_bin_delete()
2380 stats_prefix_record_delete(key, nkey); in process_bin_delete()
2383 it = item_get(key, nkey, c); in process_bin_delete()
2387 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_bin_delete()
2561 item *old_it = do_item_get(key, it->nkey, hv, c); in do_store_item()
2628 …new_it = do_item_alloc(key, it->nkey, flags, old_it->exptime, it->nbytes + old_it->nbytes - 2 /* C… in do_store_item()
2663 stored, comm, ITEM_key(it), it->nkey); in do_store_item()
3145 size_t nkey; in process_get_command() local
3156 nkey = key_token->length; in process_get_command()
3158 if(nkey > KEY_MAX_LENGTH) { in process_get_command()
3166 it = item_get(key, nkey, c); in process_get_command()
3168 stats_prefix_record_get(key, nkey, NULL != it); in process_get_command()
3195 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_get_command()
3230 add_iov(c, ITEM_key(it), it->nkey) != 0 || in process_get_command()
3246 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_get_command()
3249 add_iov(c, ITEM_key(it), it->nkey) != 0) in process_get_command()
3272 for (ii = 0; ii < it->nkey; ++ii) { in process_get_command()
3292 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_get_command()
3336 size_t nkey; in process_update_command() local
3354 nkey = tokens[KEY_TOKEN].length; in process_update_command()
3387 stats_prefix_record_set(key, nkey); in process_update_command()
3390 it = item_alloc(key, nkey, flags, realtime(exptime), vlen); in process_update_command()
3394 if (! item_size_ok(nkey, flags, vlen)) { in process_update_command()
3402 NULL, status, comm, key, nkey); in process_update_command()
3410 it = item_get(key, nkey, c); in process_update_command()
3430 size_t nkey; in process_touch_command() local
3444 nkey = tokens[KEY_TOKEN].length; in process_touch_command()
3451 it = item_touch(key, nkey, realtime(exptime_int), c); in process_touch_command()
3475 size_t nkey; in process_arithmetic_command() local
3487 nkey = tokens[KEY_TOKEN].length; in process_arithmetic_command()
3494 switch(add_delta(c, key, nkey, incr, delta, temp, NULL)) { in process_arithmetic_command()
3531 enum delta_result_type do_add_delta(conn *c, const char *key, const size_t nkey, in do_add_delta() argument
3540 it = do_item_get(key, nkey, hv, c); in do_add_delta()
3565 MEMCACHED_COMMAND_INCR(c->sfd, ITEM_key(it), it->nkey, value); in do_add_delta()
3572 MEMCACHED_COMMAND_DECR(c->sfd, ITEM_key(it), it->nkey, value); in do_add_delta()
3603 new_it = do_item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, res + 2); in do_add_delta()
3635 size_t nkey; in process_delete_command() local
3654 nkey = tokens[KEY_TOKEN].length; in process_delete_command()
3656 if(nkey > KEY_MAX_LENGTH) { in process_delete_command()
3662 stats_prefix_record_delete(key, nkey); in process_delete_command()
3665 it = item_get(key, nkey, c); in process_delete_command()
3667 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_delete_command()