99     c->flags = 0;  in createClient()
158     if (c->flags & CLIENT_LUA) return C_OK;  in prepareClientToWrite()
161     if (c->flags & (CLIENT_REPLY_OFF|CLIENT_REPLY_SKIP)) return C_ERR;  in prepareClientToWrite()
165     if ((c->flags & CLIENT_MASTER) &&  in prepareClientToWrite()
166         !(c->flags & CLIENT_MASTER_FORCE_REPLY)) return C_ERR;  in prepareClientToWrite()
175         !(c->flags & CLIENT_PENDING_WRITE) &&  in prepareClientToWrite()
185         c->flags |= CLIENT_PENDING_WRITE;  in prepareClientToWrite()
216     if (c->flags & CLIENT_CLOSE_AFTER_REPLY) return C_OK;  in _addReplyToBuffer()
233     if (c->flags & CLIENT_CLOSE_AFTER_REPLY) return;  in _addReplyObjectToList()
265     if (c->flags & CLIENT_CLOSE_AFTER_REPLY) {  in _addReplySdsToList()
296     if (c->flags & CLIENT_CLOSE_AFTER_REPLY) return;  in _addReplyStringToList()
616 static void acceptCommonHandler(int fd, int flags, char *ip) {  in acceptCommonHandler()  argument
648         !(flags & CLIENT_UNIX_SOCKET) &&  in acceptCommonHandler()
683     c->flags |= flags;  in acceptCommonHandler()
769     if (c->flags & CLIENT_PENDING_WRITE) {  in unlinkClient()
773         c->flags &= ~CLIENT_PENDING_WRITE;  in unlinkClient()
778     if (c->flags & CLIENT_UNBLOCKED) {  in unlinkClient()
782         c->flags &= ~CLIENT_UNBLOCKED;  in unlinkClient()
794     if (server.master && c->flags & CLIENT_MASTER) {  in freeClient()
796         if (!(c->flags & (CLIENT_CLOSE_AFTER_REPLY|  in freeClient()
807     if ((c->flags & CLIENT_SLAVE) && !(c->flags & CLIENT_MONITOR)) {  in freeClient()
817     if (c->flags & CLIENT_BLOCKED) unblockClient(c);  in freeClient()
841     if (c->flags & CLIENT_SLAVE) {  in freeClient()
846         list *l = (c->flags & CLIENT_MONITOR) ? server.monitors : server.slaves;  in freeClient()
853         if (c->flags & CLIENT_SLAVE && listLength(server.slaves) == 0)  in freeClient()
860     if (c->flags & CLIENT_MASTER) replicationHandleMasterDisconnection();  in freeClient()
864     if (c->flags & CLIENT_CLOSE_ASAP) {  in freeClient()
884     if (c->flags & CLIENT_CLOSE_ASAP || c->flags & CLIENT_LUA) return;  in freeClientAsync()
885     c->flags |= CLIENT_CLOSE_ASAP;  in freeClientAsync()
894         c->flags &= ~CLIENT_CLOSE_ASAP;  in freeClientsInAsyncFreeQueue()
972         if (!(c->flags & CLIENT_MASTER)) c->lastinteraction = server.unixtime;  in writeToClient()
979         if (c->flags & CLIENT_CLOSE_AFTER_REPLY) {  in writeToClient()
1006         c->flags &= ~CLIENT_PENDING_WRITE;  in handleClientsWithPendingWrites()
1035     if (!(c->flags & CLIENT_MULTI) && prevcmd != askingCommand)  in resetClient()
1036         c->flags &= ~CLIENT_ASKING;  in resetClient()
1041     c->flags &= ~CLIENT_REPLY_SKIP;  in resetClient()
1042     if (c->flags & CLIENT_REPLY_SKIP_NEXT) {  in resetClient()
1043         c->flags |= CLIENT_REPLY_SKIP;  in resetClient()
1044         c->flags &= ~CLIENT_REPLY_SKIP_NEXT;  in resetClient()
1084     if (querylen == 0 && c->flags & CLIENT_SLAVE)  in processInlineBuffer()
1118     c->flags |= CLIENT_CLOSE_AFTER_REPLY;  in setProtocolError()
1265         if (!(c->flags & CLIENT_SLAVE) && clientsArePaused()) break;  in processInputBuffer()
1268         if (c->flags & CLIENT_BLOCKED) break;  in processInputBuffer()
1273         if (c->flags & CLIENT_CLOSE_AFTER_REPLY) break;  in processInputBuffer()
1349     if (c->flags & CLIENT_MASTER) c->reploff += nread;  in readQueryFromClient()
1395     if (client->flags & CLIENT_UNIX_SOCKET) {  in genClientPeerId()
1421     char flags[16], events[3], *p;  in catClientInfoString()  local
1424     p = flags;  in catClientInfoString()
1425     if (client->flags & CLIENT_SLAVE) {  in catClientInfoString()
1426         if (client->flags & CLIENT_MONITOR)  in catClientInfoString()
1431     if (client->flags & CLIENT_MASTER) *p++ = 'M';  in catClientInfoString()
1432     if (client->flags & CLIENT_MULTI) *p++ = 'x';  in catClientInfoString()
1433     if (client->flags & CLIENT_BLOCKED) *p++ = 'b';  in catClientInfoString()
1434     if (client->flags & CLIENT_DIRTY_CAS) *p++ = 'd';  in catClientInfoString()
1435     if (client->flags & CLIENT_CLOSE_AFTER_REPLY) *p++ = 'c';  in catClientInfoString()
1436     if (client->flags & CLIENT_UNBLOCKED) *p++ = 'u';  in catClientInfoString()
1437     if (client->flags & CLIENT_CLOSE_ASAP) *p++ = 'A';  in catClientInfoString()
1438     if (client->flags & CLIENT_UNIX_SOCKET) *p++ = 'U';  in catClientInfoString()
1439     if (client->flags & CLIENT_READONLY) *p++ = 'r';  in catClientInfoString()
1440     if (p == flags) *p++ = 'N';  in catClientInfoString()
1456         flags,  in catClientInfoString()
1460         (client->flags & CLIENT_MULTI) ? client->mstate.count : -1,  in catClientInfoString()
1498             c->flags &= ~(CLIENT_REPLY_SKIP|CLIENT_REPLY_OFF);  in clientCommand()
1501             c->flags |= CLIENT_REPLY_OFF;  in clientCommand()
1503             if (!(c->flags & CLIENT_REPLY_OFF))  in clientCommand()
1504                 c->flags |= CLIENT_REPLY_SKIP_NEXT;  in clientCommand()
1594         if (close_this_client) c->flags |= CLIENT_CLOSE_AFTER_REPLY;  in clientCommand()
1740     if (c->flags & CLIENT_MASTER) return CLIENT_TYPE_MASTER;  in getClientType()
1741     if ((c->flags & CLIENT_SLAVE) && !(c->flags & CLIENT_MONITOR))  in getClientType()
1743     if (c->flags & CLIENT_PUBSUB) return CLIENT_TYPE_PUBSUB;  in getClientType()
1818     if (c->reply_bytes == 0 || c->flags & CLIENT_CLOSE_ASAP) return;  in asyncCloseClientOnOutputBufferLimitReached()
1900             if (c->flags & (CLIENT_SLAVE|CLIENT_BLOCKED)) continue;  in clientsArePaused()
1901             c->flags |= CLIENT_UNBLOCKED;  in clientsArePaused()