We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a86de10 commit 5bd7ea7Copy full SHA for 5bd7ea7
src/server/cluster/outgoing_slot_migration.cc
@@ -226,8 +226,11 @@ void OutgoingMigration::SyncFb() {
226
const absl::Duration passed = absl::Now() - start_time;
227
// we provide 30 seconds to distribute the config to all nodes to avoid extra errors
228
// reporting
229
- if (passed >= absl::Milliseconds(30000))
+ if (passed >= absl::Milliseconds(30000)) {
230
cntx_.ReportError(GenericError(LastResponseArgs().front().GetString()));
231
+ } else {
232
+ ThisFiber::SleepFor(500ms); // to prevent too many attempts
233
+ }
234
} else {
235
236
}
0 commit comments