Home
last modified time | relevance | path

Searched refs:robj (Results 1 – 25 of 31) sorted by relevance

12

/redis-3.2.3/src/
H A Dserver.h1188 robj *resetRefCount(robj *obj);
1198 robj *dupStringObject(robj *o);
1200 robj *tryObjectEncoding(robj *o);
1201 robj *getDecodedObject(robj *o);
1346 robj *setTypeCreate(robj *value);
1362 void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2);
1363 robj *hashTypeGetObject(robj *o, robj *key);
1365 int hashTypeSet(robj *o, robj *key, robj *value);
1408 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply);
1409 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply);
[all …]
H A Dobject.c97 robj *o; in createStringObjectFromLongLong()
163 robj *dupStringObject(robj *o) { in dupStringObject()
164 robj *d; in dupStringObject()
337 robj *resetRefCount(robj *obj) { in resetRefCount()
361 robj *tryObjectEncoding(robj *o) { in tryObjectEncoding()
442 robj *getDecodedObject(robj *o) { in getDecodedObject()
504 int compareStringObjects(robj *a, robj *b) { in compareStringObjects()
509 int collateStringObjects(robj *a, robj *b) { in collateStringObjects()
517 int equalStringObjects(robj *a, robj *b) { in equalStringObjects()
694 robj *objectCommandLookup(client *c, robj *key) { in objectCommandLookup()
[all …]
H A Dt_hash.c56 void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2) { in hashTypeTryObjectEncoding()
65 int hashTypeGetFromZiplist(robj *o, robj *field, in hashTypeGetFromZiplist()
101 int hashTypeGetFromHashTable(robj *o, robj *field, robj **value) { in hashTypeGetFromHashTable()
118 robj *hashTypeGetObject(robj *o, robj *field) { in hashTypeGetObject()
149 size_t hashTypeGetValueLength(robj *o, robj *field) { in hashTypeGetValueLength()
171 int hashTypeExists(robj *o, robj *field) { in hashTypeExists()
192 int hashTypeSet(robj *o, robj *field, robj *value) { in hashTypeSet()
246 int hashTypeDelete(robj *o, robj *field) { in hashTypeDelete()
488 robj *o; in hsetCommand()
501 robj *o; in hsetnxCommand()
[all …]
H A Ddb.c47 robj *lookupKey(redisDb *db, robj *key, int flags) { in lookupKey()
89 robj *val; in lookupKeyReadWithFlags()
127 robj *lookupKeyRead(redisDb *db, robj *key) { in lookupKeyRead()
136 robj *lookupKeyWrite(redisDb *db, robj *key) { in lookupKeyWrite()
141 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply) { in lookupKeyReadOrReply()
147 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply) { in lookupKeyWriteOrReply()
157 void dbAdd(redisDb *db, robj *key, robj *val) { in dbAdd()
171 void dbOverwrite(redisDb *db, robj *key, robj *val) { in dbOverwrite()
184 void setKey(redisDb *db, robj *key, robj *val) { in setKey()
265 robj *dbUnshareStringValue(redisDb *db, robj *key, robj *o) { in dbUnshareStringValue()
[all …]
H A Dt_set.c42 robj *setTypeCreate(robj *value) { in setTypeCreate()
53 int setTypeAdd(robj *subject, robj *value) { in setTypeAdd()
88 int setTypeRemove(robj *setobj, robj *value) { in setTypeRemove()
107 int setTypeIsMember(robj *subject, robj *value) { in setTypeIsMember()
273 robj *set; in saddCommand()
300 robj *set; in sremCommand()
382 robj *set; in sismemberCommand()
395 robj *o; in scardCommand()
786 robj *o1 = *(robj**)s1, *o2 = *(robj**)s2; in qsortCompareSetsByRevCardinality()
793 robj **sets = zmalloc(sizeof(robj*)*setnum); in sinterGenericCommand()
[all …]
H A Dt_list.c41 void listTypePush(robj *subject, robj *value, int where) { in listTypePush()
57 robj *listTypePop(robj *subject, int where) { in listTypePop()
59 robj *value = NULL; in listTypePop()
235 void pushxGenericCommand(client *c, robj *refval, robj *val, int where) { in pushxGenericCommand()
236 robj *subject; in pushxGenericCommand()
390 robj *o; in lrangeCommand()
436 robj *o; in ltrimCommand()
541 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush()
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList()
731 robj *argv[3]; in serveClientBlockedOnList()
[all …]
H A Drdb.h105 int rdbSaveObjectType(rio *rdb, robj *o);
112 ssize_t rdbSaveObject(rio *rdb, robj *o);
113 size_t rdbSavedObjectLen(robj *o);
114 robj *rdbLoadObject(int type, rio *rdb);
116 int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val, long long expiretime, long long now);
117 robj *rdbLoadStringObject(rio *rdb);
H A Dgeo.c113 int longLatFromMember(robj *zobj, robj *member, double *xy) { in longLatFromMember()
272 robj *o = ln->obj; in geoGetPointsInRange()
395 robj **argv = zcalloc(argc*sizeof(robj*)); in geoaddCommand()
441 robj *key = c->argv[1]; in georadiusGeneric()
442 robj *storekey = NULL; in georadiusGeneric()
446 robj *zobj = NULL; in georadiusGeneric()
461 robj *member = c->argv[2]; in georadiusGeneric()
607 robj *zobj; in georadiusGeneric()
669 robj *zobj = NULL; in geohashCommand()
723 robj *zobj = NULL; in geoposCommand()
[all …]
H A Dt_string.c67 …id setGenericCommand(client *c, int flags, robj *key, robj *val, robj *expire, int unit, robj *ok_… in setGenericCommand()
98 robj *expire = NULL; in setCommand()
104 robj *next = (j == c->argc-1) ? NULL : c->argv[j+1]; in setCommand()
158 robj *o; in getGenericCommand()
185 robj *o; in setrangeCommand()
245 robj *o; in getrangeCommand()
290 robj *o = lookupKeyRead(c->db,c->argv[j]); in mgetCommand()
343 robj *o, *new; in incrDecrCommand()
403 robj *o, *new, *aux; in incrbyfloatCommand()
437 robj *o, *append; in appendCommand()
[all …]
H A Dt_zset.c481 int zslParseLexRangeItem(robj *item, robj **dest, int *ex) { in zslParseLexRangeItem()
542 int compareStringObjectsForLexRange(robj *a, robj *b) { in compareStringObjectsForLexRange()
1096 robj *ele; in zsetConvert()
1185 int zsetScore(robj *zobj, robj *member, double *score) { in zsetScore()
1214 robj *ele; in zaddGenericCommand()
1215 robj *zobj; in zaddGenericCommand()
1413 robj *zobj; in zremCommand()
1477 robj *zobj; in zremrangeGenericCommand()
1636 robj *ele;
1943 robj *tmp; in zunionInterGenericCommand()
[all …]
H A Dpubsub.c58 int pubsubSubscribeChannel(client *c, robj *channel) { in pubsubSubscribeChannel()
88 int pubsubUnsubscribeChannel(client *c, robj *channel, int notify) { in pubsubUnsubscribeChannel()
127 int pubsubSubscribePattern(client *c, robj *pattern) { in pubsubSubscribePattern()
150 int pubsubUnsubscribePattern(client *c, robj *pattern, int notify) { in pubsubUnsubscribePattern()
184 robj *channel = dictGetKey(de); in pubsubUnsubscribeAllChannels()
209 robj *pattern = ln->value; in pubsubUnsubscribeAllPatterns()
225 int pubsubPublishMessage(robj *channel, robj *message) { in pubsubPublishMessage()
340 robj *cobj = dictGetKey(de); in pubsubCommand()
H A Dsort.c38 redisSortOperation *createSortOperation(int type, robj *pattern) { in createSortOperation()
61 robj *lookupKeyByPattern(redisDb *db, robj *pattern, robj *subst) { in lookupKeyByPattern()
64 robj *keyobj, *fieldobj = NULL, *o; in lookupKeyByPattern()
198 robj *sortval, *sortby = NULL, *storekey = NULL; in sortCommand()
383 robj *ele; in sortCommand()
402 robj *ele; in sortCommand()
450 robj *byval; in sortCommand()
517 robj *val = lookupKeyByPattern(c->db,sop->pattern, in sortCommand()
534 robj *sobj = createQuicklistObject(); in sortCommand()
547 robj *val = lookupKeyByPattern(c->db,sop->pattern, in sortCommand()
H A Dslowlog.h35 robj **argv;
44 void slowlogPushEntryIfNeeded(robj **argv, int argc, long long duration);
H A Daof.c452 robj *o; in catAppendOnlyGenericCommand()
481 sds catAppendOnlyExpireAtCommand(sds buf, struct redisCommand *cmd, robj *key, robj *seconds) { in catAppendOnlyExpireAtCommand()
483 robj *argv[3]; in catAppendOnlyExpireAtCommand()
513 robj *tmpargv[3]; in feedAppendOnlyFile()
642 robj **argv; in loadAppendOnlyFile()
787 int rewriteListObject(rio *r, robj *key, robj *o) { in rewriteListObject()
821 int rewriteSetObject(rio *r, robj *key, robj *o) { in rewriteSetObject()
868 int rewriteSortedSetObject(rio *r, robj *key, robj *o) { in rewriteSortedSetObject()
955 robj *value; in rioWriteHashIteratorCursor()
967 int rewriteHashObject(rio *r, robj *key, robj *o) { in rewriteHashObject()
[all …]
H A Dmulti.c65 mc->argv = zmalloc(sizeof(robj*)*c->argc); in queueMultiCommand()
66 memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc); in queueMultiCommand()
107 robj *multistring = createStringObject("MULTI",5); in execCommandPropagateMulti()
116 robj **orig_argv; in execCommand()
197 robj *key;
202 void watchForKey(client *c, robj *key) { in watchForKey()
261 void touchWatchedKey(redisDb *db, robj *key) { in touchWatchedKey()
H A Dnetworking.c56 incrRefCount((robj*)o); in dupClientReplyValue()
196 robj *new, *cur; in dupLastObjectIfNeeded()
231 robj *tail; in _addReplyObjectToList()
263 robj *tail; in _addReplySdsToList()
294 robj *tail; in _addReplyStringToList()
329 void addReply(client *c, robj *obj) { in addReply()
444 robj *len, *next; in setDeferredMultiBulkLength()
906 robj *o; in writeToClient()
1651 robj *a; in rewriteClientCommandVector()
1653 a = va_arg(ap, robj*); in rewriteClientCommandVector()
[all …]
H A Drdb.c456 robj *rdbLoadStringObject(rio *rdb) { in rdbLoadStringObject()
525 int rdbSaveObjectType(rio *rdb, robj *o) { in rdbSaveObjectType()
571 ssize_t rdbSaveObject(rio *rdb, robj *o) { in rdbSaveObject()
693 size_t rdbSavedObjectLen(robj *o) { in rdbSavedObjectLen()
703 int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val, in rdbSaveKeyValuePair()
976 robj *o = NULL, *ele, *dec; in rdbLoadObject()
1052 robj *ele; in rdbLoadObject()
1088 robj *field, *value; in rdbLoadObject()
1117 robj *field, *value; in rdbLoadObject()
1307 robj *key, *val; in rdbLoad()
[all …]
H A Ddebug.c71 void xorObjectDigest(unsigned char *digest, robj *o) { in xorObjectDigest()
137 robj *keyobj, *o; in computeDatasetDigest()
166 robj *ele; in computeDatasetDigest()
226 robj *obj; in computeDatasetDigest()
358 robj *val; in debugCommand()
410 robj *val; in debugCommand()
434 robj *key, *val; in debugCommand()
592 void serverLogObjectDebugInfo(robj *o) { in serverLogObjectDebugInfo()
616 void _serverAssertPrintObject(robj *o) { in _serverAssertPrintObject()
884 robj *decoded; in logCurrentClient()
[all …]
H A Dbitops.c471 robj *lookupStringForBitCommand(client *c, size_t maxbit) { in lookupStringForBitCommand()
473 robj *o = lookupKeyWrite(c->db,c->argv[1]); in lookupStringForBitCommand()
499 unsigned char *getObjectReadOnlyString(robj *o, long *len, char *llbuf) { in getObjectReadOnlyString()
519 robj *o; in setbitCommand()
558 robj *o; in getbitCommand()
586 robj *o, *targetkey = c->argv[2]; in bitopCommand()
588 robj **objects; /* Array of source objects. */ in bitopCommand()
619 objects = zmalloc(sizeof(robj*) * numkeys); in bitopCommand()
759 robj *o; in bitcountCommand()
808 robj *o; in bitposCommand()
[all …]
H A Dslowlog.c48 slowlogEntry *slowlogCreateEntry(robj **argv, int argc, long long duration) { in slowlogCreateEntry()
54 se->argv = zmalloc(sizeof(robj*)*slargc); in slowlogCreateEntry()
112 void slowlogPushEntryIfNeeded(robj **argv, int argc, long long duration) { in slowlogPushEntryIfNeeded()
H A Dhyperloglog.c568 int hllSparseToDense(robj *o) { in hllSparseToDense()
1044 int hllMerge(uint8_t *max, robj *hll) { in hllMerge()
1089 robj *createHLLObject(void) { in createHLLObject()
1090 robj *o; in createHLLObject()
1124 int isHLLObjectOrReply(client *c, robj *o) { in isHLLObjectOrReply()
1156 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfaddCommand()
1196 robj *o; in pfcountCommand()
1296 robj *o = lookupKeyRead(c->db,c->argv[j]); in pfmergeCommand()
1309 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfmergeCommand()
1355 robj *o = NULL; in pfselftestCommand()
[all …]
H A Dnotify.c95 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid) { in notifyKeyspaceEvent()
97 robj *chanobj, *eventobj; in notifyKeyspaceEvent()
H A Dredis-check-rdb.c42 robj *key; /* Current key we are reading. */
203 robj *key, *val; in redis_check_rdb()
257 robj *auxkey, *auxval; in redis_check_rdb()
H A Dcluster.c1906 robj *channel, *message; in clusterProcessPacket()
2333 void clusterSendPublish(clusterLink *link, robj *channel, robj *message) { in clusterSendPublish()
2410 void clusterPropagatePublish(robj *channel, robj *message) { in clusterPropagatePublish()
3905 robj *o; in clusterCommand()
4160 robj **keys; in clusterCommand()
4452 robj *o, *dumpobj; in dumpCommand()
4476 robj *obj; in restoreCommand()
4554 migrateCachedSocket* migrateGetSocket(client *c, robj *host, robj *port, long timeout) { in migrateGetSocket()
4610 void migrateCloseSocket(robj *host, robj *port) { in migrateCloseSocket()
4976 robj *firstkey = NULL; in getNodeByQuery()
[all …]
H A Dblocked.c76 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply()

12