Home
last modified time | relevance | path

Searched refs:c (Results 1 – 25 of 153) sorted by relevance

1234567

/redis-3.2.3/src/
H A Dnetworking.c95 c->cmd = c->lastcmd = NULL; in createClient()
225 memcpy(c->buf+c->bufpos,s,len); in _addReplyToBuffer()
346 if (listLength(c->reply) == 0 && (sizeof(c->buf) - c->bufpos) >= 32) { in addReply()
872 if (c->name) decrRefCount(c->name); in freeClient()
910 nwritten = write(fd,c->buf+c->sentlen,c->bufpos-c->sentlen); in writeToClient()
1092 if (c->argv) zfree(c->argv); in processInlineBuffer()
1164 if (c->argv) zfree(c->argv); in processMultibulkBuffer()
1233 c->argv[c->argc++] = createObject(OBJ_STRING,c->querybuf); in processMultibulkBuffer()
1241 c->argv[c->argc++] = in processMultibulkBuffer()
1620 c->name = c->argv[2]; in clientCommand()
[all …]
H A Dt_string.c139 setGenericCommand(c,flags,c->argv[1],c->argv[2],expire,unit,NULL,NULL); in setCommand()
149 setGenericCommand(c,OBJ_SET_NO_FLAGS,c->argv[1],c->argv[3],c->argv[2],UNIT_SECONDS,NULL,NULL); in setexCommand()
154 …setGenericCommand(c,OBJ_SET_NO_FLAGS,c->argv[1],c->argv[3],c->argv[2],UNIT_MILLISECONDS,NULL,NULL); in psetexCommand()
179 setKey(c->db,c->argv[1],c->argv[2]); in getsetCommand()
197 o = lookupKeyWrite(c->db,c->argv[1]); in setrangeCommand()
210 dbAdd(c->db,c->argv[1],o); in setrangeCommand()
288 addReplyMultiBulkLen(c,c->argc-1); in mgetCommand()
326 setKey(c->db,c->argv[j],c->argv[j+1]); in msetGenericCommand()
368 dbAdd(c->db,c->argv[1],new); in incrDecrCommand()
420 dbAdd(c->db,c->argv[1],new); in incrbyfloatCommand()
[all …]
H A Dmulti.c62 mc = c->mstate.commands+c->mstate.count; in queueMultiCommand()
66 memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc); in queueMultiCommand()
144 addReplyMultiBulkLen(c,c->mstate.count); in execCommand()
146 c->argc = c->mstate.commands[j].argc; in execCommand()
147 c->argv = c->mstate.commands[j].argv; in execCommand()
148 c->cmd = c->mstate.commands[j].cmd; in execCommand()
162 c->mstate.commands[j].argc = c->argc; in execCommand()
163 c->mstate.commands[j].argv = c->argv; in execCommand()
164 c->mstate.commands[j].cmd = c->cmd; in execCommand()
181 replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc); in execCommand()
[all …]
H A Dpubsub.c82 addReplyLongLong(c,clientSubscriptionsCount(c)); in pubsubSubscribeChannel()
118 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeChannel()
144 addReplyLongLong(c,clientSubscriptionsCount(c)); in pubsubSubscribePattern()
169 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribePattern()
281 pubsubSubscribeChannel(c,c->argv[j]); in subscribeCommand()
292 pubsubUnsubscribeChannel(c,c->argv[j],1); in unsubscribeCommand()
301 pubsubSubscribePattern(c,c->argv[j]); in psubscribeCommand()
312 pubsubUnsubscribePattern(c,c->argv[j],1); in punsubscribeCommand()
329 (c->argc == 2 || c->argc ==3)) in pubsubCommand()
356 addReplyMultiBulkLen(c,(c->argc-2)*2); in pubsubCommand()
[all …]
H A Dt_list.c212 dbAdd(c->db,c->argv[1],lobj); in pushGenericCommand()
221 signalModifiedKey(c->db,c->argv[1]); in pushGenericCommand()
270 signalModifiedKey(c->db,c->argv[1]); in pushxGenericCommand()
291 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_TAIL); in linsertCommand()
293 pushxGenericCommand(c,c->argv[3],c->argv[4],LIST_HEAD); in linsertCommand()
374 dbDelete(c->db,c->argv[1]); in popGenericCommand()
473 dbDelete(c->db,c->argv[1]); in ltrimCommand()
476 signalModifiedKey(c->db,c->argv[1]); in ltrimCommand()
518 dbDelete(c->db,c->argv[1]); in lremCommand()
924 blockForKeys(c, c->argv + 1, c->argc - 2, timeout, NULL); in blockingPopGenericCommand()
[all …]
H A Dt_set.c279 dbAdd(c->db,c->argv[1],set); in saddCommand()
359 dbDelete(c->db,c->argv[1]); in smoveCommand()
366 dbAdd(c->db,c->argv[2],dstset); in smoveCommand()
451 dbDelete(c->db,c->argv[1]); in spopWithCountCommand()
605 dbDelete(c->db,c->argv[1]); in spopCommand()
928 sinterGenericCommand(c,c->argv+1,c->argc-1,NULL); in sinterCommand()
932 sinterGenericCommand(c,c->argv+2,c->argc-2,c->argv[1]); in sinterstoreCommand()
1099 sunionDiffGenericCommand(c,c->argv+1,c->argc-1,NULL,SET_OP_UNION); in sunionCommand()
1103 sunionDiffGenericCommand(c,c->argv+2,c->argc-2,c->argv[1],SET_OP_UNION); in sunionstoreCommand()
1107 sunionDiffGenericCommand(c,c->argv+1,c->argc-1,NULL,SET_OP_DIFF); in sdiffCommand()
[all …]
H A Dblocked.c101 c->flags |= CLIENT_BLOCKED; in blockClient()
102 c->btype = btype; in blockClient()
111 client *c; in processUnblockedClients() local
116 c = ln->value; in processUnblockedClients()
125 if (c->querybuf && sdslen(c->querybuf) > 0) { in processUnblockedClients()
134 void unblockClient(client *c) { in unblockClient() argument
144 c->flags &= ~CLIENT_BLOCKED; in unblockClient()
145 c->btype = BLOCKED_NONE; in unblockClient()
161 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
183 addReplySds(c,sdsnew( in disconnectAllBlockedClients()
[all …]
H A Dt_hash.c495 signalModifiedKey(c->db,c->argv[1]); in hsetCommand()
509 hashTypeSet(o,c->argv[2],c->argv[3]); in hsetnxCommand()
511 signalModifiedKey(c->db,c->argv[1]); in hsetnxCommand()
533 signalModifiedKey(c->db,c->argv[1]); in hmsetCommand()
567 signalModifiedKey(c->db,c->argv[1]); in hincrbyCommand()
594 signalModifiedKey(c->db,c->argv[1]); in hincrbyfloatCommand()
653 addHashFieldToReply(c, o, c->argv[2]); in hgetCommand()
662 o = lookupKeyRead(c->db, c->argv[1]); in hmgetCommand()
668 addReplyMultiBulkLen(c, c->argc-2); in hmgetCommand()
685 dbDelete(c->db,c->argv[1]); in hdelCommand()
[all …]
H A Dsha1.c81 R0(a,b,c,d,e, 0); R0(e,a,b,c,d, 1); R0(d,e,a,b,c, 2); R0(c,d,e,a,b, 3); in SHA1Transform()
82 R0(b,c,d,e,a, 4); R0(a,b,c,d,e, 5); R0(e,a,b,c,d, 6); R0(d,e,a,b,c, 7); in SHA1Transform()
83 R0(c,d,e,a,b, 8); R0(b,c,d,e,a, 9); R0(a,b,c,d,e,10); R0(e,a,b,c,d,11); in SHA1Transform()
84 R0(d,e,a,b,c,12); R0(c,d,e,a,b,13); R0(b,c,d,e,a,14); R0(a,b,c,d,e,15); in SHA1Transform()
85 R1(e,a,b,c,d,16); R1(d,e,a,b,c,17); R1(c,d,e,a,b,18); R1(b,c,d,e,a,19); in SHA1Transform()
86 R2(a,b,c,d,e,20); R2(e,a,b,c,d,21); R2(d,e,a,b,c,22); R2(c,d,e,a,b,23); in SHA1Transform()
87 R2(b,c,d,e,a,24); R2(a,b,c,d,e,25); R2(e,a,b,c,d,26); R2(d,e,a,b,c,27); in SHA1Transform()
88 R2(c,d,e,a,b,28); R2(b,c,d,e,a,29); R2(a,b,c,d,e,30); R2(e,a,b,c,d,31); in SHA1Transform()
89 R2(d,e,a,b,c,32); R2(c,d,e,a,b,33); R2(b,c,d,e,a,34); R2(a,b,c,d,e,35); in SHA1Transform()
90 R2(e,a,b,c,d,36); R2(d,e,a,b,c,37); R2(c,d,e,a,b,38); R2(b,c,d,e,a,39); in SHA1Transform()
[all …]
H A Dserver.h1094 void freeClient(client *c);
1096 void resetClient(client *c);
1479 void authCommand(client *c);
1480 void pingCommand(client *c);
1481 void echoCommand(client *c);
1483 void setCommand(client *c);
1487 void getCommand(client *c);
1488 void delCommand(client *c);
1495 void incrCommand(client *c);
1496 void decrCommand(client *c);
[all …]
H A Dredis-benchmark.c199 if (c->latency < 0) c->latency = ustime()-(c->start); in readHandler()
278 if (sdslen(c->obuf) > c->written) { in writeHandler()
279 void *ptr = c->obuf+c->written; in writeHandler()
280 ssize_t nwritten = write(c->context->fd,ptr,sdslen(c->obuf)-c->written); in writeHandler()
288 if (sdslen(c->obuf) == c->written) { in writeHandler()
347 c->obuf = sdscatlen(c->obuf, buf, len); in createClient()
361 c->prefixlen = sdslen(c->obuf); in createClient()
364 c->obuf = sdscatlen(c->obuf, in createClient()
397 c->randptr = zrealloc(c->randptr,sizeof(char*)*c->randlen*2); in createClient()
398 c->randfree += c->randlen; in createClient()
[all …]
H A Ddb.c348 expireIfNeeded(c->db,c->argv[j]); in delCommand()
349 if (dbDelete(c->db,c->argv[j])) { in delCommand()
367 expireIfNeeded(c->db,c->argv[j]); in existsCommand()
749 expire = getExpire(c->db,c->argv[1]); in renameGenericCommand()
758 dbDelete(c->db,c->argv[2]); in renameGenericCommand()
760 dbAdd(c->db,c->argv[2],o); in renameGenericCommand()
762 dbDelete(c->db,c->argv[1]); in renameGenericCommand()
763 signalModifiedKey(c->db,c->argv[1]); in renameGenericCommand()
764 signalModifiedKey(c->db,c->argv[2]); in renameGenericCommand()
766 c->argv[1],c->db->id); in renameGenericCommand()
[all …]
H A Dgeo.c139 addReplyError(c, in extractUnitOrReply()
407 if (extractLongLatOrReply(c, (c->argv+2)+(i*3),xy) == C_ERR) { in geoaddCommand()
427 zaddCommand(c); in geoaddCommand()
457 if (extractLongLatOrReply(c, c->argv + 2, xy) == C_ERR) in georadiusGeneric()
473 if ((radius_meters = extractDistanceOrReply(c, c->argv + base_args - 2, in georadiusGeneric()
497 if (getLongLongFromObjectOrReply(c, c->argv[base_args+i+1], in georadiusGeneric()
670 if ((zobj = lookupKeyReadOrReply(c, c->argv[1], shared.emptymultibulk)) in geohashCommand()
675 addReplyMultiBulkLen(c,c->argc-2); in geohashCommand()
729 addReplyMultiBulkLen(c,c->argc-2); in geoposCommand()
758 to_meter = extractUnitOrReply(c,c->argv[4]); in geodistCommand()
[all …]
H A Dbitops.c122 c++; in redisBitpos()
149 c++; in redisBitpos()
473 robj *o = lookupKeyWrite(c->db,c->argv[1]); in lookupStringForBitCommand()
477 dbAdd(c->db,c->argv[1],o); in lookupStringForBitCommand()
480 o = dbUnshareStringValue(c->db,c->argv[1],o); in lookupStringForBitCommand()
550 signalModifiedKey(c->db,c->argv[1]); in setbitCommand()
621 o = lookupKeyRead(c->db,c->argv[j+3]); in bitopCommand()
826 if ((o = lookupKeyRead(c->db,c->argv[1])) == NULL) { in bitposCommand()
834 if (c->argc == 4 || c->argc == 5) { in bitposCommand()
984 o = lookupKeyRead(c->db,c->argv[1]); in bitfieldCommand()
[all …]
H A Ddebug.c332 if (c->argc >= 3) c->argv[2] = tryObjectEncoding(c->argv[2]); in debugCommand()
333 serverAssertWithInfo(c,c->argv[0],1 == 2); in debugCommand()
356 } else if (!strcasecmp(c->argv[1]->ptr,"object") && c->argc == 3) { in debugCommand()
361 if ((de = dictFind(c->db->dict,c->argv[2]->ptr)) == NULL) { in debugCommand()
413 if ((de = dictFind(c->db->dict,c->argv[2]->ptr)) == NULL) { in debugCommand()
432 (c->argc == 3 || c->argc == 4)) { in debugCommand()
442 (c->argc == 3) ? "key" : (char*)c->argv[3]->ptr, j); in debugCommand()
465 } else if (!strcasecmp(c->argv[1]->ptr,"sleep") && c->argc == 3) { in debugCommand()
484 } else if (!strcasecmp(c->argv[1]->ptr,"error") && c->argc == 3) { in debugCommand()
584 c->argv[j]->type, c->argv[j]->encoding); in _serverAssertPrintClientInfo()
[all …]
/redis-3.2.3/deps/hiredis/
H A Dnet.c58 if (c && c->fd >= 0) { in redisContextCloseFd()
59 close(c->fd); in redisContextCloseFd()
60 c->fd = -1; in redisContextCloseFd()
78 redisContextCloseFd(c); in redisSetReuseAddr()
90 c->fd = s; in redisCreateSocket()
107 redisContextCloseFd(c); in redisSetBlocking()
118 redisContextCloseFd(c); in redisSetBlocking()
126 int fd = c->fd; in redisKeepAlive()
183 wfd[0].fd = c->fd; in redisContextWaitReady()
222 redisContextCloseFd(c); in redisContextWaitReady()
[all …]
H A Dhiredis.c291 char c; in readLongLong() local
707 if (*c != '%' || c[1] == '\0') { in redisvFormatCommand()
857 c++; in redisvFormatCommand()
985 strerror_r(errno,c->errstr,sizeof(c->errstr)); in __redisSetError()
1000 return c; in redisContextInit()
1010 free(c); in redisFree()
1015 c->fd = -1; in redisFreeKeepFd()
1032 return c; in redisConnect()
1155 __redisSetError(c,c->reader->err,c->reader->errstr); in redisBufferRead()
1179 nwritten = write(c->fd,c->obuf,sdslen(c->obuf)); in redisBufferWrite()
[all …]
H A Dasync.c112 c = &(ac->c); in redisAsyncInitialize()
145 redisContext *c = &(ac->c); in __redisAsyncCopyError() 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
483 redisContext *c = &(ac->c); in __redisAsyncHandleConnect() local
[all …]
H A Dtest.c65 return c; in select_database()
82 redisFree(c); in disconnect()
105 if (c == NULL) { in connect()
221 redisContext *c; in test_append_formatted_commands() local
322 redisContext *c; in test_blocking_connection_errors() local
332 redisFree(c); in test_blocking_connection_errors()
338 redisFree(c); in test_blocking_connection_errors()
343 redisFree(c); in test_blocking_connection_errors()
464 redisFree(c); in test_blocking_io_errors()
472 redisFree(c); in test_blocking_io_errors()
[all …]
/redis-3.2.3/deps/lua/src/
H A Dlua_cmsgpack.c573 mp_cur_need(c,1); in mp_decode_to_lua_type()
584 switch(c->p[0]) { in mp_decode_to_lua_type()
586 mp_cur_need(c,2); in mp_decode_to_lua_type()
591 mp_cur_need(c,2); in mp_decode_to_lua_type()
596 mp_cur_need(c,3); in mp_decode_to_lua_type()
599 c->p[2]); in mp_decode_to_lua_type()
606 c->p[2]); in mp_decode_to_lua_type()
703 size_t l = (c->p[1] << 8) | c->p[2]; in mp_decode_to_lua_type()
725 size_t l = (c->p[1] << 8) | c->p[2]; in mp_decode_to_lua_type()
744 size_t l = (c->p[1] << 8) | c->p[2]; in mp_decode_to_lua_type()
[all …]
/redis-3.2.3/deps/jemalloc/
H A DMakefile.in81 C_SRCS := $(srcroot)src/jemalloc.c $(srcroot)src/arena.c \
82 $(srcroot)src/atomic.c $(srcroot)src/base.c $(srcroot)src/bitmap.c \
83 $(srcroot)src/chunk.c $(srcroot)src/chunk_dss.c \
84 $(srcroot)src/chunk_mmap.c $(srcroot)src/ckh.c $(srcroot)src/ctl.c \
85 $(srcroot)src/extent.c $(srcroot)src/hash.c $(srcroot)src/huge.c \
86 $(srcroot)src/mb.c $(srcroot)src/mutex.c $(srcroot)src/pages.c \
87 $(srcroot)src/prof.c $(srcroot)src/quarantine.c $(srcroot)src/rtree.c \
88 $(srcroot)src/stats.c $(srcroot)src/tcache.c $(srcroot)src/util.c \
116 $(srcroot)test/src/mtx.c $(srcroot)test/src/mq.c \
117 $(srcroot)test/src/SFMT.c $(srcroot)test/src/test.c \
[all …]
/redis-3.2.3/deps/hiredis/examples/
H A Dexample.c9 redisContext *c; in main() local
16 if (c == NULL || c->err) { in main()
17 if (c) { in main()
19 redisFree(c); in main()
27 reply = redisCommand(c,"PING"); in main()
42 reply = redisCommand(c,"GET foo"); in main()
46 reply = redisCommand(c,"INCR counter"); in main()
50 reply = redisCommand(c,"INCR counter"); in main()
55 reply = redisCommand(c,"DEL mylist"); in main()
66 reply = redisCommand(c,"LRANGE mylist 0 -1"); in main()
[all …]
H A Dexample-libev.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
16 redisAsyncDisconnect(c); in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback() argument
21 printf("Error: %s\n", c->errstr); in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback() argument
29 printf("Error: %s\n", c->errstr); in disconnectCallback()
39 if (c->err) { in main()
41 printf("Error: %s\n", c->errstr); in main()
45 redisLibevAttach(EV_DEFAULT_ c); in main()
46 redisAsyncSetConnectCallback(c,connectCallback); in main()
[all …]
H A Dexample-libevent.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
16 redisAsyncDisconnect(c); in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback() argument
21 printf("Error: %s\n", c->errstr); in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback() argument
29 printf("Error: %s\n", c->errstr); in disconnectCallback()
40 if (c->err) { in main()
42 printf("Error: %s\n", c->errstr); in main()
46 redisLibeventAttach(c,base); in main()
47 redisAsyncSetConnectCallback(c,connectCallback); in main()
[all …]
H A Dexample-libuv.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
16 redisAsyncDisconnect(c); in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback() argument
21 printf("Error: %s\n", c->errstr); in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback() argument
29 printf("Error: %s\n", c->errstr); in disconnectCallback()
40 if (c->err) { in main()
42 printf("Error: %s\n", c->errstr); in main()
46 redisLibuvAttach(c,loop); in main()
47 redisAsyncSetConnectCallback(c,connectCallback); in main()
[all …]

1234567