summaryrefslogtreecommitdiff
path: root/src/pubsub.c
diff options
context:
space:
mode:
authorantirez <antirez@gmail.com>2011-11-08 17:07:55 +0100
committerantirez <antirez@gmail.com>2011-11-08 17:07:55 +0100
commitc0ba9ebe13865189a3b21f7be8a910e349b59fda (patch)
treeca836b0d89cf04306b428b24dba552d574488e15 /src/pubsub.c
parent71a50956b1ff6b45b8265afa8e7e0264c465cec8 (diff)
downloadredis-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.c8
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;