From 0132ed754483b3c6a6ddccf45dcab849ee7e7508 Mon Sep 17 00:00:00 2001 From: Binbin Date: Wed, 6 Jul 2022 14:50:08 +0800 Subject: [PATCH] Add pubsubshard_channels field in INFO STATS (#10929) We already have `pubsub_channels` and `pubsub_patterns` in INFO stats, now add `pubsubshard_channels` (symmetry). Sharded pubsub was added in #8621 --- src/server.c | 2 ++ src/server.h | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/server.c b/src/server.c index 4db60dc6b..84d6adf86 100644 --- a/src/server.c +++ b/src/server.c @@ -5661,6 +5661,7 @@ sds genRedisInfoString(dict *section_dict, int all_sections, int everything) { "keyspace_misses:%lld\r\n" "pubsub_channels:%ld\r\n" "pubsub_patterns:%lu\r\n" + "pubsubshard_channels:%lu\r\n" "latest_fork_usec:%lld\r\n" "total_forks:%lld\r\n" "migrate_cached_sockets:%ld\r\n" @@ -5710,6 +5711,7 @@ sds genRedisInfoString(dict *section_dict, int all_sections, int everything) { server.stat_keyspace_misses, dictSize(server.pubsub_channels), dictSize(server.pubsub_patterns), + dictSize(server.pubsubshard_channels), server.stat_fork_time, server.stat_total_forks, dictSize(server.migrate_cached_sockets), diff --git a/src/server.h b/src/server.h index e65b69122..007614c1d 100644 --- a/src/server.h +++ b/src/server.h @@ -1858,7 +1858,7 @@ struct redisServer { dict *pubsub_patterns; /* A dict of pubsub_patterns */ int notify_keyspace_events; /* Events to propagate via Pub/Sub. This is an xor of NOTIFY_... flags. */ - dict *pubsubshard_channels; /* Map channels to list of subscribed clients */ + dict *pubsubshard_channels; /* Map shard channels to list of subscribed clients */ /* Cluster */ int cluster_enabled; /* Is cluster enabled? */ int cluster_port; /* Set the cluster port for a node. */