diff options
| author | shenlongxing <shenlongxing2012@gmail.com> | 2018-08-03 19:01:15 +0800 |
|---|---|---|
| committer | shenlongxing <shenlongxing2012@gmail.com> | 2018-08-03 19:01:15 +0800 |
| commit | fe56c6740520b6fef2646d757896861c49faee0a (patch) | |
| tree | 427d32dc25d6cd9cca5bf51e3d72ba615fdc57b9 | |
| parent | 2f2987ffc5c3cbf8eab307782a07f20492a3d439 (diff) | |
| download | redis-fe56c6740520b6fef2646d757896861c49faee0a.tar.gz | |
Fix stream command paras
| -rw-r--r-- | src/server.c | 10 | ||||
| -rw-r--r-- | src/t_stream.c | 4 |
2 files changed, 7 insertions, 7 deletions
diff --git a/src/server.c b/src/server.c index 66d42ee6c..b537ee04a 100644 --- a/src/server.c +++ b/src/server.c @@ -310,14 +310,14 @@ struct redisCommand redisCommandTable[] = { {"xrange",xrangeCommand,-4,"r",0,NULL,1,1,1,0,0}, {"xrevrange",xrevrangeCommand,-4,"r",0,NULL,1,1,1,0,0}, {"xlen",xlenCommand,2,"rF",0,NULL,1,1,1,0,0}, - {"xread",xreadCommand,-3,"rs",0,xreadGetKeys,1,1,1,0,0}, - {"xreadgroup",xreadCommand,-3,"ws",0,xreadGetKeys,1,1,1,0,0}, + {"xread",xreadCommand,-4,"rs",0,xreadGetKeys,1,1,1,0,0}, + {"xreadgroup",xreadCommand,-7,"ws",0,xreadGetKeys,1,1,1,0,0}, {"xgroup",xgroupCommand,-2,"wm",0,NULL,2,2,1,0,0}, - {"xack",xackCommand,-3,"wF",0,NULL,1,1,1,0,0}, + {"xack",xackCommand,-4,"wF",0,NULL,1,1,1,0,0}, {"xpending",xpendingCommand,-3,"r",0,NULL,1,1,1,0,0}, - {"xclaim",xclaimCommand,-5,"wF",0,NULL,1,1,1,0,0}, + {"xclaim",xclaimCommand,-6,"wF",0,NULL,1,1,1,0,0}, {"xinfo",xinfoCommand,-2,"r",0,NULL,2,2,1,0,0}, - {"xdel",xdelCommand,-2,"wF",0,NULL,1,1,1,0,0}, + {"xdel",xdelCommand,-3,"wF",0,NULL,1,1,1,0,0}, {"xtrim",xtrimCommand,-2,"wF",0,NULL,1,1,1,0,0}, {"post",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, {"host:",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, diff --git a/src/t_stream.c b/src/t_stream.c index 72d03b466..d31563217 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2040,12 +2040,12 @@ void xclaimCommand(client *c) { } else if (!strcasecmp(opt,"TIME") && moreargs) { j++; if (getLongLongFromObjectOrReply(c,c->argv[j],&deliverytime, - "Invalid IDLE option argument for XCLAIM") + "Invalid TIME option argument for XCLAIM") != C_OK) return; } else if (!strcasecmp(opt,"RETRYCOUNT") && moreargs) { j++; if (getLongLongFromObjectOrReply(c,c->argv[j],&retrycount, - "Invalid IDLE option argument for XCLAIM") + "Invalid RETRYCOUNT option argument for XCLAIM") != C_OK) return; } else { addReplyErrorFormat(c,"Unrecognized XCLAIM option '%s'",opt); |