Merge branch 'timeout' into 'master'

improvement: longer timeout, more descriptive errors

See merge request famedly/conduit!146
This commit is contained in:
Timo Kösters 2021-08-04 21:09:48 +00:00
commit 1cf9da26bf
2 changed files with 6 additions and 4 deletions

View file

@ -55,6 +55,7 @@ impl Engine {
conn.pragma_update(Some(Main), "journal_mode", &"WAL")?;
conn.pragma_update(Some(Main), "synchronous", &"NORMAL")?;
conn.pragma_update(Some(Main), "cache_size", &(-i64::from(cache_size_kb)))?;
conn.pragma_update(Some(Main), "wal_autocheckpoint", &0)?;
Ok(conn)
}

View file

@ -228,11 +228,9 @@ where
.headers_mut()
.insert(HOST, HeaderValue::from_str(&host).unwrap());
let mut reqwest_request = reqwest::Request::try_from(http_request)
let reqwest_request = reqwest::Request::try_from(http_request)
.expect("all http requests are valid reqwest requests");
*reqwest_request.timeout_mut() = Some(Duration::from_secs(30));
let url = reqwest_request.url().clone();
let response = globals.reqwest_client().execute(reqwest_request).await;
@ -273,7 +271,10 @@ where
if status == 200 {
let response = T::IncomingResponse::try_from_http_response(http_response);
response.map_err(|_| Error::BadServerResponse("Server returned bad 200 response."))
response.map_err(|e| {
warn!("Invalid 200 response: {}", e);
Error::BadServerResponse("Server returned bad 200 response.")
})
} else {
Err(Error::FederationError(
destination.to_owned(),