Merge pull request #895 from near/xiangyi/remove_timeout

remove timeout for send encrypted and /state
near · Oct 15, 2024 · d49cd4e · d49cd4e
2 parents 534a598 + 95e017d
commit d49cd4e
Show file tree

Hide file tree

Showing 3 changed files with 125 additions and 16 deletions.
diff --git a/chain-signatures/node/src/http_client.rs b/chain-signatures/node/src/http_client.rs
@@ -46,7 +46,6 @@ async fn send_encrypted<U: IntoUrl>(
             .post(url.clone())
             .header("content-type", "application/json")
             .json(&message)
-            .timeout(Duration::from_millis(200))
             .send()
             .await
             .map_err(SendError::ReqwestClientError)?;

diff --git a/chain-signatures/node/src/mesh/connection.rs b/chain-signatures/node/src/mesh/connection.rs
@@ -49,13 +49,7 @@ impl Pool {
                 continue;
             };
 
-            let Ok(resp) = self
-                .http
-                .get(url.clone())
-                .timeout(Duration::from_millis(200))
-                .send()
-                .await
-            else {
+            let Ok(resp) = self.http.get(url.clone()).send().await else {
                 tracing::warn!(
                     "Pool.ping resp err participant {:?} url {}",
                     participant,
@@ -99,13 +93,7 @@ impl Pool {
                 continue;
             };
 
-            let Ok(resp) = self
-                .http
-                .get(url)
-                .timeout(Duration::from_millis(200))
-                .send()
-                .await
-            else {
+            let Ok(resp) = self.http.get(url).send().await else {
                 continue;
             };
 

diff --git a/integration-tests/chain-signatures/Cargo.lock b/integration-tests/chain-signatures/Cargo.lock