From 8e52c255abdaff02011eabe40eeb2e2df6043009 Mon Sep 17 00:00:00 2001
From: Andrey Vasnetsov <andrey@vasnetsov.com>
Date: Mon, 6 Jun 2022 21:44:03 +0200
Subject: [PATCH] add consensus configuration + lower log level + fix
 flickering test

---
 config/config.yaml                            | 17 +++++++++++++++++
 lib/segment/tests/filtrable_hnsw_test.rs      |  3 ++-
 lib/storage/src/content_manager/raft_state.rs |  6 +++---
 src/consensus.rs                              |  4 ++--
 4 files changed, 24 insertions(+), 6 deletions(-)

diff --git a/config/config.yaml b/config/config.yaml
index 11b9a036c2..8998cc35aa 100644
--- a/config/config.yaml
+++ b/config/config.yaml
@@ -102,3 +102,20 @@ service:
   # More info: https://developer.mozilla.org/en-US/docs/Web/HTTP/CORS
   # Default: true
   enable_cors: true
+
+cluster:
+  # Use `enabled: true` to run Qdrant in distributed deployment mode
+  enabled: true
+
+  # Configuration of the inter-cluster communication
+  p2p:
+    # Port for internal communication between peers
+    port: 6335
+
+  # Configuration related to distributed consensus algorithm
+  consensus:
+    # How frequently peers should ping each other.
+    # Setting this parameter to lower value will allow consensus
+    # to detect disconnected nodes earlier, but too frequent
+    # tick period may create significant network and CPU overhead.
+    tick_period_ms: 300
diff --git a/lib/segment/tests/filtrable_hnsw_test.rs b/lib/segment/tests/filtrable_hnsw_test.rs
index 8b9bd00ddb..48b5b9a9aa 100644
--- a/lib/segment/tests/filtrable_hnsw_test.rs
+++ b/lib/segment/tests/filtrable_hnsw_test.rs
@@ -107,8 +107,9 @@ mod tests {
         }
         let expected_blocks = num_vectors as usize / indexing_threshold * 2;
 
+        eprintln!("blocks.len() = {:#?}", blocks.len());
         assert!(
-            (blocks.len() as i64 - expected_blocks as i64).abs() < 3,
+            (blocks.len() as i64 - expected_blocks as i64).abs() <= 3,
             "real number of payload blocks is too far from expected"
         );
 
diff --git a/lib/storage/src/content_manager/raft_state.rs b/lib/storage/src/content_manager/raft_state.rs
index 1b0a2af5c8..74b5ba88bb 100644
--- a/lib/storage/src/content_manager/raft_state.rs
+++ b/lib/storage/src/content_manager/raft_state.rs
@@ -82,13 +82,13 @@ impl Persistent {
     ) -> Result<Self, StorageError> {
         let path = storage_path.as_ref().join(STATE_FILE_NAME);
         let state = if path.exists() {
-            log::info!("Loading raft state from {}", path.display());
+            log::debug!("Loading raft state from {}", path.display());
             Self::load(path)?
         } else {
-            log::info!("Initializing new raft state at {}", path.display());
+            log::debug!("Initializing new raft state at {}", path.display());
             Self::init(path, first_peer)?
         };
-        log::info!("State: {:?}", state.state());
+        log::debug!("State: {:?}", state.state());
         Ok(state)
     }
 
diff --git a/src/consensus.rs b/src/consensus.rs
index cea756ba56..9bbed7a5f6 100644
--- a/src/consensus.rs
+++ b/src/consensus.rs
@@ -76,9 +76,9 @@ impl Consensus {
             )?;
         } else {
             if bootstrap_peer.is_some() || uri.is_some() {
-                log::warn!("Local raft state found - bootstrap and uri cli arguments were ignored")
+                log::info!("Local raft state found - bootstrap and uri cli arguments were ignored")
             }
-            log::info!("Local raft state found - skipping initialization");
+            log::debug!("Local raft state found - skipping initialization");
         };
         let mut node = Node::new(&raft_config, toc_ref.clone(), logger)?;
         // Before consensus has started apply any unapplied committed entries