77     listAddNodeTail(server.clients,c);  in linkClient()
81     c->client_list_node = listLast(server.clients);  in linkClient()
83     raxInsert(server.clients_index,(unsigned char*)&id,sizeof(id),c,NULL);  in linkClient()
96         if (server.tcpkeepalive)  in createClient()
97             anetKeepAlive(NULL,fd,server.tcpkeepalive);  in createClient()
98         if (aeCreateFileEvent(server.el,fd,AE_READABLE,  in createClient()
109     atomicGetIncr(server.next_client_id,client_id,1);  in createClient()
126     c->ctime = c->lastinteraction = server.unixtime;  in createClient()
186         listAddNodeHead(server.clients_pending_write,c);  in clientInstallWriteHandler()
677     if (listLength(server.clients) > server.maxclients) {  in acceptCommonHandler()
684         server.stat_rejected_conn++;  in acceptCommonHandler()
693     if (server.protected_mode &&  in acceptCommonHandler()
694         server.bindaddr_count == 0 &&  in acceptCommonHandler()
695         server.requirepass == NULL &&  in acceptCommonHandler()
724             server.stat_rejected_conn++;  in acceptCommonHandler()
730     server.stat_numconnections++;  in acceptCommonHandler()
742         cfd = anetTcpAccept(server.neterr, fd, cip, sizeof(cip), &cport);  in acceptTcpHandler()
746                     "Accepting client connection: %s", server.neterr);  in acceptTcpHandler()
761         cfd = anetUnixAccept(server.neterr, fd);  in acceptUnixHandler()
765                     "Accepting client connection: %s", server.neterr);  in acceptUnixHandler()
768         serverLog(LL_VERBOSE,"Accepted connection to %s", server.unixsocket);  in acceptUnixHandler()
785     while (listLength(server.slaves)) {  in disconnectSlaves()
786         listNode *ln = listFirst(server.slaves);  in disconnectSlaves()
798     if (server.current_client == c) server.current_client = NULL;  in unlinkClient()
807             raxRemove(server.clients_index,(unsigned char*)&id,sizeof(id),NULL);  in unlinkClient()
808             listDelNode(server.clients,c->client_list_node);  in unlinkClient()
823         aeDeleteFileEvent(server.el,c->fd,AE_READABLE);  in unlinkClient()
824         aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE);  in unlinkClient()
831         ln = listSearchKey(server.clients_pending_write,c);  in unlinkClient()
833         listDelNode(server.clients_pending_write,ln);  in unlinkClient()
840         ln = listSearchKey(server.unblocked_clients,c);  in unlinkClient()
842         listDelNode(server.unblocked_clients,ln);  in unlinkClient()
862     if (server.master && c->flags & CLIENT_MASTER) {  in freeClient()
914         list *l = (c->flags & CLIENT_MONITOR) ? server.monitors : server.slaves;  in freeClient()
921         if (c->flags & CLIENT_SLAVE && listLength(server.slaves) == 0)  in freeClient()
922             server.repl_no_slaves_since = server.unixtime;  in freeClient()
933         ln = listSearchKey(server.clients_to_close,c);  in freeClient()
935         listDelNode(server.clients_to_close,ln);  in freeClient()
954     listAddNodeTail(server.clients_to_close,c);  in freeClientAsync()
958     while (listLength(server.clients_to_close)) {  in freeClientsInAsyncFreeQueue()
959         listNode *ln = listFirst(server.clients_to_close);  in freeClientsInAsyncFreeQueue()
964         listDelNode(server.clients_to_close,ln);  in freeClientsInAsyncFreeQueue()
973     client *c = raxFind(server.clients_index,(unsigned char*)&id,sizeof(id));  in lookupClientByID()
1036             (server.maxmemory == 0 ||  in writeToClient()
1037              zmalloc_used_memory() < server.maxmemory) &&  in writeToClient()
1040     server.stat_net_output_bytes += totwritten;  in writeToClient()
1056         if (!(c->flags & CLIENT_MASTER)) c->lastinteraction = server.unixtime;  in writeToClient()
1060         if (handler_installed) aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE);  in writeToClient()
1085     int processed = listLength(server.clients_pending_write);  in handleClientsWithPendingWrites()
1087     listRewind(server.clients_pending_write,&li);  in handleClientsWithPendingWrites()
1091         listDelNode(server.clients_pending_write,ln);  in handleClientsWithPendingWrites()
1109             if (server.aof_state == AOF_ON &&  in handleClientsWithPendingWrites()
1110                 server.aof_fsync == AOF_FSYNC_ALWAYS)  in handleClientsWithPendingWrites()
1114             if (aeCreateFileEvent(server.el, c->fd, ae_flags,  in handleClientsWithPendingWrites()
1163     aeDeleteFileEvent(server.el,c->fd,AE_READABLE);  in protectClient()
1164     aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE);  in protectClient()
1171         aeCreateFileEvent(server.el,c->fd,AE_READABLE,readQueryFromClient,c);  in unprotectClient()
1220         c->repl_ack_time = server.unixtime;  in processInlineBuffer()
1248     if (server.verbosity <= LL_VERBOSE) {  in setProtocolError()
1357             if (!ok || ll < 0 || ll > server.proto_max_bulk_len) {  in processMultibulkBuffer()
1425     server.current_client = c;  in processInputBuffer()
1439         if (server.lua_timedout && c->flags & CLIENT_MASTER) break;  in processInputBuffer()
1486             if (server.current_client == NULL) break;  in processInputBuffer()
1491     if (server.current_client != NULL && c->qb_pos) {  in processInputBuffer()
1496     server.current_client = NULL;  in processInputBuffer()
1511             replicationFeedSlavesFromMasterStream(server.slaves,  in processInputBufferAndReplicate()
1567     c->lastinteraction = server.unixtime;  in readQueryFromClient()
1569     server.stat_net_input_bytes += nread;  in readQueryFromClient()
1570     if (sdslen(c->querybuf) > server.client_max_querybuf_len) {  in readQueryFromClient()
1597     listRewind(server.clients,&li);  in getClientsMaxBuffers()
1623         snprintf(peerid,peerid_len,"%s:0",server.unixsocket);  in genClientPeerId()
1670     emask = client->fd == -1 ? 0 : aeGetFileEvents(server.el,client->fd);  in catClientInfoString()
1681         (long long)(server.unixtime - client->ctime),  in catClientInfoString()
1682         (long long)(server.unixtime - client->lastinteraction),  in catClientInfoString()
1701     sds o = sdsnewlen(SDS_NOINIT,200*listLength(server.clients));  in getAllClientsInfoString()
1703     listRewind(server.clients,&li);  in getAllClientsInfoString()
1826         listRewind(server.clients,&li);  in clientCommand()
2086     if (server.client_obuf_limits[class].hard_limit_bytes &&  in checkClientOutputBufferLimits()
2087         used_mem >= server.client_obuf_limits[class].hard_limit_bytes)  in checkClientOutputBufferLimits()
2089     if (server.client_obuf_limits[class].soft_limit_bytes &&  in checkClientOutputBufferLimits()
2090         used_mem >= server.client_obuf_limits[class].soft_limit_bytes)  in checkClientOutputBufferLimits()
2097             c->obuf_soft_limit_reached_time = server.unixtime;  in checkClientOutputBufferLimits()
2100             time_t elapsed = server.unixtime - c->obuf_soft_limit_reached_time;  in checkClientOutputBufferLimits()
2103                 server.client_obuf_limits[class].soft_limit_seconds) {  in checkClientOutputBufferLimits()
2143     listRewind(server.slaves,&li);  in flushSlavesOutputBuffers()
2154         events = aeGetFileEvents(server.el,slave->fd);  in flushSlavesOutputBuffers()
2182     if (!server.clients_paused || end > server.clients_pause_end_time)  in pauseClients()
2183         server.clients_pause_end_time = end;  in pauseClients()
2184     server.clients_paused = 1;  in pauseClients()
2190     if (server.clients_paused &&  in clientsArePaused()
2191         server.clients_pause_end_time < server.mstime)  in clientsArePaused()
2197         server.clients_paused = 0;  in clientsArePaused()
2201         listRewind(server.clients,&li);  in clientsArePaused()
2211     return server.clients_paused;  in clientsArePaused()
2231         events += aeProcessEvents(server.el, AE_FILE_EVENTS|AE_DONT_WAIT);  in processEventsWhileBlocked()