diff options
Diffstat (limited to 'src/pubsub.c')
-rw-r--r-- | src/pubsub.c | 2 |
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++; } } |