Compare commits

..

2 Commits

Author SHA1 Message Date
kozabrada123 c8a3fdb132 argh 2024-01-19 13:58:44 +01:00
kozabrada123 6d0fae1510 into 2024-01-19 13:52:56 +01:00
1 changed files with 10 additions and 10 deletions

View File

@ -30,7 +30,7 @@ impl HeartbeatHandler {
kill_rc: tokio::sync::broadcast::Receiver<()>, kill_rc: tokio::sync::broadcast::Receiver<()>,
) -> Self { ) -> Self {
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: Creating new self"); web_sys::console::log_1(&String::from("HBH: Creating new self").into());
let (send, receive) = tokio::sync::mpsc::channel(32); let (send, receive) = tokio::sync::mpsc::channel(32);
let kill_receive = kill_rc.resubscribe(); let kill_receive = kill_rc.resubscribe();
@ -44,7 +44,7 @@ impl HeartbeatHandler {
Self::heartbeat_task(websocket_tx, heartbeat_interval, receive, kill_receive).await; Self::heartbeat_task(websocket_tx, heartbeat_interval, receive, kill_receive).await;
}); });
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: Spawned task"); web_sys::console::log_1(&String::from("HBH: Spawned task").into());
Self { Self {
heartbeat_interval, heartbeat_interval,
@ -63,23 +63,23 @@ impl HeartbeatHandler {
mut kill_receive: tokio::sync::broadcast::Receiver<()>, mut kill_receive: tokio::sync::broadcast::Receiver<()>,
) { ) {
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: Running task"); web_sys::console::log_1(&String::from("HBH: Running task").into());
let mut last_heartbeat_timestamp: Instant = time::Instant::now(); let mut last_heartbeat_timestamp: Instant = time::Instant::now();
let mut last_heartbeat_acknowledged = true; let mut last_heartbeat_acknowledged = true;
let mut last_seq_number: Option<u64> = None; let mut last_seq_number: Option<u64> = None;
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: Initialized variables"); web_sys::console::log_1(&String::from("HBH: Initialized variables").into());
safina_timer::start_timer_thread(); safina_timer::start_timer_thread();
loop { loop {
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: L0"); web_sys::console::log_1(&String::from("HBH: L0").into());
println!("HBH: L0"); println!("HBH: L0");
if kill_receive.try_recv().is_ok() { if kill_receive.try_recv().is_ok() {
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: dying"); web_sys::console::log_1(&String::from("HBH: dying").into());
println!("HBH: dying"); println!("HBH: dying");
trace!("GW: Closing heartbeat task"); trace!("GW: Closing heartbeat task");
@ -96,7 +96,7 @@ impl HeartbeatHandler {
let mut should_send = false; let mut should_send = false;
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: L1"); web_sys::console::log_1(&String::from("HBH: L1").into());
println!("HBH: L1"); println!("HBH: L1");
@ -127,7 +127,7 @@ impl HeartbeatHandler {
} }
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: L2"); web_sys::console::log_1(&String::from("HBH: L2").into());
println!("HBH: L2"); println!("HBH: L2");
@ -135,7 +135,7 @@ impl HeartbeatHandler {
trace!("GW: Sending Heartbeat.."); trace!("GW: Sending Heartbeat..");
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: L3, sending"); web_sys::console::log_1(&String::from("HBH: L3, sending").into());
println!("HBH: L3, sending"); println!("HBH: L3, sending");
@ -159,7 +159,7 @@ impl HeartbeatHandler {
last_heartbeat_acknowledged = false; last_heartbeat_acknowledged = false;
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
web_sys::console::log_1("HBH: L4, sending done"); web_sys::console::log_1(&String::from("HBH: L4, sending done").into());
} }
} }
} }