Lines Matching refs:redisReply
512 redisReply *reply = redisCommand(context, "COMMAND"); in cliIntegrateHelp()
518 redisReply *entry = reply->element[j]; in cliIntegrateHelp()
726 redisReply *reply; in cliAuth()
739 redisReply *reply; in cliSelect()
803 static sds cliFormatReplyTTY(redisReply *r, char *prefix) { in cliFormatReplyTTY()
914 static sds cliFormatReplyRaw(redisReply *r) { in cliFormatReplyRaw()
965 static sds cliFormatReplyCSV(redisReply *r) { in cliFormatReplyCSV()
1003 redisReply *reply; in cliReadReply()
1026 reply = (redisReply*)_reply; in cliReadReply()
1191 static redisReply *reconnectingRedisCommand(redisContext *c, const char *fmt, ...) { in reconnectingRedisCommand()
1192 redisReply *reply = NULL; in reconnectingRedisCommand()
1847 redisReply *reply = redisCommand(context, in evalMode()
1955 typedef int (*clusterManagerOnReplyError)(redisReply *reply, int bulk_idx);
2203 redisReply *r, char **err) in clusterManagerCheckRedisReply()
2220 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "MULTI"); in clusterManagerStartTransaction()
2230 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "EXEC"); in clusterManagerExecTransaction()
2239 redisReply *r = reply->element[i]; in clusterManagerExecTransaction()
2273 redisReply *reply = redisCommand(node->context,"AUTH %s",config.auth); in clusterManagerNodeConnect()
2347 static redisReply *clusterManagerGetNodeRedisInfo(clusterManagerNode *node, in clusterManagerGetNodeRedisInfo()
2350 redisReply *info = CLUSTER_MANAGER_COMMAND(node, "INFO"); in clusterManagerGetNodeRedisInfo()
2365 redisReply *info = clusterManagerGetNodeRedisInfo(node, err); in clusterManagerNodeIsCluster()
2375 redisReply *info = clusterManagerGetNodeRedisInfo(node, err); in clusterManagerNodeIsEmpty()
2718 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "DBSIZE"); in clusterManagerShowClusterInfo()
2745 redisReply *reply = NULL; in clusterManagerAddSlots()
2775 reply = (redisReply*) _reply; in clusterManagerAddSlots()
2791 redisReply *reply = CLUSTER_MANAGER_COMMAND(node1, "CLUSTER " in clusterManagerSetSlot()
2812 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, in clusterManagerClearSlotStatus()
2822 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, in clusterManagerDelSlot()
2838 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, in clusterManagerAddSlot()
2848 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, in clusterManagerCountKeysInSlot()
2858 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "CLUSTER BUMPEPOCH"); in clusterManagerBumpEpoch()
2864 static int clusterManagerIgnoreUnassignedErr(redisReply *reply, int bulk_idx) { in clusterManagerIgnoreUnassignedErr()
2892 static redisReply *clusterManagerMigrateKeysInReply(clusterManagerNode *source, in clusterManagerMigrateKeysInReply()
2894 redisReply *reply, in clusterManagerMigrateKeysInReply()
2898 redisReply *migrate_reply = NULL; in clusterManagerMigrateKeysInReply()
2940 redisReply *entry = reply->element[i]; in clusterManagerMigrateKeysInReply()
2954 migrate_reply = (redisReply *) _reply; in clusterManagerMigrateKeysInReply()
2973 redisReply *reply = NULL, *migrate_reply = NULL; in clusterManagerMigrateKeysInSlot()
3092 redisReply *r = CLUSTER_MANAGER_COMMAND(n, "CLUSTER " in clusterManagerMoveSlot()
3122 redisReply *reply = NULL; in clusterManagerFlushNodeConfig()
3169 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "CLUSTER NODES"); in clusterManagerNodeLoadInfo()
3444 redisReply *reply = CLUSTER_MANAGER_COMMAND(node, "CLUSTER NODES"); in clusterManagerGetConfigSignature()
3619 redisReply *r = in clusterManagerGetNodeWithMostKeysInSlot()
3711 redisReply *reply = CLUSTER_MANAGER_COMMAND(n, in clusterManagerFixSlotsCoverage()
3905 redisReply *r = CLUSTER_MANAGER_COMMAND(n, in clusterManagerFixOpenSlot()
3954 redisReply *r = CLUSTER_MANAGER_COMMAND(n, in clusterManagerFixOpenSlot()
4154 redisReply *r = CLUSTER_MANAGER_COMMAND(n, in clusterManagerFixOpenSlot()
4172 redisReply *r = CLUSTER_MANAGER_COMMAND(n, "CLUSTER SETSLOT %d %s", in clusterManagerFixOpenSlot()
4774 redisReply *reply = NULL; in clusterManagerCommandCreate()
4790 redisReply *reply = NULL; in clusterManagerCommandCreate()
4857 redisReply *reply = NULL; in clusterManagerCommandAddNode()
4994 redisReply *r = CLUSTER_MANAGER_COMMAND(n, "CLUSTER REPLICATE %s", in clusterManagerCommandDeleteNode()
5000 redisReply *r = CLUSTER_MANAGER_COMMAND(n, "CLUSTER FORGET %s", in clusterManagerCommandDeleteNode()
5009 redisReply *r = redisCommand(node->context, "SHUTDOWN"); in clusterManagerCommandDeleteNode()
5449 redisReply *reply = CLUSTER_MANAGER_COMMAND(n, "CONFIG %s %s %d", in clusterManagerCommandSetTimeout()
5510 redisReply *src_reply = NULL; in clusterManagerCommandImport()
5587 redisReply *kr = src_reply->element[1]->element[i]; in clusterManagerCommandImport()
5593 redisReply *r = reconnectingRedisCommand(src_ctx, cmdfmt, in clusterManagerCommandImport()
5643 redisReply *reply = NULL; in clusterManagerCommandCall()
5721 redisReply *reply; in latencyMode()
5845 redisReply *reply; in latencyDistMode()
6050 redisReply *reply; in pipeMode()
6203 static redisReply *sendScan(unsigned long long *it) { in sendScan()
6204 redisReply *reply = redisCommand(context, "SCAN %llu", *it); in sendScan()
6232 redisReply *reply; in getDbSize()
6293 static void getKeyTypes(dict *types_dict, redisReply *keys, typeinfo **types) { in getKeyTypes()
6294 redisReply *reply; in getKeyTypes()
6332 static void getKeySizes(redisReply *keys, typeinfo **types, in getKeySizes()
6336 redisReply *reply; in getKeySizes()
6387 redisReply *reply, *keys; in findBigKeys()
6520 static void getKeyFreqs(redisReply *keys, unsigned long long *freqs) { in getKeyFreqs()
6521 redisReply *reply; in getKeyFreqs()
6552 redisReply *keys, *reply; in findHotKeys()
6705 redisReply *reply; in statMode()
6795 redisReply *reply; in scanMode()
6854 redisReply *reply; in LRUTestMode()