mirrors/dragonflydb-dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2024-12-14 11:58:02 +00:00
Code Activity

fix(cluster): fix backoff on unknown migration (#3965)

Browse source
This commit is contained in:
Andy Dunstall 2024-10-23 15:35:50 +01:00 committed by GitHub
parent c80d21fcba
commit 70614b8d40
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/server/cluster/outgoing_slot_migration.cc
View file

@ -207,9 +207,11 @@ void OutgoingMigration::SyncFb() {
}
if (!CheckRespIsSimpleReply("OK")) {
VLOG(2) << "Received non-OK response, retrying";
if (!CheckRespIsSimpleReply(kUnknownMigration)) {
VLOG(2) << "Target node does not recognize migration";
if (CheckRespIsSimpleReply(kUnknownMigration)) {
VLOG(2) << "Target node does not recognize migration; retrying";
ThisFiber::SleepFor(1000ms);
} else {
VLOG(1) << "Unable to initialize migration";
cntx_.ReportError(GenericError(std::string(ToSV(LastResponseArgs().front().GetBuf()))));
}
continue;