diff options
| author | antirez <antirez@gmail.com> | 2015-07-27 09:41:48 +0200 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2015-07-27 14:37:58 +0200 |
| commit | 32f80e2f1bf42d0508f1114a9dddd91c4719eb8e (patch) | |
| tree | 66763c2803eb8a91c6b57e5e54e61d454888365c /src/pubsub.c | |
| parent | 40eb548a80797b93cc733876654ff0978d7381cf (diff) | |
| download | redis-32f80e2f1bf42d0508f1114a9dddd91c4719eb8e.tar.gz | |
RDMF: More consistent define names.
Diffstat (limited to 'src/pubsub.c')
| -rw-r--r-- | src/pubsub.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/pubsub.c b/src/pubsub.c index c07a692a9..b6d1167db 100644 --- a/src/pubsub.c +++ b/src/pubsub.c @@ -279,7 +279,7 @@ void subscribeCommand(client *c) { for (j = 1; j < c->argc; j++) pubsubSubscribeChannel(c,c->argv[j]); - c->flags |= REDIS_PUBSUB; + c->flags |= CLIENT_PUBSUB; } void unsubscribeCommand(client *c) { @@ -291,7 +291,7 @@ void unsubscribeCommand(client *c) { for (j = 1; j < c->argc; j++) pubsubUnsubscribeChannel(c,c->argv[j],1); } - if (clientSubscriptionsCount(c) == 0) c->flags &= ~REDIS_PUBSUB; + if (clientSubscriptionsCount(c) == 0) c->flags &= ~CLIENT_PUBSUB; } void psubscribeCommand(client *c) { @@ -299,7 +299,7 @@ void psubscribeCommand(client *c) { for (j = 1; j < c->argc; j++) pubsubSubscribePattern(c,c->argv[j]); - c->flags |= REDIS_PUBSUB; + c->flags |= CLIENT_PUBSUB; } void punsubscribeCommand(client *c) { @@ -311,7 +311,7 @@ void punsubscribeCommand(client *c) { for (j = 1; j < c->argc; j++) pubsubUnsubscribePattern(c,c->argv[j],1); } - if (clientSubscriptionsCount(c) == 0) c->flags &= ~REDIS_PUBSUB; + if (clientSubscriptionsCount(c) == 0) c->flags &= ~CLIENT_PUBSUB; } void publishCommand(client *c) { @@ -319,7 +319,7 @@ void publishCommand(client *c) { if (server.cluster_enabled) clusterPropagatePublish(c->argv[1],c->argv[2]); else - forceCommandPropagation(c,REDIS_PROPAGATE_REPL); + forceCommandPropagation(c,PROPAGATE_REPL); addReplyLongLong(c,receivers); } |