Home
last modified time | relevance | path

Searched defs:c (Results 1 – 25 of 91) sorted by relevance

1234

/redis-3.2.3/src/
H A Dt_string.c96 void setCommand(client *c) { in setCommand()
142 void setnxCommand(client *c) { in setnxCommand()
147 void setexCommand(client *c) { in setexCommand()
152 void psetexCommand(client *c) { in psetexCommand()
172 void getCommand(client *c) { in getCommand()
176 void getsetCommand(client *c) { in getsetCommand()
285 void mgetCommand(client *c) { in mgetCommand()
333 void msetCommand(client *c) { in msetCommand()
337 void msetnxCommand(client *c) { in msetnxCommand()
379 void incrCommand(client *c) { in incrCommand()
[all …]
H A Dmulti.c35 void initClientMultiState(client *c) { in initClientMultiState()
41 void freeClientMultiState(client *c) { in freeClientMultiState()
56 void queueMultiCommand(client *c) { in queueMultiCommand()
72 void discardTransaction(client *c) { in discardTransaction()
81 void flagTransaction(client *c) { in flagTransaction()
86 void multiCommand(client *c) { in multiCommand()
95 void discardCommand(client *c) { in discardCommand()
114 void execCommand(client *c) { in execCommand()
233 void unwatchAllKeys(client *c) { in unwatchAllKeys()
307 void watchCommand(client *c) { in watchCommand()
[all …]
H A Dnetworking.c155 int prepareClientToWrite(client *c) { in prepareClientToWrite()
617 client *c; in acceptCommonHandler() local
746 void unlinkClient(client *c) { in unlinkClient()
786 void freeClient(client *c) { in freeClient()
883 void freeClientAsync(client *c) { in freeClientAsync()
1025 void resetClient(client *c) { in resetClient()
1366 client *c; in getClientsMaxBuffers() local
1408 char *getClientPeerId(client *c) { in getClientPeerId()
1485 void clientCommand(client *c) { in clientCommand()
1739 int getClientType(client *c) { in getClientType()
[all …]
H A Dblocked.c76 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply()
100 void blockClient(client *c, int btype) { in blockClient()
111 client *c; in processUnblockedClients() local
134 void unblockClient(client *c) { in unblockClient()
157 void replyToBlockedClientTimedOut(client *c) { in replyToBlockedClientTimedOut()
180 client *c = listNodeValue(ln); in disconnectAllBlockedClients() local
H A Dpubsub.c51 int clientSubscriptionsCount(client *c) { in clientSubscriptionsCount()
58 int pubsubSubscribeChannel(client *c, robj *channel) { in pubsubSubscribeChannel()
127 int pubsubSubscribePattern(client *c, robj *pattern) { in pubsubSubscribePattern()
178 int pubsubUnsubscribeAllChannels(client *c, int notify) { in pubsubUnsubscribeAllChannels()
240 client *c = ln->value; in pubsubPublishMessage() local
277 void subscribeCommand(client *c) { in subscribeCommand()
285 void unsubscribeCommand(client *c) { in unsubscribeCommand()
297 void psubscribeCommand(client *c) { in psubscribeCommand()
305 void punsubscribeCommand(client *c) { in punsubscribeCommand()
317 void publishCommand(client *c) { in publishCommand()
[all …]
H A Dt_list.c227 void lpushCommand(client *c) { in lpushCommand()
231 void rpushCommand(client *c) { in rpushCommand()
278 void lpushxCommand(client *c) { in lpushxCommand()
283 void rpushxCommand(client *c) { in rpushxCommand()
299 void llenCommand(client *c) { in llenCommand()
305 void lindexCommand(client *c) { in lindexCommand()
332 void lsetCommand(client *c) { in lsetCommand()
381 void lpopCommand(client *c) { in lpopCommand()
385 void rpopCommand(client *c) { in rpopCommand()
435 void ltrimCommand(client *c) { in ltrimCommand()
[all …]
H A Dt_set.c272 void saddCommand(client *c) { in saddCommand()
299 void sremCommand(client *c) { in sremCommand()
327 void smoveCommand(client *c) { in smoveCommand()
381 void sismemberCommand(client *c) { in sismemberCommand()
394 void scardCommand(client *c) { in scardCommand()
562 void spopCommand(client *c) { in spopCommand()
927 void sinterCommand(client *c) { in sinterCommand()
1098 void sunionCommand(client *c) { in sunionCommand()
1106 void sdiffCommand(client *c) { in sdiffCommand()
1110 void sdiffstoreCommand(client *c) { in sdiffstoreCommand()
[all …]
H A Ddb.c317 void flushdbCommand(client *c) { in flushdbCommand()
344 void delCommand(client *c) { in delCommand()
362 void existsCommand(client *c) { in existsCommand()
373 void selectCommand(client *c) { in selectCommand()
403 void keysCommand(client *c) { in keysCommand()
669 void scanCommand(client *c) { in scanCommand()
683 void typeCommand(client *c) { in typeCommand()
781 void moveCommand(client *c) { in moveCommand()
1027 void ttlCommand(client *c) { in ttlCommand()
1031 void pttlCommand(client *c) { in pttlCommand()
[all …]
H A Dt_hash.c486 void hsetCommand(client *c) { in hsetCommand()
500 void hsetnxCommand(client *c) { in hsetnxCommand()
517 void hmsetCommand(client *c) { in hmsetCommand()
538 void hincrbyCommand(client *c) { in hincrbyCommand()
647 void hgetCommand(client *c) { in hgetCommand()
656 void hmgetCommand(client *c) { in hmgetCommand()
674 void hdelCommand(client *c) { in hdelCommand()
702 void hlenCommand(client *c) { in hlenCommand()
774 void hkeysCommand(client *c) { in hkeysCommand()
778 void hvalsCommand(client *c) { in hvalsCommand()
[all …]
H A Dgeo.c93 int extractLongLatOrReply(client *c, robj **argv, double *xy) { in extractLongLatOrReply()
127 double extractUnitOrReply(client *c, robj *unit) { in extractUnitOrReply()
152 double extractDistanceOrReply(client *c, robj **argv, in extractDistanceOrReply()
179 void addReplyDoubleDistance(client *c, double d) { in addReplyDoubleDistance()
384 void geoaddCommand(client *c) { in geoaddCommand()
440 void georadiusGeneric(client *c, int type) { in georadiusGeneric()
651 void georadiusCommand(client *c) { in georadiusCommand()
656 void georadiusByMemberCommand(client *c) { in georadiusByMemberCommand()
664 void geohashCommand(client *c) { in geohashCommand()
719 void geoposCommand(client *c) { in geoposCommand()
[all …]
H A Dredis-benchmark.c125 static void freeClient(client c) { in freeClient()
149 static void resetClient(client c) { in resetClient()
157 static void randomizeClientKey(client c) { in randomizeClientKey()
173 static void clientDone(client c) { in clientDone()
190 client c = privdata; in readHandler() local
259 client c = privdata; in writeHandler() local
318 client c = zmalloc(sizeof(struct _client)); in createClient() local
413 static void createMissingClients(client c) { in createMissingClients()
462 client c; in benchmark() local
653 client c; in main() local
H A Dt_zset.c482 char *c = item->ptr; in zslParseLexRangeItem() local
1403 void zaddCommand(client *c) { in zaddCommand()
1407 void zincrbyCommand(client *c) { in zincrbyCommand()
1411 void zremCommand(client *c) { in zremCommand()
2284 void zrangeCommand(client *c) { in zrangeCommand()
2487 void zcountCommand(client *c) { in zcountCommand()
2828 void zcardCommand(client *c) { in zcardCommand()
2838 void zscoreCommand(client *c) { in zscoreCommand()
2915 void zrankCommand(client *c) { in zrankCommand()
2919 void zrevrankCommand(client *c) { in zrevrankCommand()
[all …]
H A Dbitops.c103 unsigned char *c; in redisBitpos() local
354 uint64_t a = value, b = incr, c; in checkSignedBitfieldOverflow() local
404 int getBitOffsetFromArgument(client *c, robj *o, size_t *offset, int hash, int bits) { in getBitOffsetFromArgument()
440 int getBitfieldTypeFromArgument(client *c, robj *o, int *sign, int *bits) { in getBitfieldTypeFromArgument()
471 robj *lookupStringForBitCommand(client *c, size_t maxbit) { in lookupStringForBitCommand()
518 void setbitCommand(client *c) { in setbitCommand()
557 void getbitCommand(client *c) { in getbitCommand()
584 void bitopCommand(client *c) { in bitopCommand()
758 void bitcountCommand(client *c) { in bitcountCommand()
807 void bitposCommand(client *c) { in bitposCommand()
[all …]
H A Dreplication.c52 char *replicationGetSlaveName(client *c) { in replicationGetSlaveName()
416 int masterTryPartialResynchronization(client *c) { in masterTryPartialResynchronization()
564 void syncCommand(client *c) { in syncCommand()
706 void replconfCommand(client *c) { in replconfCommand()
1773 void slaveofCommand(client *c) { in slaveofCommand()
1819 void roleCommand(client *c) { in roleCommand()
1876 client *c = server.master; in replicationSendAck() local
1908 void replicationCacheMaster(client *c) { in replicationCacheMaster()
2137 void waitCommand(client *c) { in waitCommand()
2172 void unblockClientWaitingReplicas(client *c) { in unblockClientWaitingReplicas()
[all …]
/redis-3.2.3/deps/hiredis/
H A Dnet.c57 static void redisContextCloseFd(redisContext *c) { in redisContextCloseFd()
74 static int redisSetReuseAddr(redisContext *c) { in redisSetReuseAddr()
84 static int redisCreateSocket(redisContext *c, int type) { in redisCreateSocket()
99 static int redisSetBlocking(redisContext *c, int blocking) { in redisSetBlocking()
124 int redisKeepAlive(redisContext *c, int interval) { in redisKeepAlive()
166 static int redisSetTcpNoDelay(redisContext *c) { in redisSetTcpNoDelay()
226 int redisCheckSocketError(redisContext *c) { in redisCheckSocketError()
244 int redisContextSetTimeout(redisContext *c, const struct timeval tv) { in redisContextSetTimeout()
256 static int _redisContextConnectTcp(redisContext *c, const char *addr, int port, in _redisContextConnectTcp()
345 int redisContextConnectTcp(redisContext *c, const char *addr, int port, in redisContextConnectTcp()
[all …]
H A Dhiredis.c291 char c; in readLongLong() local
687 const char *c = format; in redisvFormatCommand() local
990 redisContext *c; in redisContextInit() local
1003 void redisFree(redisContext *c) { in redisFree()
1024 redisContext *c; in redisConnect() local
1036 redisContext *c; in redisConnectWithTimeout() local
1048 redisContext *c; in redisConnectNonBlock() local
1068 redisContext *c; in redisConnectUnix() local
1080 redisContext *c; in redisConnectUnixWithTimeout() local
1092 redisContext *c; in redisConnectUnixNonBlock() local
[all …]
H A Dasync.c145 redisContext *c = &(ac->c); in __redisAsyncCopyError() local
151 redisContext *c; in redisAsyncConnect() local
177 redisContext *c; in redisAsyncConnectUnix() local
255 redisContext *c = &(ac->c); in __redisRunCallback() local
265 redisContext *c = &(ac->c); in __redisAsyncFree() local
313 redisContext *c = &(ac->c); in redisAsyncFree() local
321 redisContext *c = &(ac->c); in __redisAsyncDisconnect() local
347 redisContext *c = &(ac->c); in redisAsyncDisconnect() local
354 redisContext *c = &(ac->c); in __redisGetSubscribeCallback() local
401 redisContext *c = &(ac->c); in redisProcessCallbacks() local
[all …]
H A Dtest.c46 static redisContext *select_database(redisContext *c) { in select_database()
68 static int disconnect(redisContext *c, int keep_fd) { in disconnect()
87 redisContext *c = NULL; in connect() local
221 redisContext *c; in test_append_formatted_commands() local
322 redisContext *c; in test_blocking_connection_errors() local
347 redisContext *c; in test_blocking_connection() local
425 redisContext *c; in test_blocking_io_errors() local
476 redisContext *c; in test_invalid_timeout_errors() local
500 redisContext *c = connect(config); in test_throughput() local
/redis-3.2.3/deps/hiredis/examples/
H A Dexample-libev.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
38 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main() local
H A Dexample-libevent.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
39 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main() local
H A Dexample-libuv.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
39 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main() local
H A Dexample-ae.c13 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
22 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
32 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
46 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main() local
/redis-3.2.3/deps/jemalloc/include/jemalloc/internal/
H A Datomic.h102 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
144 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
180 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
212 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
244 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
275 atomic_cas_uint64(uint64_t *p, uint64_t c, uint64_t s) in atomic_cas_uint64()
326 atomic_cas_uint32(uint32_t *p, uint32_t c, uint32_t s) in atomic_cas_uint32()
368 atomic_cas_uint32(uint32_t *p, uint32_t c, uint32_t s) in atomic_cas_uint32()
530 atomic_cas_p(void **p, void *c, void *s) in atomic_cas_p()
578 atomic_cas_z(size_t *p, size_t c, size_t s) in atomic_cas_z()
[all …]
H A Dprng.h28 #define prng32(r, lg_range, state, a, c) do { \ argument
38 #define prng64(r, lg_range, state, a, c) do { \ argument
/redis-3.2.3/deps/lua/src/
H A Dstrbuf.h116 static inline void strbuf_append_char(strbuf_t *s, const char c) in strbuf_append_char()
122 static inline void strbuf_append_char_unsafe(strbuf_t *s, const char c) in strbuf_append_char_unsafe()
127 static inline void strbuf_append_mem(strbuf_t *s, const char *c, int len) in strbuf_append_mem()
134 static inline void strbuf_append_mem_unsafe(strbuf_t *s, const char *c, int len) in strbuf_append_mem_unsafe()

1234