From 57c993e8d553a3400a5b7fd7d8a1cca96c0ce973 Mon Sep 17 00:00:00 2001
From: Dennis Schwerdel <schwerdel@googlemail.com>
Date: Wed, 17 Jun 2020 22:53:14 +0200
Subject: [PATCH] Fix keepalive for small timeouts

---
 CHANGELOG.md  | 1 +
 src/cloud.rs  | 4 ++--
 src/config.rs | 5 +++--
 3 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 6dc251f..5fd9225 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -7,6 +7,7 @@ This project follows [semantic versioning](http://semver.org).
 
 - [added] Added crypto option AES128
 - [changed] Updated dependencies
+- [fixed] Fixed keepalive for small timeouts
 
 
 ### v1.4.0 (2020-06-03)
diff --git a/src/cloud.rs b/src/cloud.rs
index 0f31c6b..88865e5 100644
--- a/src/cloud.rs
+++ b/src/cloud.rs
@@ -3,7 +3,7 @@
 // This software is licensed under GPL-3 or newer (see LICENSE.md)
 
 use std::{
-    cmp::min,
+    cmp::{min, max},
     collections::HashMap,
     fmt,
     fs::{self, File},
@@ -473,7 +473,7 @@ impl<D: Device, P: Protocol, T: Table, S: Socket, TS: TimeSource> GenericCloud<D
             let mut msg = Message::Peers(peers);
             self.broadcast_msg(&mut msg)?;
             // Reschedule for next update
-            let interval = min(self.update_freq as u16, self.peers.min_peer_timeout());
+            let interval = min(self.update_freq as u16, max(self.peers.min_peer_timeout()/2-60, 1));
             self.next_peerlist = now + Time::from(interval);
         }
         // Connect to those reconnect_peers that are due
diff --git a/src/config.rs b/src/config.rs
index 6989ec7..ce09a76 100644
--- a/src/config.rs
+++ b/src/config.rs
@@ -14,7 +14,8 @@ use super::{
 use siphasher::sip::SipHasher24;
 use std::{
     hash::{Hash, Hasher},
-    net::{IpAddr, Ipv6Addr, SocketAddr}
+    net::{IpAddr, Ipv6Addr, SocketAddr},
+    cmp::max
 };
 
 
@@ -284,7 +285,7 @@ impl Config {
     pub fn get_keepalive(&self) -> Duration {
         match self.keepalive {
             Some(dur) => dur,
-            None => self.peer_timeout / 2 - 60
+            None => max(self.peer_timeout / 2 - 60, 1)
         }
     }
 }