Lines Matching refs:robj
469 } robj; typedef
517 robj **argv;
539 robj *target; /* The key that should receive the element,
560 robj *key;
570 robj *name; /* As set by CLIENT SETNAME. */
574 robj **argv; /* Arguments of current command. */
624 robj *crlf, *ok, *err, *emptybulk, *czero, *cone, *cnegone, *pong, *space,
640 robj *obj;
675 robj **argv;
984 robj *pattern;
988 typedef int *redisGetKeysProc(struct redisCommand *cmd, robj **argv, int argc, int *numkeys);
1011 robj *obj;
1014 robj *cmpobj;
1020 robj *pattern;
1025 robj *subject;
1039 robj *subject;
1050 robj *subject;
1105 void addReplyBulk(client *c, robj *obj);
1109 void addReply(client *c, robj *obj);
1126 void rewriteClientCommandArgument(client *c, int i, robj *newval);
1127 void replaceClientCommandVector(client *c, int argc, robj **argv);
1156 void listTypeTryConversion(robj *subject, robj *value);
1157 void listTypePush(robj *subject, robj *value, int where);
1158 robj *listTypePop(robj *subject, int where);
1159 unsigned long listTypeLength(robj *subject);
1160 listTypeIterator *listTypeInitIterator(robj *subject, long index, unsigned char direction);
1163 robj *listTypeGet(listTypeEntry *entry);
1164 void listTypeInsert(listTypeEntry *entry, robj *value, int where);
1165 int listTypeEqual(listTypeEntry *entry, robj *o);
1167 void listTypeConvert(robj *subject, int enc);
1171 void signalListAsReady(redisDb *db, robj *key);
1178 void touchWatchedKey(redisDb *db, robj *key);
1185 void decrRefCount(robj *o);
1187 void incrRefCount(robj *o);
1188 robj *resetRefCount(robj *obj);
1189 void freeStringObject(robj *o);
1190 void freeListObject(robj *o);
1191 void freeSetObject(robj *o);
1192 void freeZsetObject(robj *o);
1193 void freeHashObject(robj *o);
1194 robj *createObject(int type, void *ptr);
1195 robj *createStringObject(const char *ptr, size_t len);
1196 robj *createRawStringObject(const char *ptr, size_t len);
1197 robj *createEmbeddedStringObject(const char *ptr, size_t len);
1198 robj *dupStringObject(robj *o);
1199 int isObjectRepresentableAsLongLong(robj *o, long long *llongval);
1200 robj *tryObjectEncoding(robj *o);
1201 robj *getDecodedObject(robj *o);
1202 size_t stringObjectLen(robj *o);
1203 robj *createStringObjectFromLongLong(long long value);
1204 robj *createStringObjectFromLongDouble(long double value, int humanfriendly);
1205 robj *createQuicklistObject(void);
1206 robj *createZiplistObject(void);
1207 robj *createSetObject(void);
1208 robj *createIntsetObject(void);
1209 robj *createHashObject(void);
1210 robj *createZsetObject(void);
1211 robj *createZsetZiplistObject(void);
1212 int getLongFromObjectOrReply(client *c, robj *o, long *target, const char *msg);
1213 int checkType(client *c, robj *o, int type);
1214 int getLongLongFromObjectOrReply(client *c, robj *o, long long *target, const char *msg);
1215 int getDoubleFromObjectOrReply(client *c, robj *o, double *target, const char *msg);
1216 int getLongLongFromObject(robj *o, long long *target);
1217 int getLongDoubleFromObject(robj *o, long double *target);
1218 int getLongDoubleFromObjectOrReply(client *c, robj *o, long double *target, const char *msg);
1220 int compareStringObjects(robj *a, robj *b);
1221 int collateStringObjects(robj *a, robj *b);
1222 int equalStringObjects(robj *a, robj *b);
1223 unsigned long long estimateObjectIdleTime(robj *o);
1232 void replicationFeedSlaves(list *slaves, int dictid, robj **argv, int argc);
1233 void replicationFeedMonitors(client *c, list *monitors, int dictid, robj **argv, int argc);
1265 void feedAppendOnlyFile(struct redisCommand *cmd, int dictid, robj **argv, int argc);
1285 robj *min, *max; /* May be set to shared.(minstring|maxstring) */
1291 zskiplistNode *zslInsert(zskiplist *zsl, double score, robj *obj);
1292 unsigned char *zzlInsert(unsigned char *zl, robj *ele, double score);
1293 int zslDelete(zskiplist *zsl, double score, robj *obj);
1299 unsigned int zsetLength(robj *zobj);
1300 void zsetConvert(robj *zobj, int encoding);
1301 void zsetConvertToZiplistIfNeeded(robj *zobj, size_t maxelelen);
1302 int zsetScore(robj *zobj, robj *member, double *score);
1303 unsigned long zslGetRank(zskiplist *zsl, double score, robj *o);
1313 void propagate(struct redisCommand *cmd, int dbid, robj **argv, int argc, int flags);
1314 void alsoPropagate(struct redisCommand *cmd, int dbid, robj **argv, int argc, int target);
1346 robj *setTypeCreate(robj *value);
1347 int setTypeAdd(robj *subject, robj *value);
1348 int setTypeRemove(robj *subject, robj *value);
1349 int setTypeIsMember(robj *subject, robj *value);
1350 setTypeIterator *setTypeInitIterator(robj *subject);
1352 int setTypeNext(setTypeIterator *si, robj **objele, int64_t *llele);
1353 robj *setTypeNextObject(setTypeIterator *si);
1354 int setTypeRandomElement(robj *setobj, robj **objele, int64_t *llele);
1355 unsigned long setTypeRandomElements(robj *set, unsigned long count, robj *aux_set);
1356 unsigned long setTypeSize(robj *subject);
1357 void setTypeConvert(robj *subject, int enc);
1360 void hashTypeConvert(robj *o, int enc);
1361 void hashTypeTryConversion(robj *subject, robj **argv, int start, int end);
1362 void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2);
1363 robj *hashTypeGetObject(robj *o, robj *key);
1364 int hashTypeExists(robj *o, robj *key);
1365 int hashTypeSet(robj *o, robj *key, robj *value);
1366 int hashTypeDelete(robj *o, robj *key);
1367 unsigned long hashTypeLength(robj *o);
1368 hashTypeIterator *hashTypeInitIterator(robj *subject);
1375 void hashTypeCurrentFromHashTable(hashTypeIterator *hi, int what, robj **dst);
1376 robj *hashTypeCurrentObject(hashTypeIterator *hi, int what);
1377 robj *hashTypeLookupWriteOrCreate(client *c, robj *key);
1384 int pubsubPublishMessage(robj *channel, robj *message);
1387 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid);
1400 int removeExpire(redisDb *db, robj *key);
1401 void propagateExpire(redisDb *db, robj *key);
1402 int expireIfNeeded(redisDb *db, robj *key);
1403 long long getExpire(redisDb *db, robj *key);
1404 void setExpire(redisDb *db, robj *key, long long when);
1405 robj *lookupKey(redisDb *db, robj *key, int flags);
1406 robj *lookupKeyRead(redisDb *db, robj *key);
1407 robj *lookupKeyWrite(redisDb *db, robj *key);
1408 robj *lookupKeyReadOrReply(client *c, robj *key, robj *reply);
1409 robj *lookupKeyWriteOrReply(client *c, robj *key, robj *reply);
1410 robj *lookupKeyReadWithFlags(redisDb *db, robj *key, int flags);
1413 void dbAdd(redisDb *db, robj *key, robj *val);
1414 void dbOverwrite(redisDb *db, robj *key, robj *val);
1415 void setKey(redisDb *db, robj *key, robj *val);
1416 int dbExists(redisDb *db, robj *key);
1417 robj *dbRandomKey(redisDb *db);
1418 int dbDelete(redisDb *db, robj *key);
1419 robj *dbUnshareStringValue(redisDb *db, robj *key, robj *o);
1422 void signalModifiedKey(redisDb *db, robj *key);
1424 unsigned int getKeysInSlot(unsigned int hashslot, robj **keys, unsigned int count);
1428 void scanGenericCommand(client *c, robj *o, unsigned long cursor);
1429 int parseScanCursorOrReply(client *c, robj *o, unsigned long *cursor);
1432 int *getKeysFromCommand(struct redisCommand *cmd, robj **argv, int argc, int *numkeys);
1434 int *zunionInterGetKeys(struct redisCommand *cmd,robj **argv, int argc, int *numkeys);
1435 int *evalGetKeys(struct redisCommand *cmd, robj **argv, int argc, int *numkeys);
1436 int *sortGetKeys(struct redisCommand *cmd, robj **argv, int argc, int *numkeys);
1437 int *migrateGetKeys(struct redisCommand *cmd, robj **argv, int argc, int *numkeys);
1444 void clusterPropagatePublish(robj *channel, robj *message);
1470 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit);
1657 void _serverAssertWithInfo(client *c, robj *o, char *estr, char *file, int line);
1661 void serverLogObjectDebugInfo(robj *o);