Home
last modified time | relevance | path

Searched refs:CLIENT_PUBSUB (Results 1 – 4 of 4) sorted by relevance

/redis-3.2.3/src/
H A Dpubsub.c282 c->flags |= CLIENT_PUBSUB; in subscribeCommand()
294 if (clientSubscriptionsCount(c) == 0) c->flags &= ~CLIENT_PUBSUB; in unsubscribeCommand()
302 c->flags |= CLIENT_PUBSUB; in psubscribeCommand()
314 if (clientSubscriptionsCount(c) == 0) c->flags &= ~CLIENT_PUBSUB; in punsubscribeCommand()
H A Dserver.c931 !(c->flags & CLIENT_PUBSUB) && /* no timeout for Pub/Sub clients */ in clientsCronHandleTimeout()
2468 if (c->flags & CLIENT_PUBSUB && in processCommand()
2680 if (c->flags & CLIENT_PUBSUB) { in pingCommand()
H A Dserver.h264 #define CLIENT_PUBSUB (1<<18) /* Client is in Pub/Sub mode. */ macro
H A Dnetworking.c1743 if (c->flags & CLIENT_PUBSUB) return CLIENT_TYPE_PUBSUB; in getClientType()