summaryrefslogtreecommitdiff
path: root/src/blocked.c
diff options
context:
space:
mode:
authorMadelyn Olson <34459052+madolson@users.noreply.github.com>2020-12-23 19:06:25 -0800
committerGitHub <noreply@github.com>2020-12-23 19:06:25 -0800
commitefaf09ee4b6437c69c467acdb0c62a510207e993 (patch)
treeb8eb22c7360cb9db2959b5cb3f26813698c3a3e7 /src/blocked.c
parent55abd1c6d078e0d30ee01a819f069fa7737c3dc2 (diff)
downloadredis-efaf09ee4b6437c69c467acdb0c62a510207e993.tar.gz
Flow through the error handling path for most errors (#8226)
Properly throw errors for invalid replication stream and support https://github.com/redis/redis/pull/8217
Diffstat (limited to 'src/blocked.c')
-rw-r--r--src/blocked.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/blocked.c b/src/blocked.c
index d85723458..e3f7b74d6 100644
--- a/src/blocked.c
+++ b/src/blocked.c
@@ -200,9 +200,9 @@ void disconnectAllBlockedClients(void) {
client *c = listNodeValue(ln);
if (c->flags & CLIENT_BLOCKED) {
- addReplySds(c,sdsnew(
+ addReplyError(c,
"-UNBLOCKED force unblock from blocking operation, "
- "instance state changed (master -> replica?)\r\n"));
+ "instance state changed (master -> replica?)");
unblockClient(c);
c->flags |= CLIENT_CLOSE_AFTER_REPLY;
}