feat(dup): optimize time-lag by reducing repeat delay (#450)

XiaoMi · Apr 30, 2020 · 966c04d · 966c04d
1 parent cf0971c
commit 966c04d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/src/dist/replication/lib/duplication/duplication_pipeline.cpp b/src/dist/replication/lib/duplication/duplication_pipeline.cpp
@@ -29,8 +29,8 @@ void load_mutation::run()
     decree last_decree = _duplicator->progress().last_decree;
     _start_decree = last_decree + 1;
     if (_replica->private_log()->max_commit_on_disk() < _start_decree) {
-        // wait 10 seconds for next try if no mutation was added.
-        repeat(10_s);
+        // wait 100ms for next try if no mutation was added.
+        repeat(100_ms);
         return;
     }
 

diff --git a/src/dist/replication/lib/duplication/load_from_private_log.h b/src/dist/replication/lib/duplication/load_from_private_log.h
@@ -52,10 +52,8 @@ class load_from_private_log : public replica_base,
     bool will_fail_skip() const;
     bool will_fail_fast() const;
 
-    void TEST_set_repeat_delay(std::chrono::milliseconds delay)
-    {
-        const_cast<std::chrono::milliseconds &>(_repeat_delay) = delay;
-    }
+    void TEST_set_repeat_delay(std::chrono::milliseconds delay) { _repeat_delay = delay; }
+
     static constexpr int MAX_ALLOWED_BLOCK_REPEATS{3};
     static constexpr int MAX_ALLOWED_FILE_REPEATS{10};