Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/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 Dnetworking.c1658 if (client->flags & CLIENT_PUBSUB) *p++ = 'P'; in catClientInfoString()
2048 if (c->flags & CLIENT_PUBSUB) return CLIENT_TYPE_PUBSUB; in getClientType()
H A Dserver.c827 !(c->flags & CLIENT_PUBSUB) && /* no timeout for Pub/Sub clients */ in clientsCronHandleTimeout()
2686 if (c->flags & CLIENT_PUBSUB && in processCommand()
2958 if (c->flags & CLIENT_PUBSUB) { in pingCommand()
H A Dserver.h248 #define CLIENT_PUBSUB (1<<18) /* Client is in Pub/Sub mode. */ macro