Lines Matching refs:client

715 typedef struct client {  struct
772 } client;  argument
983     client *current_client; /* Current client, only used on crash report */
1159     client *master;     /* Client that is master for this slave */
1160     client *cached_master; /* Cached master to be reused for PSYNC. */
1252     client *lua_client;   /* The "fake client" to query Redis from Lua */
1253     client *lua_caller;   /* The client running EVAL right now, or NULL */
1293     client *client;  member
1297 typedef void redisCommandProc(client *c);
1406 void unblockClientFromModule(client *c);
1408 void moduleBlockedClientTimedOut(client *c);
1414 void moduleCallCommandFilters(client *c);
1427 client *createClient(int fd);
1429 void freeClient(client *c);
1430 void freeClientAsync(client *c);
1431 void resetClient(client *c);
1433 void *addDeferredMultiBulkLength(client *c);
1434 void setDeferredMultiBulkLength(client *c, void *node, long length);
1435 void processInputBuffer(client *c);
1436 void processInputBufferAndReplicate(client *c);
1441 void addReplyString(client *c, const char *s, size_t len);
1442 void AddReplyFromClient(client *c, client *src);
1443 void addReplyBulk(client *c, robj *obj);
1444 void addReplyBulkCString(client *c, const char *s);
1445 void addReplyBulkCBuffer(client *c, const void *p, size_t len);
1446 void addReplyBulkLongLong(client *c, long long ll);
1447 void addReply(client *c, robj *obj);
1448 void addReplySds(client *c, sds s);
1449 void addReplyBulkSds(client *c, sds s);
1450 void addReplyError(client *c, const char *err);
1451 void addReplyStatus(client *c, const char *status);
1452 void addReplyDouble(client *c, double d);
1453 void addReplyHumanLongDouble(client *c, long double d);
1454 void addReplyLongLong(client *c, long long ll);
1455 void addReplyMultiBulkLen(client *c, long length);
1456 void addReplyHelp(client *c, const char **help);
1457 void addReplySubcommandSyntaxError(client *c);
1458 void copyClientOutputBuffer(client *dst, client *src);
1465 char *getClientPeerId(client *client);
1466 sds catClientInfoString(sds s, client *client);
1468 void rewriteClientCommandVector(client *c, int argc, ...);
1469 void rewriteClientCommandArgument(client *c, int i, robj *newval);
1470 void replaceClientCommandVector(client *c, int argc, robj **argv);
1471 unsigned long getClientOutputBufferMemoryUsage(client *c);
1473 void asyncCloseClientOnOutputBufferLimitReached(client *c);
1474 int getClientType(client *c);
1484 int clientHasPendingReplies(client *c);
1485 void unlinkClient(client *c);
1486 int writeToClient(int fd, client *c, int handler_installed);
1487 void linkClient(client *c);
1488 void protectClient(client *c);
1489 void unprotectClient(client *c);
1492 void addReplyErrorFormat(client *c, const char *fmt, ...)
1494 void addReplyStatusFormat(client *c, const char *fmt, ...)
1497 void addReplyErrorFormat(client *c, const char *fmt, ...);
1498 void addReplyStatusFormat(client *c, const char *fmt, ...);
1514 void unblockClientWaitingData(client *c);
1515 void popGenericCommand(client *c, int where);
1518 void unwatchAllKeys(client *c);
1519 void initClientMultiState(client *c);
1520 void freeClientMultiState(client *c);
1521 void queueMultiCommand(client *c);
1524 void discardTransaction(client *c);
1525 void flagTransaction(client *c);
1526 void execCommandPropagateMulti(client *c);
1561 int getLongFromObjectOrReply(client *c, robj *o, long *target, const char *msg);
1562 int checkType(client *c, robj *o, int type);
1563 int getLongLongFromObjectOrReply(client *c, robj *o, long long *target, const char *msg);
1564 int getDoubleFromObjectOrReply(client *c, robj *o, double *target, const char *msg);
1568 int getLongDoubleFromObjectOrReply(client *c, robj *o, long double *target, const char *msg);
1585 void replicationFeedMonitors(client *c, list *monitors, int dictid, robj **argv, int argc);
1589 void replicationCacheMaster(client *c);
1599 void unblockClientWaitingReplicas(client *c);
1603 char *replicationGetSlaveName(client *c);
1605 int replicationSetupSlaveForFullResync(client *slave, long long offset);
1694 void genericZpopCommand(client *c, robj **keyv, int keyc, int where, int emitkey, robj *countarg);
1714 int processCommand(client *c);
1719 void call(client *c, int flags);
1722 void forceCommandPropagation(client *c, int flags);
1723 void preventCommandPropagation(client *c);
1724 void preventCommandAOF(client *c);
1725 void preventCommandReplication(client *c);
1792 robj *hashTypeLookupWriteOrCreate(client *c, robj *key);
1797 int pubsubUnsubscribeAllChannels(client *c, int notify);
1798 int pubsubUnsubscribeAllPatterns(client *c, int notify);
1821 void setExpire(client *c, redisDb *db, robj *key, long long when);
1825 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply);
1826 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply);
1828 robj *objectCommandLookup(client *c, robj *key);
1829 robj *objectCommandLookupOrReply(client *c, robj *key, robj *reply);
1847 int selectDb(client *c, int id);
1854 void scanGenericCommand(client *c, robj *o, unsigned long cursor);
1855 int parseScanCursorOrReply(client *c, robj *o, unsigned long *cursor);
1902 sds luaCreateFunction(client *c, lua_State *lua, robj *body);
1906 void blockClient(client *c, int btype);
1907 void unblockClient(client *c);
1908 void queueClientForReprocessing(client *c);
1909 void replyToBlockedClientTimedOut(client *c);
1910 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit);
1914 void blockForKeys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, s…
1941 void authCommand(client *c);
1942 void pingCommand(client *c);
1943 void echoCommand(client *c);
1944 void commandCommand(client *c);
1945 void setCommand(client *c);
1946 void setnxCommand(client *c);
1947 void setexCommand(client *c);
1948 void psetexCommand(client *c);
1949 void getCommand(client *c);
1950 void delCommand(client *c);
1951 void unlinkCommand(client *c);
1952 void existsCommand(client *c);
1953 void setbitCommand(client *c);
1954 void getbitCommand(client *c);
1955 void bitfieldCommand(client *c);
1956 void setrangeCommand(client *c);
1957 void getrangeCommand(client *c);
1958 void incrCommand(client *c);
1959 void decrCommand(client *c);
1960 void incrbyCommand(client *c);
1961 void decrbyCommand(client *c);
1962 void incrbyfloatCommand(client *c);
1963 void selectCommand(client *c);
1964 void swapdbCommand(client *c);
1965 void randomkeyCommand(client *c);
1966 void keysCommand(client *c);
1967 void scanCommand(client *c);
1968 void dbsizeCommand(client *c);
1969 void lastsaveCommand(client *c);
1970 void saveCommand(client *c);
1971 void bgsaveCommand(client *c);
1972 void bgrewriteaofCommand(client *c);
1973 void shutdownCommand(client *c);
1974 void moveCommand(client *c);
1975 void renameCommand(client *c);
1976 void renamenxCommand(client *c);
1977 void lpushCommand(client *c);
1978 void rpushCommand(client *c);
1979 void lpushxCommand(client *c);
1980 void rpushxCommand(client *c);
1981 void linsertCommand(client *c);
1982 void lpopCommand(client *c);
1983 void rpopCommand(client *c);
1984 void llenCommand(client *c);
1985 void lindexCommand(client *c);
1986 void lrangeCommand(client *c);
1987 void ltrimCommand(client *c);
1988 void typeCommand(client *c);
1989 void lsetCommand(client *c);
1990 void saddCommand(client *c);
1991 void sremCommand(client *c);
1992 void smoveCommand(client *c);
1993 void sismemberCommand(client *c);
1994 void scardCommand(client *c);
1995 void spopCommand(client *c);
1996 void srandmemberCommand(client *c);
1997 void sinterCommand(client *c);
1998 void sinterstoreCommand(client *c);
1999 void sunionCommand(client *c);
2000 void sunionstoreCommand(client *c);
2001 void sdiffCommand(client *c);
2002 void sdiffstoreCommand(client *c);
2003 void sscanCommand(client *c);
2004 void syncCommand(client *c);
2005 void flushdbCommand(client *c);
2006 void flushallCommand(client *c);
2007 void sortCommand(client *c);
2008 void lremCommand(client *c);
2009 void rpoplpushCommand(client *c);
2010 void infoCommand(client *c);
2011 void mgetCommand(client *c);
2012 void monitorCommand(client *c);
2013 void expireCommand(client *c);
2014 void expireatCommand(client *c);
2015 void pexpireCommand(client *c);
2016 void pexpireatCommand(client *c);
2017 void getsetCommand(client *c);
2018 void ttlCommand(client *c);
2019 void touchCommand(client *c);
2020 void pttlCommand(client *c);
2021 void persistCommand(client *c);
2022 void replicaofCommand(client *c);
2023 void roleCommand(client *c);
2024 void debugCommand(client *c);
2025 void msetCommand(client *c);
2026 void msetnxCommand(client *c);
2027 void zaddCommand(client *c);
2028 void zincrbyCommand(client *c);
2029 void zrangeCommand(client *c);
2030 void zrangebyscoreCommand(client *c);
2031 void zrevrangebyscoreCommand(client *c);
2032 void zrangebylexCommand(client *c);
2033 void zrevrangebylexCommand(client *c);
2034 void zcountCommand(client *c);
2035 void zlexcountCommand(client *c);
2036 void zrevrangeCommand(client *c);
2037 void zcardCommand(client *c);
2038 void zremCommand(client *c);
2039 void zscoreCommand(client *c);
2040 void zremrangebyscoreCommand(client *c);
2041 void zremrangebylexCommand(client *c);
2042 void zpopminCommand(client *c);
2043 void zpopmaxCommand(client *c);
2044 void bzpopminCommand(client *c);
2045 void bzpopmaxCommand(client *c);
2046 void multiCommand(client *c);
2047 void execCommand(client *c);
2048 void discardCommand(client *c);
2049 void blpopCommand(client *c);
2050 void brpopCommand(client *c);
2051 void brpoplpushCommand(client *c);
2052 void appendCommand(client *c);
2053 void strlenCommand(client *c);
2054 void zrankCommand(client *c);
2055 void zrevrankCommand(client *c);
2056 void hsetCommand(client *c);
2057 void hsetnxCommand(client *c);
2058 void hgetCommand(client *c);
2059 void hmsetCommand(client *c);
2060 void hmgetCommand(client *c);
2061 void hdelCommand(client *c);
2062 void hlenCommand(client *c);
2063 void hstrlenCommand(client *c);
2064 void zremrangebyrankCommand(client *c);
2065 void zunionstoreCommand(client *c);
2066 void zinterstoreCommand(client *c);
2067 void zscanCommand(client *c);
2068 void hkeysCommand(client *c);
2069 void hvalsCommand(client *c);
2070 void hgetallCommand(client *c);
2071 void hexistsCommand(client *c);
2072 void hscanCommand(client *c);
2073 void configCommand(client *c);
2074 void hincrbyCommand(client *c);
2075 void hincrbyfloatCommand(client *c);
2076 void subscribeCommand(client *c);
2077 void unsubscribeCommand(client *c);
2078 void psubscribeCommand(client *c);
2079 void punsubscribeCommand(client *c);
2080 void publishCommand(client *c);
2081 void pubsubCommand(client *c);
2082 void watchCommand(client *c);
2083 void unwatchCommand(client *c);
2084 void clusterCommand(client *c);
2085 void restoreCommand(client *c);
2086 void migrateCommand(client *c);
2087 void askingCommand(client *c);
2088 void readonlyCommand(client *c);
2089 void readwriteCommand(client *c);
2090 void dumpCommand(client *c);
2091 void objectCommand(client *c);
2092 void memoryCommand(client *c);
2093 void clientCommand(client *c);
2094 void evalCommand(client *c);
2095 void evalShaCommand(client *c);
2096 void scriptCommand(client *c);
2097 void timeCommand(client *c);
2098 void bitopCommand(client *c);
2099 void bitcountCommand(client *c);
2100 void bitposCommand(client *c);
2101 void replconfCommand(client *c);
2102 void waitCommand(client *c);
2103 void geoencodeCommand(client *c);
2104 void geodecodeCommand(client *c);
2105 void georadiusbymemberCommand(client *c);
2106 void georadiusbymemberroCommand(client *c);
2107 void georadiusCommand(client *c);
2108 void georadiusroCommand(client *c);
2109 void geoaddCommand(client *c);
2110 void geohashCommand(client *c);
2111 void geoposCommand(client *c);
2112 void geodistCommand(client *c);
2113 void pfselftestCommand(client *c);
2114 void pfaddCommand(client *c);
2115 void pfcountCommand(client *c);
2116 void pfmergeCommand(client *c);
2117 void pfdebugCommand(client *c);
2118 void latencyCommand(client *c);
2119 void moduleCommand(client *c);
2120 void securityWarningCommand(client *c);
2121 void xaddCommand(client *c);
2122 void xrangeCommand(client *c);
2123 void xrevrangeCommand(client *c);
2124 void xlenCommand(client *c);
2125 void xreadCommand(client *c);
2126 void xgroupCommand(client *c);
2127 void xsetidCommand(client *c);
2128 void xackCommand(client *c);
2129 void xpendingCommand(client *c);
2130 void xclaimCommand(client *c);
2131 void xinfoCommand(client *c);
2132 void xdelCommand(client *c);
2133 void xtrimCommand(client *c);
2134 void lolwutCommand(client *c);
2144 void _serverAssertWithInfo(const client *c, const robj *o, const char *estr, const char *file, int …