Merge pull request #5002 from soloestoy/streams-read-or-write

Streams: lookupKey[Read->Write]OrReply in xdel and xtrim
This commit is contained in:
Salvatore Sanfilippo 2018-06-11 16:33:10 +02:00 committed by GitHub
commit 5db262b623
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -2053,7 +2053,7 @@ void xclaimCommand(client *c) {
void xdelCommand(client *c) {
robj *o;
if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL
if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL
|| checkType(c,o,OBJ_STREAM)) return;
stream *s = o->ptr;
@ -2094,7 +2094,7 @@ void xtrimCommand(client *c) {
/* If the key does not exist, we are ok returning zero, that is, the
* number of elements removed from the stream. */
if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL
if ((o = lookupKeyWriteOrReply(c,c->argv[1],shared.czero)) == NULL
|| checkType(c,o,OBJ_STREAM)) return;
stream *s = o->ptr;