RESP3: Allow any command in RESP3 Pub/Sub mode.

9018388c · antirez · a4f8f4a8 · 9018388c
隐藏空白更改
内联并排

Showing with 3 addition and 2 deletion

src/server.c src/server.c +3 -2

未找到文件。
--- a/src/server.c
+++ b/src/server.c
@@ -2681,8 +2681,9 @@ int processCommand(client *c) {
        return C_OK;
    }

-    /* Only allow SUBSCRIBE and UNSUBSCRIBE in the context of Pub/Sub */
-    if (c->flags & CLIENT_PUBSUB &&
+    /* Only allow a subset of commands in the context of Pub/Sub if the
+     * connection is in RESP2 mode. With RESP3 there are no limits. */
+    if ((c->flags & CLIENT_PUBSUB && c->resp == 2) &&
        c->cmd->proc != pingCommand &&
        c->cmd->proc != subscribeCommand &&
        c->cmd->proc != unsubscribeCommand &&