Lines Matching refs:robj
1906 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()
3794 int getSlotOrReply(client *c, robj *o) { in getSlotOrReply()
3905 robj *o; in clusterCommand()
4160 robj **keys; in clusterCommand()
4172 keys = zmalloc(sizeof(robj*)*maxkeys); in clusterCommand()
4396 void createDumpPayload(rio *payload, robj *o) { in createDumpPayload()
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()
4656 robj **ov = NULL; /* Objects to migrate. */ in migrateCommand()
4657 robj **kv = NULL; /* Key names. */ in migrateCommand()
4658 robj **newargv = NULL; /* Used to rewrite the command as DEL ... keys ... */ in migrateCommand()
4707 ov = zrealloc(ov,sizeof(robj*)*num_keys); in migrateCommand()
4708 kv = zrealloc(kv,sizeof(robj*)*num_keys); in migrateCommand()
4806 if (!copy) newargv = zmalloc(sizeof(robj*)*(num_keys+1)); in migrateCommand()
4974 clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashsl… in getNodeByQuery()
4976 robj *firstkey = NULL; in getNodeByQuery()
5008 robj **margv; in getNodeByQuery()
5017 robj *thiskey = margv[keyindex[j]]; in getNodeByQuery()
5192 robj *key = dictGetKey(de); in clusterRedirectBlockedClientIfNeeded()