Lines Matching defs:c
65 client *c = zmalloc(sizeof(client)); in createClient() local
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()
611 int clientHasPendingReplies(client *c) { in clientHasPendingReplies()
617 client *c; in acceptCommonHandler() local
725 static void freeClientArgv(client *c) { in freeClientArgv()
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() local
902 int writeToClient(int fd, client *c, int handler_installed) { in writeToClient()
1005 client *c = listNodeValue(ln); in handleClientsWithPendingWrites() local
1025 void resetClient(client *c) { in resetClient()
1048 int processInlineBuffer(client *c) { in processInlineBuffer()
1111 static void setProtocolError(client *c, int pos) { in setProtocolError()
1122 int processMultibulkBuffer(client *c) { in processMultibulkBuffer()
1260 void processInputBuffer(client *c) { in processInputBuffer()
1308 client *c = (client*) privdata; in readQueryFromClient() local
1366 client *c; in getClientsMaxBuffers() local
1408 char *getClientPeerId(client *c) { in getClientPeerId()
1485 void clientCommand(client *c) { 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()
1888 client *c; in clientsArePaused() local