summaryrefslogtreecommitdiff
path: root/src/pubsub.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/pubsub.c')
-rw-r--r--src/pubsub.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/pubsub.c b/src/pubsub.c
index 0169b3604..e0bbc6d94 100644
--- a/src/pubsub.c
+++ b/src/pubsub.c
@@ -304,6 +304,7 @@ int pubsubPublishMessage(robj *channel, robj *message) {
while ((ln = listNext(&li)) != NULL) {
client *c = ln->value;
addReplyPubsubMessage(c,channel,message);
+ updateClientMemUsage(c);
receivers++;
}
}
@@ -323,6 +324,7 @@ int pubsubPublishMessage(robj *channel, robj *message) {
while ((ln = listNext(&li)) != NULL) {
client *c = listNodeValue(ln);
addReplyPubsubPatMessage(c,pattern,channel,message);
+ updateClientMemUsage(c);
receivers++;
}
}