X-Git-Url: https://git.saurik.com/redis.git/blobdiff_plain/75b41de8ca975d01c6371a98f9e552c934af5937..0d916763afa44c2c6d5e28a4fe0f167197b00fc7:/src/pubsub.c?ds=sidebyside diff --git a/src/pubsub.c b/src/pubsub.c index 23b0ceb0..728e559c 100644 --- a/src/pubsub.c +++ b/src/pubsub.c @@ -141,7 +141,7 @@ int pubsubUnsubscribePattern(redisClient *c, robj *pattern, int notify) { /* Unsubscribe from all the channels. Return the number of channels the * client was subscribed from. */ int pubsubUnsubscribeAllChannels(redisClient *c, int notify) { - dictIterator *di = dictGetIterator(c->pubsub_channels); + dictIterator *di = dictGetSafeIterator(c->pubsub_channels); dictEntry *de; int count = 0; @@ -262,7 +262,6 @@ void punsubscribeCommand(redisClient *c) { } void publishCommand(redisClient *c) { - c->argv[2] = tryObjectEncoding(c->argv[2]); int receivers = pubsubPublishMessage(c->argv[1],c->argv[2]); addReplyLongLong(c,receivers); }