Compare commits

...

12 Commits

Author SHA1 Message Date
Bogdan-Ștefan Neacşu 1104911688 Configure bw reset via RESET_EVERY env var 2024-09-03 13:28:11 +00:00
benedettadavico 9c88f254a4 10 mins test 2024-09-03 13:28:11 +00:00
benedettadavico 3599078363 back to the original 2024-09-03 13:28:11 +00:00
benedettadavico 857521592a debug, 1 hour 2024-09-03 13:28:11 +00:00
benedettadavico f1ec92b5c5 debug 2024-09-03 13:28:11 +00:00
benedettadavico f1f84183ff more debug 2024-09-03 13:28:11 +00:00
benedettadavico 561c3db999 debugging more.. 2024-09-03 13:28:11 +00:00
Bogdan-Ștefan Neacşu f0e35599f1 Revert "Disable peer configuring"
This reverts commit 06d37352979d4dfdcc768493484cf5577e9e3221.
2024-09-03 13:28:11 +00:00
Bogdan-Ștefan Neacşu 6590bea1b1 Reset at xx:x5 2024-09-03 13:28:11 +00:00
Bogdan-Ștefan Neacşu ae5057195a Disable peer configuring 2024-09-03 13:28:11 +00:00
Bogdan-Ștefan Neacşu 128a624b2b Use xx:15 instead of o'clock 2024-09-03 13:28:11 +00:00
Bogdan-Ștefan Neacşu f0a8b125f7 Midnight to hourly wg bandwidth refresh 2024-09-03 13:28:11 +00:00
+5 -4
View File
@@ -133,10 +133,11 @@ impl<St: Storage> PeerController<St> {
}
async fn check_peers(&mut self) -> Result<(), Error> {
// Add 10 seconds to cover edge cases. At worst, we give ten free seconds worth of bandwidth
// by resetting the bandwidth twice
let reset = Utc::now().num_seconds_from_midnight() as u64
<= DEFAULT_PEER_TIMEOUT_CHECK.as_secs() + 10;
let reset_every: u32 = std::env::var("RESET_EVERY")
.expect("RESET_EVERY should be set")
.parse()
.expect("RESET_EVERY should be a number");
let reset = Utc::now().minute() % reset_every == 0;
if reset {
for (_, peer) in self.suspended_peers.drain() {