From 9f8885760b53e6d3952b9c9b41f9e6c48dfa6cec Mon Sep 17 00:00:00 2001 From: Harkrishn Patro <30795839+hpatro@users.noreply.github.com> Date: Mon, 3 Jan 2022 01:54:47 +0100 Subject: Sharded pubsub implementation (#8621) This commit implements a sharded pubsub implementation based off of shard channels. Co-authored-by: Harkrishn Patro Co-authored-by: Madelyn Olson --- src/tracking.c | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'src/tracking.c') diff --git a/src/tracking.c b/src/tracking.c index 11e2587e2..bb36f742d 100644 --- a/src/tracking.c +++ b/src/tracking.c @@ -228,6 +228,12 @@ void trackingRememberKeys(client *c) { getKeysFreeResult(&result); return; } + /* Shard channels are treated as special keys for client + * library to rely on `COMMAND` command to discover the node + * to connect to. These channels doesn't need to be tracked. */ + if (c->cmd->flags & CMD_PUBSUB) { + return; + } int *keys = result.keys; -- cgit v1.2.1