diff options
author | Vika <vika@fireburn.ru> | 2021-08-06 07:52:50 +0300 |
---|---|---|
committer | Vika <vika@fireburn.ru> | 2021-08-06 08:10:13 +0300 |
commit | 29fe8dce1ef6bac807717a9416282f6170010436 (patch) | |
tree | 4a58737bdae9c688f00f35eec5ab53eb4dcafe66 | |
parent | b027a1992e6707cec32e5ba85bfab7789321df7d (diff) | |
download | kittybox-29fe8dce1ef6bac807717a9416282f6170010436.tar.zst |
Shortened a connection timeout and installed a lifetime limit for connection
-rw-r--r-- | src/database/redis/mod.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/database/redis/mod.rs b/src/database/redis/mod.rs index 00932de..3a0d5fc 100644 --- a/src/database/redis/mod.rs +++ b/src/database/redis/mod.rs @@ -10,6 +10,7 @@ use mobc_redis::redis; use mobc_redis::redis::AsyncCommands; use mobc_redis::RedisConnectionManager; use serde_json::json; +use std::time::Duration; use crate::database::{ErrorKind, MicropubChannel, Result, Storage, StorageError}; use crate::indieauth::User; @@ -292,7 +293,7 @@ impl Storage for RedisStorage { // Happens because of a broken link (result of an improper deletion?) None => Ok(None), }, - Err(err) => Err(StorageError::from(err)) + Err(err) => Err(StorageError::with_source(ErrorKind::Backend, "Error executing a Redis command", Box::new(err))) } } Err(err) => Err(StorageError::with_source(ErrorKind::Backend, "Error getting a connection from the pool", Box::new(err))) @@ -360,6 +361,8 @@ impl RedisStorage { redis: Pool::builder() .max_open(20) .max_idle(5) + .get_timeout(Some(Duration::from_secs(3))) + .max_lifetime(Some(Duration::from_secs(120))) .build(RedisConnectionManager::new(client)), }), Err(e) => Err(e.into()), |