Преглед на файлове

Change the default timeout to be 1 second.

Jing Yang преди 4 години
родител
ревизия
4177b73f90
променени са 2 файла, в които са добавени 4 реда и са изтрити 2 реда
  1. 3 1
      kvraft/src/client.rs
  2. 1 1
      kvraft/src/server.rs

+ 3 - 1
kvraft/src/client.rs

@@ -125,6 +125,8 @@ impl ClerkInner {
         }
     }
 
+    const DEFAULT_TIMEOUT: Duration = Duration::from_secs(1);
+
     fn call_rpc<M, A, R>(
         &mut self,
         method: M,
@@ -150,7 +152,7 @@ impl ClerkInner {
             let client = &self.servers[index];
             let rpc_response = self.executor.block_on(async {
                 tokio::time::timeout(
-                    Duration::from_secs(1),
+                    Self::DEFAULT_TIMEOUT,
                     client.call_rpc(method.clone(), data.clone()),
                 )
                 .await

+ 1 - 1
kvraft/src/server.rs

@@ -295,7 +295,7 @@ impl KVServer {
         );
     }
 
-    const DEFAULT_TIMEOUT: Duration = Duration::from_secs(2);
+    const DEFAULT_TIMEOUT: Duration = Duration::from_secs(1);
 
     pub fn get(&self, args: GetArgs) -> GetReply {
         let (is_retry, result) = match self.block_for_commit(