Lines Matching refs:migrate_reply

2898     redisReply *migrate_reply = NULL;  in clusterManagerMigrateKeysInReply()  local
2954 migrate_reply = (redisReply *) _reply; in clusterManagerMigrateKeysInReply()
2958 return migrate_reply; in clusterManagerMigrateKeysInReply()
2973 redisReply *reply = NULL, *migrate_reply = NULL; in clusterManagerMigrateKeysInSlot() local
2996 migrate_reply = clusterManagerMigrateKeysInReply(source, target, in clusterManagerMigrateKeysInSlot()
2999 if (migrate_reply == NULL) goto next; in clusterManagerMigrateKeysInSlot()
3000 if (migrate_reply->type == REDIS_REPLY_ERROR) { in clusterManagerMigrateKeysInSlot()
3001 int is_busy = strstr(migrate_reply->str, "BUSYKEY") != NULL; in clusterManagerMigrateKeysInSlot()
3002 int not_served = strstr(migrate_reply->str, "slot not served") != NULL; in clusterManagerMigrateKeysInSlot()
3012 freeReplyObject(migrate_reply); in clusterManagerMigrateKeysInSlot()
3013 migrate_reply = clusterManagerMigrateKeysInReply(source, in clusterManagerMigrateKeysInSlot()
3019 success = (migrate_reply != NULL && in clusterManagerMigrateKeysInSlot()
3020 migrate_reply->type != REDIS_REPLY_ERROR); in clusterManagerMigrateKeysInSlot()
3023 if (migrate_reply != NULL) { in clusterManagerMigrateKeysInSlot()
3025 *err = zmalloc((migrate_reply->len + 1) * sizeof(char)); in clusterManagerMigrateKeysInSlot()
3026 strcpy(*err, migrate_reply->str); in clusterManagerMigrateKeysInSlot()
3030 migrate_reply->str); in clusterManagerMigrateKeysInSlot()
3041 if (migrate_reply != NULL) freeReplyObject(migrate_reply); in clusterManagerMigrateKeysInSlot()