diff options
author | antirez <antirez@gmail.com> | 2011-11-08 17:07:55 +0100 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2011-11-08 17:07:55 +0100 |
commit | c0ba9ebe13865189a3b21f7be8a910e349b59fda (patch) | |
tree | ca836b0d89cf04306b428b24dba552d574488e15 /src/pubsub.c | |
parent | 71a50956b1ff6b45b8265afa8e7e0264c465cec8 (diff) | |
download | redis-c0ba9ebe13865189a3b21f7be8a910e349b59fda.tar.gz |
dict.c API names modified to be more coincise and consistent.
Diffstat (limited to 'src/pubsub.c')
-rw-r--r-- | src/pubsub.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/pubsub.c b/src/pubsub.c index af37df5c4..27e6f9a58 100644 --- a/src/pubsub.c +++ b/src/pubsub.c @@ -36,7 +36,7 @@ int pubsubSubscribeChannel(redisClient *c, robj *channel) { dictAdd(server.pubsub_channels,channel,clients); incrRefCount(channel); } else { - clients = dictGetEntryVal(de); + clients = dictGetVal(de); } listAddNodeTail(clients,c); } @@ -64,7 +64,7 @@ int pubsubUnsubscribeChannel(redisClient *c, robj *channel, int notify) { /* Remove the client from the channel -> clients list hash table */ de = dictFind(server.pubsub_channels,channel); redisAssertWithInfo(c,NULL,de != NULL); - clients = dictGetEntryVal(de); + clients = dictGetVal(de); ln = listSearchKey(clients,c); redisAssertWithInfo(c,NULL,ln != NULL); listDelNode(clients,ln); @@ -146,7 +146,7 @@ int pubsubUnsubscribeAllChannels(redisClient *c, int notify) { int count = 0; while((de = dictNext(di)) != NULL) { - robj *channel = dictGetEntryKey(de); + robj *channel = dictGetKey(de); count += pubsubUnsubscribeChannel(c,channel,notify); } @@ -180,7 +180,7 @@ int pubsubPublishMessage(robj *channel, robj *message) { /* Send to clients listening for that channel */ de = dictFind(server.pubsub_channels,channel); if (de) { - list *list = dictGetEntryVal(de); + list *list = dictGetVal(de); listNode *ln; listIter li; |