dandri/mycelium
1
0 Fork 0
mirror of https://github.com/threefoldtech/mycelium.git synced 2026-10-23 22:12:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use more constants for router timings

Browse Source 
Signed-off-by: Lee Smet <lee.smet@hotmail.com>
This commit is contained in:
Lee Smet committed 2023-11-06 15:45:40 +01:00
1 parent a2c44e68db
commit 4f2da4b4f7
1 file changed
+5 -3
Download Patch File Download Diff File Expand all files Collapse all files
src/router.rs
+5 -3
View File
@@ -25,6 +25,8 @@ use tokio::sync::mpsc::{self, Receiver, Sender, UnboundedReceiver, UnboundedSend
const HELLO_INTERVAL: u16 = 4;
const IHU_INTERVAL: u16 = HELLO_INTERVAL * 3;
const UPDATE_INTERVAL: u16 = HELLO_INTERVAL * 4;
const ROUTE_PROPAGATION_INTERVAL: u64 = 3;
const DEAD_PEER_TRESHOLD: u64 = 8;
#[derive(Debug, Clone, Copy)]
pub struct StaticRoute {
@@ -252,7 +254,7 @@ impl Router {
}
async fn check_for_dead_peers(self, router_id: RouterId) {
let ihu_threshold = tokio::time::Duration::from_secs(8);
let ihu_threshold = tokio::time::Duration::from_secs(DEAD_PEER_TRESHOLD);
loop {
// check for dead peers every second
@@ -600,7 +602,7 @@ impl Router {
pub async fn propagate_static_route(self) {
loop {
tokio::time::sleep(tokio::time::Duration::from_secs(3)).await;
tokio::time::sleep(tokio::time::Duration::from_secs(ROUTE_PROPAGATION_INTERVAL)).await;
trace!("Propagating static routes");
@@ -618,7 +620,7 @@ impl Router {
pub async fn propagate_selected_routes(self) {
loop {
tokio::time::sleep(tokio::time::Duration::from_secs(3)).await;
tokio::time::sleep(tokio::time::Duration::from_secs(ROUTE_PROPAGATION_INTERVAL)).await;
trace!("Propagating selected routes");