Home
last modified time | relevance | path

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

12

/f-stack/app/redis-5.0.5/src/
H A Dserver.h1532 robj *makeObjectShared(robj *o);
1533 robj *resetRefCount(robj *obj);
1543 robj *dupStringObject(const robj *o);
1546 robj *tryObjectEncoding(robj *o);
1547 robj *getDecodedObject(robj *o);
1572 int equalStringObjects(robj *a, robj *b);
1778 void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2);
1825 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply);
1826 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply);
1829 robj *objectCommandLookupOrReply(client *c, robj *key, robj *reply);
[all …]
H A Dobject.c69 robj *makeObjectShared(robj *o) { in makeObjectShared()
134 robj *o; in createStringObjectFromLongLongWithOptions()
193 robj *dupStringObject(const robj *o) { in dupStringObject()
391 robj *resetRefCount(robj *obj) { in resetRefCount()
431 robj *tryObjectEncoding(robj *o) { in tryObjectEncoding()
507 robj *getDecodedObject(robj *o) { in getDecodedObject()
569 int compareStringObjects(robj *a, robj *b) { in compareStringObjects()
574 int collateStringObjects(robj *a, robj *b) { in collateStringObjects()
582 int equalStringObjects(robj *a, robj *b) { in equalStringObjects()
1234 robj *objectCommandLookup(client *c, robj *key) { in objectCommandLookup()
[all …]
H A Ddb.c55 robj *lookupKey(redisDb *db, robj *key, int flags) { in lookupKey()
101 robj *val; in lookupKeyReadWithFlags()
143 robj *lookupKeyRead(redisDb *db, robj *key) { in lookupKeyRead()
152 robj *lookupKeyWrite(redisDb *db, robj *key) { in lookupKeyWrite()
157 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply) { in lookupKeyReadOrReply()
163 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply) { in lookupKeyWriteOrReply()
173 void dbAdd(redisDb *db, robj *key, robj *val) { in dbAdd()
189 void dbOverwrite(redisDb *db, robj *key, robj *val) { in dbOverwrite()
216 void setKey(redisDb *db, robj *key, robj *val) { in setKey()
317 robj *dbUnshareStringValue(redisDb *db, robj *key, robj *o) { in dbUnshareStringValue()
[all …]
H A Drdb.h136 int rdbSaveObjectType(rio *rdb, robj *o);
143 ssize_t rdbSaveObject(rio *rdb, robj *o, robj *key);
144 size_t rdbSavedObjectLen(robj *o);
145 robj *rdbLoadObject(int type, rio *rdb, robj *key);
147 int rdbSaveKeyValuePair(rio *rdb, robj *key, robj *val, long long expiretime);
148 robj *rdbLoadStringObject(rio *rdb);
149 ssize_t rdbSaveStringObject(rio *rdb, robj *obj);
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()
236 robj *subject; in pushxGenericCommand()
266 robj *subject; in linsertCommand()
399 robj *o; in lrangeCommand()
445 robj *o; in ltrimCommand()
550 void rpoplpushHandlePush(client *c, robj *dstkey, robj *dstobj, robj *value) { in rpoplpushHandlePush()
628 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList()
630 robj *argv[3]; in serveClientBlockedOnList()
[all …]
H A Dt_set.c265 robj *set; in saddCommand()
291 robj *set; in sremCommand()
374 robj *set; in sismemberCommand()
386 robj *o; in scardCommand()
405 robj *set; in spopWithCountCommand()
618 robj *set; in srandmemberWithCountCommand()
750 robj *set; in srandmemberCommand()
783 robj *o1 = *(robj**)s1, *o2 = *(robj**)s2; in qsortCompareSetsByRevCardinality()
794 robj **sets = zmalloc(sizeof(robj*)*setnum); in sinterGenericCommand()
933 robj **sets = zmalloc(sizeof(robj*)*setnum); in sunionDiffGenericCommand()
[all …]
H A Dt_hash.c131 robj *hashTypeGetValueObject(robj *o, sds field) { in hashTypeGetValueObject()
515 robj *o; in hsetnxCommand()
532 robj *o; in hsetCommand()
561 robj *o; in hincrbyCommand()
597 robj *o; in hincrbyfloatCommand()
680 robj *o; in hgetCommand()
689 robj *o; in hmgetCommand()
707 robj *o; in hdelCommand()
735 robj *o; in hlenCommand()
744 robj *o; in hstrlenCommand()
[all …]
H A Dgeo.c113 int longLatFromMember(robj *zobj, robj *member, double *xy) { in longLatFromMember()
127 double extractUnitOrReply(client *c, robj *unit) { in extractUnitOrReply()
416 robj **argv = zcalloc(argc*sizeof(robj*)); in geoaddCommand()
440 robj *val = c->argv[2 + i * 3 + 2]; in geoaddCommand()
463 robj *key = c->argv[1]; in georadiusGeneric()
464 robj *storekey = NULL; in georadiusGeneric()
468 robj *zobj = NULL; in georadiusGeneric()
483 robj *member = c->argv[2]; in georadiusGeneric()
635 robj *zobj; in georadiusGeneric()
704 robj *zobj = lookupKeyRead(c->db, c->argv[1]); in geohashCommand()
[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()
341 robj *o, *new; in incrDecrCommand()
401 robj *o, *new, *aux; in incrbyfloatCommand()
435 robj *o, *append; in appendCommand()
[all …]
H A Dblocked.c68 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i…
78 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply()
266 robj *o = lookupKeyWrite(rl->db,rl->key); in handleClientsBlockedOnKeys()
289 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnKeys()
293 robj *value = listTypePop(o,where); in handleClientsBlockedOnKeys()
359 robj *argv[2]; in handleClientsBlockedOnKeys()
497 void blockForKeys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, s… in blockForKeys()
552 robj *key = dictGetKey(de); in unblockClientWaitingData()
585 void signalKeyAsReady(redisDb *db, robj *key) { in signalKeyAsReady()
H A Dlazyfree.c31 size_t lazyfreeGetFreeEffort(robj *obj) { in lazyfreeGetFreeEffort()
54 int dbAsyncDelete(redisDb *db, robj *key) { in dbAsyncDelete()
64 robj *val = dictGetVal(de); in dbAsyncDelete()
94 void freeObjAsync(robj *o) { in freeObjAsync()
129 void lazyfreeFreeObjectFromBioThread(robj *o) { in lazyfreeFreeObjectFromBioThread()
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()
348 robj *cobj = dictGetKey(de); in pubsubCommand()
H A Dt_stream.c794 void streamPropagateXCLAIM(client *c, robj *key, streamCG *group, robj *groupname, robj *id, stream… in streamPropagateXCLAIM()
802 robj *argv[14]; in streamPropagateXCLAIM()
838 robj *argv[5]; in streamPropagateGroupID()
1058 robj *streamTypeLookupWriteOrCreate(client *c, robj *key) { in streamTypeLookupWriteOrCreate()
1220 robj *o; in xaddCommand()
1262 robj *o; in xrangeGenericCommand()
1313 robj *o; in xlenCommand()
1719 robj *o; in xgroupCommand()
2319 robj *o; in xdelCommand()
2362 robj *o; in xtrimCommand()
[all …]
H A Dslowlog.h35 robj **argv;
46 void slowlogPushEntryIfNeeded(client *c, robj **argv, int argc, long long duration);
H A Daof.c521 robj *o; in catAppendOnlyGenericCommand()
552 robj *argv[3]; in catAppendOnlyExpireAtCommand()
582 robj *tmpargv[3]; in feedAppendOnlyFile()
755 robj **argv; in loadAppendOnlyFile()
922 int rewriteListObject(rio *r, robj *key, robj *o) { in rewriteListObject()
956 int rewriteSetObject(rio *r, robj *key, robj *o) { in rewriteSetObject()
1003 int rewriteSortedSetObject(rio *r, robj *key, robj *o) { in rewriteSortedSetObject()
1098 int rewriteHashObject(rio *r, robj *key, robj *o) { in rewriteHashObject()
1162 int rewriteStreamObject(rio *r, robj *key, robj *o) { in rewriteStreamObject()
1261 int rewriteModuleObject(rio *r, robj *key, robj *o) { in rewriteModuleObject()
[all …]
H A Dmulti.c66 mc->argv = zmalloc(sizeof(robj*)*c->argc); in queueMultiCommand()
67 memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc); in queueMultiCommand()
109 robj *multistring = createStringObject("MULTI",5); in execCommandPropagateMulti()
118 robj **orig_argv; in execCommand()
229 robj *key;
234 void watchForKey(client *c, robj *key) { in watchForKey()
293 void touchWatchedKey(redisDb *db, robj *key) { in touchWatchedKey()
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()
452 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 Ddefrag.c103 robj *activeDefragStringOb(robj* ob, long *defragged) { in activeDefragStringOb()
104 robj *ret = NULL; in activeDefragStringOb()
322 robj *newele, *ele = ln->value; in activeDefragList()
443 long scanLaterList(robj *ob) { in scanLaterList()
513 robj *ob = dictGetVal(kde); in defragQuicklist()
527 robj *ob = dictGetVal(kde); in defragZsetSkiplist()
561 robj *ob = dictGetVal(kde); in defragHash()
579 robj *ob = dictGetVal(kde); in defragSet()
739 robj *ob = dictGetVal(kde); in defragStream()
765 robj *newob, *ob; in defragKey()
[all …]
H A Dt_zset.c1536 robj *zobj; in zaddGenericCommand()
1665 robj *zobj; in zremCommand()
1696 robj *zobj; in zremrangeGenericCommand()
2413 robj *zobj; in zrangeGenericCommand()
2525 robj *zobj; in genericZrangebyscoreCommand()
2723 robj *zobj; in zcountCommand()
2800 robj *zobj; in zlexcountCommand()
2881 robj *zobj; in genericZrangebylexCommand()
3067 robj *zobj; in zcardCommand()
3117 robj *o; in zscanCommand()
[all …]
H A Dhyperloglog.c584 int hllSparseToDense(robj *o) { in hllSparseToDense()
1068 int hllMerge(uint8_t *max, robj *hll) { in hllMerge()
1114 robj *createHLLObject(void) { in createHLLObject()
1115 robj *o; in createHLLObject()
1149 int isHLLObjectOrReply(client *c, robj *o) { in isHLLObjectOrReply()
1182 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfaddCommand()
1222 robj *o; in pfcountCommand()
1323 robj *o = lookupKeyRead(c->db,c->argv[j]); in pfmergeCommand()
1341 robj *o = lookupKeyWrite(c->db,c->argv[1]); in pfmergeCommand()
1394 robj *o = NULL; in pfselftestCommand()
[all …]
H A Dbitops.c478 robj *lookupStringForBitCommand(client *c, size_t maxbit) { in lookupStringForBitCommand()
480 robj *o = lookupKeyWrite(c->db,c->argv[1]); in lookupStringForBitCommand()
506 unsigned char *getObjectReadOnlyString(robj *o, long *len, char *llbuf) { in getObjectReadOnlyString()
526 robj *o; in setbitCommand()
565 robj *o; in getbitCommand()
593 robj *o, *targetkey = c->argv[2]; in bitopCommand()
595 robj **objects; /* Array of source objects. */ in bitopCommand()
626 objects = zmalloc(sizeof(robj*) * numkeys); in bitopCommand()
770 robj *o; in bitcountCommand()
819 robj *o; in bitposCommand()
[all …]
H A Ddebug.c121 void xorObjectDigest(redisDb *db, robj *keyobj, unsigned char *digest, robj *o) { in xorObjectDigest()
134 robj *eleobj = listTypeGet(&entry); in xorObjectDigest()
281 robj *keyobj, *o; in computeDatasetDigest()
388 robj *val; in debugCommand()
440 robj *val; in debugCommand()
464 robj *o; in debugCommand()
478 robj *key, *val; in debugCommand()
591 robj *o; in debugCommand()
672 void serverLogObjectDebugInfo(const robj *o) { in serverLogObjectDebugInfo()
1129 robj *decoded; in logCurrentClient()
[all …]
H A Dslowlog.c48 slowlogEntry *slowlogCreateEntry(client *c, robj **argv, int argc, long long duration) { in slowlogCreateEntry()
54 se->argv = zmalloc(sizeof(robj*)*slargc); in slowlogCreateEntry()
123 void slowlogPushEntryIfNeeded(client *c, robj **argv, int argc, long long duration) { in slowlogPushEntryIfNeeded()
H A Dstream.h92 robj *keyname;
93 robj *groupname;
H A Dexpire.c58 robj *keyobj = createStringObject(key,sdslen(key)); in activeExpireCycleTryExpire()
344 void rememberSlaveKeyWithExpire(redisDb *db, robj *key) { in rememberSlaveKeyWithExpire()
406 robj *key = c->argv[1], *param = c->argv[2]; in expireGenericCommand()
428 robj *aux; in expireGenericCommand()

12