Skip to content

Commit 96c3f8f

Browse files
committed
1 parent 77ec7bf commit 96c3f8f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/tools/cephfs_mirror/Mirror.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -558,9 +558,9 @@ void Mirror::update_fs_mirrors() {
558558
std::scoped_lock locker(m_lock);
559559
for (auto &[filesystem, mirror_action] : m_mirror_actions) {
560560
auto failed_restart = mirror_action.fs_mirror && mirror_action.fs_mirror->is_failed() &&
561-
(failed_interval.count() > 0 && duration_cast<seconds>(mirror_action.fs_mirror->get_failed_ts() - clock::now()) > failed_interval);
561+
(failed_interval.count() > 0 && duration_cast<seconds>(clock::now() - mirror_action.fs_mirror->get_failed_ts()).count() > failed_interval.count());
562562
auto blocklisted_restart = mirror_action.fs_mirror && mirror_action.fs_mirror->is_blocklisted() &&
563-
(blocklist_interval.count() > 0 && duration_cast<seconds>(mirror_action.fs_mirror->get_blocklisted_ts() - clock::now()) > blocklist_interval);
563+
(blocklist_interval.count() > 0 && duration_cast<seconds>(clock::now() - mirror_action.fs_mirror->get_blocklisted_ts()).count() > blocklist_interval.count());
564564

565565
if (!mirror_action.action_in_progress && !_is_restarting(filesystem)) {
566566
if (failed_restart || blocklisted_restart) {

0 commit comments

Comments
 (0)