Lines Matching refs:nkey
34 #define META_KEY(p, key, nkey, bin) { \ argument
37 memcpy(p, key, nkey); \
38 p += nkey; \
40 … p += base64_encode((unsigned char *) key, nkey, (unsigned char *)p, WRITE_BUFFER_SIZE / 2); \
98 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in _finalize_mset()
188 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
192 MEMCACHED_COMMAND_REPLACE(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
196 MEMCACHED_COMMAND_APPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
200 MEMCACHED_COMMAND_PREPEND(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
204 MEMCACHED_COMMAND_SET(c->sfd, ITEM_key(it), it->nkey, in complete_nread_ascii()
208 MEMCACHED_COMMAND_CAS(c->sfd, ITEM_key(it), it->nkey, it->nbytes, in complete_nread_ascii()
549 size_t nkey; in process_get_command() local
572 nkey = key_token->length; in process_get_command()
574 if (nkey > KEY_MAX_LENGTH) { in process_get_command()
579 it = limited_get(key, nkey, c->thread, exptime, should_touch, DO_UPDATE, &overflow); in process_get_command()
581 stats_prefix_record_get(key, nkey, NULL != it); in process_get_command()
593 MEMCACHED_COMMAND_GET(c->sfd, ITEM_key(it), it->nkey, in process_get_command()
599 memcpy(p, ITEM_key(it), it->nkey); in process_get_command()
600 p += it->nkey; in process_get_command()
631 for (ii = 0; ii < it->nkey; ++ii) { in process_get_command()
664 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_get_command()
847 size_t nkey = tokens[KEY_TOKEN].length; in process_meta_command() local
850 size_t ret = base64_decode((unsigned char *)key, nkey, in process_meta_command()
851 (unsigned char *)key, nkey); in process_meta_command()
857 nkey = ret; in process_meta_command()
861 item *it = limited_get(key, nkey, c->thread, 0, false, DONT_UPDATE, &overflow); in process_meta_command()
873 …total += base64_encode((unsigned char *) ITEM_key(it), it->nkey, (unsigned char *)resp->wbuf + tot… in process_meta_command()
875 memcpy(resp->wbuf + total, ITEM_key(it), it->nkey); in process_meta_command()
876 total += it->nkey; in process_meta_command()
881 ret = snprintf(resp->wbuf + total, WRITE_BUFFER_SIZE - (it->nkey + 12), in process_meta_command()
1077 size_t nkey; in process_mget_command() local
1118 nkey = tokens[KEY_TOKEN].length; in process_mget_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()
1141 it = item_alloc(key, nkey, 0, realtime(0), 2); in process_mget_command()
1241 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in process_mget_command()
1353 MEMCACHED_COMMAND_GET(c->sfd, key, nkey, -1, 0); in process_mget_command()
1374 META_KEY(p, key, nkey, of.key_binary); in process_mget_command()
1397 size_t nkey; in process_mset_command() local
1451 nkey = tokens[KEY_TOKEN].length; in process_mset_command()
1535 it = item_alloc(key, nkey, of.client_flags, exptime, vlen); in process_mset_command()
1541 if (! item_size_ok(nkey, of.client_flags, vlen)) { in process_mset_command()
1556 NULL, status, comm, key, nkey, 0, 0); in process_mset_command()
1560 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_mset_command()
1612 size_t nkey; in process_mdelete_command() local
1647 nkey = tokens[KEY_TOKEN].length; in process_mdelete_command()
1662 META_KEY(p, key, nkey, of.key_binary); in process_mdelete_command()
1667 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_mdelete_command()
1669 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_mdelete_command()
1683 item *new_it = item_alloc(key, nkey, of.client_flags, of.exptime, 2); in process_mdelete_command()
1764 size_t nkey; in process_marithmetic_command() local
1804 nkey = tokens[KEY_TOKEN].length; in process_marithmetic_command()
1826 hv = hash(key, nkey); in process_marithmetic_command()
1834 switch(do_add_delta(c->thread, key, nkey, incr, of.delta, tmpbuf, &of.req_cas_id, hv, &it)) { in process_marithmetic_command()
1858 it = item_alloc(key, nkey, 0, 0, vlen+2); in process_marithmetic_command()
1941 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()
1970 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()
1995 size_t nkey; in process_update_command() local
2013 nkey = tokens[KEY_TOKEN].length; in process_update_command()
2039 stats_prefix_record_set(key, nkey); in process_update_command()
2042 it = item_alloc(key, nkey, flags, exptime, vlen); in process_update_command()
2046 if (! item_size_ok(nkey, flags, vlen)) { in process_update_command()
2060 NULL, status, comm, key, nkey, 0, 0, c->sfd); in process_update_command()
2068 it = item_get(key, nkey, c->thread, DONT_UPDATE); in process_update_command()
2097 size_t nkey; in process_touch_command() local
2112 nkey = tokens[KEY_TOKEN].length; in process_touch_command()
2120 it = item_touch(key, nkey, exptime, c->thread); in process_touch_command()
2143 size_t nkey; in process_arithmetic_command() local
2155 nkey = tokens[KEY_TOKEN].length; in process_arithmetic_command()
2162 switch(add_delta(c->thread, key, nkey, incr, delta, temp, NULL)) { in process_arithmetic_command()
2191 size_t nkey; in process_delete_command() local
2211 nkey = tokens[KEY_TOKEN].length; in process_delete_command()
2213 if(nkey > KEY_MAX_LENGTH) { in process_delete_command()
2219 stats_prefix_record_delete(key, nkey); in process_delete_command()
2222 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_delete_command()
2224 MEMCACHED_COMMAND_DELETE(c->sfd, ITEM_key(it), it->nkey); in process_delete_command()