mirror of
https://github.com/dragonflydb/dragonfly.git
synced 2025-05-11 02:15:45 +02:00
fix(server): do not print warning on replica stop/ takeover (#2560)
* fix(server): do not print warning on replica stop/ takeover --------- Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
parent
4860c8eac2
commit
c2ee348d2c
1 changed files with 5 additions and 3 deletions
|
@ -234,9 +234,11 @@ void Replica::MainReplicationFb() {
|
||||||
else
|
else
|
||||||
ec = ConsumeRedisStream();
|
ec = ConsumeRedisStream();
|
||||||
|
|
||||||
LOG(WARNING) << "Error stable sync with " << server().Description() << " " << ec << " "
|
auto state = state_mask_.fetch_and(R_ENABLED);
|
||||||
<< ec.message();
|
if (state & R_ENABLED) { // replication was not stopped.
|
||||||
state_mask_.fetch_and(R_ENABLED);
|
LOG(WARNING) << "Error stable sync with " << server().Description() << " " << ec << " "
|
||||||
|
<< ec.message();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Wait for unblocking cleanup to finish.
|
// Wait for unblocking cleanup to finish.
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue