gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove unneeded mgetCore function

Browse Source 
Former-commit-id: 7961d4253b5a356e24d17ab07ac79ba1bf191efd
This commit is contained in:
malavan 2021-09-22 21:15:47 +00:00
parent f9b88a79ce
commit dd2d3aca1e
1 changed files with 1 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/t_string.cpp
View File

@ -524,26 +524,10 @@ void getrangeCommand(client *c) {
} }
} }
void mgetCore(client *c, robj **keys, int count, const redisDbPersistentDataSnapshot *snapshot = nullptr) {
addReplyArrayLen(c,count);
for (int i = 0; i < count; i++) {
robj_roptr o;
if (snapshot)
o = snapshot->find_cached_threadsafe(szFromObj(keys[i])).val();
else
o = lookupKeyRead(c->db,keys[i]);
if (o == nullptr || o->type != OBJ_STRING) {
addReplyNull(c);
} else {
addReplyBulk(c,o);
}
}
}
void mgetCommand(client *c) { void mgetCommand(client *c) {
addReplyArrayLen(c,c->argc-1); addReplyArrayLen(c,c->argc-1);
for (int i = 1; i < c->argc; i++) { for (int i = 1; i < c->argc; i++) {
robj_roptr o = lookupKeyRead(c->db,c->argv[i], c->mvccCheckpoint); robj_roptr o = lookupKeyRead(c->db,c->argv[i],c->mvccCheckpoint);
if (o == nullptr || o->type != OBJ_STRING) { if (o == nullptr || o->type != OBJ_STRING) {
addReplyNull(c); addReplyNull(c);
} else { } else {