34 static void setProtocolError(client *c, int pos);
64 client *createClient(int fd) {  in createClient()
65     client *c = zmalloc(sizeof(client));  in createClient()
155 int prepareClientToWrite(client *c) {  in prepareClientToWrite()
213 int _addReplyToBuffer(client *c, const char *s, size_t len) {  in _addReplyToBuffer()
230 void _addReplyObjectToList(client *c, robj *o) {  in _addReplyObjectToList()
262 void _addReplySdsToList(client *c, sds s) {  in _addReplySdsToList()
293 void _addReplyStringToList(client *c, const char *s, size_t len) {  in _addReplyStringToList()
329 void addReply(client *c, robj *obj) {  in addReply()
365 void addReplySds(client *c, sds s) {  in addReplySds()
379 void addReplyString(client *c, const char *s, size_t len) {  in addReplyString()
385 void addReplyErrorLength(client *c, const char *s, size_t len) {  in addReplyErrorLength()
391 void addReplyError(client *c, const char *err) {  in addReplyError()
395 void addReplyErrorFormat(client *c, const char *fmt, ...) {  in addReplyErrorFormat()
411 void addReplyStatusLength(client *c, const char *s, size_t len) {  in addReplyStatusLength()
417 void addReplyStatus(client *c, const char *status) {  in addReplyStatus()
421 void addReplyStatusFormat(client *c, const char *fmt, ...) {  in addReplyStatusFormat()
432 void *addDeferredMultiBulkLength(client *c) {  in addDeferredMultiBulkLength()
442 void setDeferredMultiBulkLength(client *c, void *node, long length) {  in setDeferredMultiBulkLength()
469 void addReplyDouble(client *c, double d) {  in addReplyDouble()
486 void addReplyHumanLongDouble(client *c, long double d) {  in addReplyHumanLongDouble()
494 void addReplyLongLongWithPrefix(client *c, long long ll, char prefix) {  in addReplyLongLongWithPrefix()
516 void addReplyLongLong(client *c, long long ll) {  in addReplyLongLong()
525 void addReplyMultiBulkLen(client *c, long length) {  in addReplyMultiBulkLen()
533 void addReplyBulkLen(client *c, robj *obj) {  in addReplyBulkLen()
559 void addReplyBulk(client *c, robj *obj) {  in addReplyBulk()
566 void addReplyBulkCBuffer(client *c, const void *p, size_t len) {  in addReplyBulkCBuffer()
573 void addReplyBulkSds(client *c, sds s)  {  in addReplyBulkSds()
581 void addReplyBulkCString(client *c, const char *s) {  in addReplyBulkCString()
590 void addReplyBulkLongLong(client *c, long long ll) {  in addReplyBulkLongLong()
601 void copyClientOutputBuffer(client *dst, client *src) {  in copyClientOutputBuffer()
611 int clientHasPendingReplies(client *c) {  in clientHasPendingReplies()
617     client *c;  in acceptCommonHandler()
725 static void freeClientArgv(client *c) {  in freeClientArgv()
739         freeClient((client*)ln->value);  in disconnectSlaves()
746 void unlinkClient(client *c) {  in unlinkClient()
786 void freeClient(client *c) {  in freeClient()
883 void freeClientAsync(client *c) {  in freeClientAsync()
892         client *c = listNodeValue(ln);  in freeClientsInAsyncFreeQueue()
902 int writeToClient(int fd, client *c, int handler_installed) {  in writeToClient()
1005         client *c = listNodeValue(ln);  in handleClientsWithPendingWrites()
1025 void resetClient(client *c) {  in resetClient()
1048 int processInlineBuffer(client *c) {  in processInlineBuffer()
1111 static void setProtocolError(client *c, int pos) {  in setProtocolError()
1113         sds client = catClientInfoString(sdsempty(),c);  in setProtocolError()  local
1115             "Protocol error from client: %s", client);  in setProtocolError()
1116         sdsfree(client);  in setProtocolError()
1122 int processMultibulkBuffer(client *c) {  in processMultibulkBuffer()
1260 void processInputBuffer(client *c) {  in processInputBuffer()
1308     client *c = (client*) privdata;  in readQueryFromClient()
1366     client *c;  in getClientsMaxBuffers()
1393 void genClientPeerId(client *client, char *peerid,  in genClientPeerId()  argument
1395     if (client->flags & CLIENT_UNIX_SOCKET) {  in genClientPeerId()
1400         anetFormatPeer(client->fd,peerid,peerid_len);  in genClientPeerId()
1408 char *getClientPeerId(client *c) {  in getClientPeerId()
1420 sds catClientInfoString(sds s, client *client) {  in catClientInfoString()  argument
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()
1443     emask = client->fd == -1 ? 0 : aeGetFileEvents(server.el,client->fd);  in catClientInfoString()
1450         (unsigned long long) client->id,  in catClientInfoString()
1451         getClientPeerId(client),  in catClientInfoString()
1452         client->fd,  in catClientInfoString()
1453         client->name ? (char*)client->name->ptr : "",  in catClientInfoString()
1454         (long long)(server.unixtime - client->ctime),  in catClientInfoString()
1455         (long long)(server.unixtime - client->lastinteraction),  in catClientInfoString()
1457         client->db->id,  in catClientInfoString()
1458         (int) dictSize(client->pubsub_channels),  in catClientInfoString()
1459         (int) listLength(client->pubsub_patterns),  in catClientInfoString()
1460         (client->flags & CLIENT_MULTI) ? client->mstate.count : -1,  in catClientInfoString()
1461         (unsigned long long) sdslen(client->querybuf),  in catClientInfoString()
1462         (unsigned long long) sdsavail(client->querybuf),  in catClientInfoString()
1463         (unsigned long long) client->bufpos,  in catClientInfoString()
1464         (unsigned long long) listLength(client->reply),  in catClientInfoString()
1465         (unsigned long long) getClientOutputBufferMemoryUsage(client),  in catClientInfoString()
1467         client->lastcmd ? client->lastcmd->name : "NULL");  in catClientInfoString()
1473     client *client;  in getAllClientsInfoString()  local
1478         client = listNodeValue(ln);  in getAllClientsInfoString()
1479         o = catClientInfoString(o,client);  in getAllClientsInfoString()
1485 void clientCommand(client *c) {  in clientCommand()
1488     client *client;  in clientCommand()  local
1567             client = listNodeValue(ln);  in clientCommand()
1568             if (addr && strcmp(getClientPeerId(client),addr) != 0) continue;  in clientCommand()
1569             if (type != -1 && getClientType(client) != type) continue;  in clientCommand()
1570             if (id != 0 && client->id != id) continue;  in clientCommand()
1571             if (c == client && skipme) continue;  in clientCommand()
1574             if (c == client) {  in clientCommand()
1577                 freeClient(client);  in clientCommand()
1643 void rewriteClientCommandVector(client *c, int argc, ...) {  in rewriteClientCommandVector()
1671 void replaceClientCommandVector(client *c, int argc, robj **argv) {  in replaceClientCommandVector()
1691 void rewriteClientCommandArgument(client *c, int i, robj *newval) {  in rewriteClientCommandArgument()
1724 unsigned long getClientOutputBufferMemoryUsage(client *c) {  in getClientOutputBufferMemoryUsage()
1739 int getClientType(client *c) {  in getClientType()
1771 int checkClientOutputBufferLimits(client *c) {  in checkClientOutputBufferLimits()
1816 void asyncCloseClientOnOutputBufferLimitReached(client *c) {  in asyncCloseClientOnOutputBufferLimitReached()
1820         sds client = catClientInfoString(sdsempty(),c);  in asyncCloseClientOnOutputBufferLimitReached()  local
1823 …L_WARNING,"Client %s scheduled to be closed ASAP for overcoming of output buffer limits.", client);  in asyncCloseClientOnOutputBufferLimitReached()
1824         sdsfree(client);  in asyncCloseClientOnOutputBufferLimitReached()
1838         client *slave = listNodeValue(ln);  in flushSlavesOutputBuffers()
1888         client *c;  in clientsArePaused()