Commit 071da984 authored by antirez's avatar antirez
Browse files

RESP3: blocked.c updated.

parent 9705c12d
...@@ -187,7 +187,7 @@ void replyToBlockedClientTimedOut(client *c) { ...@@ -187,7 +187,7 @@ void replyToBlockedClientTimedOut(client *c) {
if (c->btype == BLOCKED_LIST || if (c->btype == BLOCKED_LIST ||
c->btype == BLOCKED_ZSET || c->btype == BLOCKED_ZSET ||
c->btype == BLOCKED_STREAM) { c->btype == BLOCKED_STREAM) {
addReply(c,shared.nullmultibulk); addReplyNull(c);
} else if (c->btype == BLOCKED_WAIT) { } else if (c->btype == BLOCKED_WAIT) {
addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset));
} else if (c->btype == BLOCKED_MODULE) { } else if (c->btype == BLOCKED_MODULE) {
...@@ -436,8 +436,8 @@ void handleClientsBlockedOnKeys(void) { ...@@ -436,8 +436,8 @@ void handleClientsBlockedOnKeys(void) {
* the name of the stream and the data we * the name of the stream and the data we
* extracted from it. Wrapped in a single-item * extracted from it. Wrapped in a single-item
* array, since we have just one key. */ * array, since we have just one key. */
addReplyMultiBulkLen(receiver,1); addReplyArrayLen(receiver,1);
addReplyMultiBulkLen(receiver,2); addReplyArrayLen(receiver,2);
addReplyBulk(receiver,rl->key); addReplyBulk(receiver,rl->key);
streamPropInfo pi = { streamPropInfo pi = {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment