Lines Matching refs:src_reply

5510     redisReply *src_reply = NULL;  in clusterManagerCommandImport()  local
5519 src_reply = reconnectingRedisCommand(src_ctx, "INFO"); in clusterManagerCommandImport()
5520 if (!src_reply || src_reply->type == REDIS_REPLY_ERROR) { in clusterManagerCommandImport()
5521 if (src_reply && src_reply->str) reply_err = src_reply->str; in clusterManagerCommandImport()
5525 if (getLongInfoField(src_reply->str, "cluster_enabled")) { in clusterManagerCommandImport()
5531 freeReplyObject(src_reply); in clusterManagerCommandImport()
5532 src_reply = reconnectingRedisCommand(src_ctx, "DBSIZE"); in clusterManagerCommandImport()
5533 if (!src_reply || src_reply->type == REDIS_REPLY_ERROR) { in clusterManagerCommandImport()
5534 if (src_reply && src_reply->str) reply_err = src_reply->str; in clusterManagerCommandImport()
5538 int size = src_reply->integer, i; in clusterManagerCommandImport()
5570 freeReplyObject(src_reply); in clusterManagerCommandImport()
5571 src_reply = reconnectingRedisCommand(src_ctx, "SCAN %d COUNT %d", in clusterManagerCommandImport()
5573 if (!src_reply || src_reply->type == REDIS_REPLY_ERROR) { in clusterManagerCommandImport()
5574 if (src_reply && src_reply->str) reply_err = src_reply->str; in clusterManagerCommandImport()
5578 assert(src_reply->type == REDIS_REPLY_ARRAY); in clusterManagerCommandImport()
5579 assert(src_reply->elements >= 2); in clusterManagerCommandImport()
5580 assert(src_reply->element[1]->type == REDIS_REPLY_ARRAY); in clusterManagerCommandImport()
5581 if (src_reply->element[0]->type == REDIS_REPLY_STRING) in clusterManagerCommandImport()
5582 cursor = atoi(src_reply->element[0]->str); in clusterManagerCommandImport()
5583 else if (src_reply->element[0]->type == REDIS_REPLY_INTEGER) in clusterManagerCommandImport()
5584 cursor = src_reply->element[0]->integer; in clusterManagerCommandImport()
5585 int keycount = src_reply->element[1]->elements; in clusterManagerCommandImport()
5587 redisReply *kr = src_reply->element[1]->element[i]; in clusterManagerCommandImport()
5615 if (src_reply) freeReplyObject(src_reply); in clusterManagerCommandImport()