Lines Matching refs:client
46 return (pa->client == pb->client) && in listMatchPubsubPattern()
51 int clientSubscriptionsCount(client *c) { in clientSubscriptionsCount()
58 int pubsubSubscribeChannel(client *c, robj *channel) { in pubsubSubscribeChannel()
88 int pubsubUnsubscribeChannel(client *c, robj *channel, int notify) { in pubsubUnsubscribeChannel()
127 int pubsubSubscribePattern(client *c, robj *pattern) { in pubsubSubscribePattern()
137 pat->client = c; in pubsubSubscribePattern()
150 int pubsubUnsubscribePattern(client *c, robj *pattern, int notify) { in pubsubUnsubscribePattern()
159 pat.client = c; in pubsubUnsubscribePattern()
178 int pubsubUnsubscribeAllChannels(client *c, int notify) { in pubsubUnsubscribeAllChannels()
202 int pubsubUnsubscribeAllPatterns(client *c, int notify) { in pubsubUnsubscribeAllPatterns()
240 client *c = ln->value; in pubsubPublishMessage()
260 addReply(pat->client,shared.mbulkhdr[4]); in pubsubPublishMessage()
261 addReply(pat->client,shared.pmessagebulk); in pubsubPublishMessage()
262 addReplyBulk(pat->client,pat->pattern); in pubsubPublishMessage()
263 addReplyBulk(pat->client,channel); in pubsubPublishMessage()
264 addReplyBulk(pat->client,message); in pubsubPublishMessage()
277 void subscribeCommand(client *c) { in subscribeCommand()
285 void unsubscribeCommand(client *c) { in unsubscribeCommand()
297 void psubscribeCommand(client *c) { in psubscribeCommand()
305 void punsubscribeCommand(client *c) { in punsubscribeCommand()
317 void publishCommand(client *c) { in publishCommand()
327 void pubsubCommand(client *c) { in pubsubCommand()