SEND_CACHE_HASH_PERIOD=120

sifis-home · Jun 20, 2023 · daf119b · daf119b
1 parent 9fc2ea4
commit daf119b
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/dht-cache/src/domocache.rs b/dht-cache/src/domocache.rs
@@ -42,7 +42,7 @@ pub enum DomoEvent {
 }
 
 // period at which we send messages containing our cache hash
-const SEND_CACHE_HASH_PERIOD: u8 = 5;
+const SEND_CACHE_HASH_PERIOD: u8 = 120;
 
 #[derive(Clone, Debug, PartialEq, Eq, Deserialize, Serialize)]
 pub struct DomoCacheElement {

diff --git a/src/domobroker.rs b/src/domobroker.rs
@@ -8,6 +8,7 @@ use crate::websocketmessage::{
 };
 
 use serde_json::json;
+use crate::utils::get_epoch_ms;
 
 pub struct DomoBroker {
     pub domo_cache: DomoCache,
@@ -259,6 +260,7 @@ impl DomoBroker {
                         deleted: m.deleted,
                     },
                 );
+                println!("SENT DATA ON WS {}", get_epoch_ms());
                 DomoEvent::PersistentData(m2)
             }
             Ok(DomoEvent::VolatileData(m)) => {

diff --git a/src/webapimanager.rs b/src/webapimanager.rs
@@ -25,6 +25,7 @@ use crate::websocketmessage::{
 use crate::{restmessage, utils};
 
 use std::net::TcpListener;
+use crate::utils::get_epoch_ms;
 
 pub struct WebApiManager {
     // rest api listening port
@@ -61,7 +62,7 @@ impl WebApiManager {
             _ = socket::setsockopt(listener.as_raw_fd(), ReuseAddr, &true);
         }
 
-        let (tx_rest, rx_rest) = mpsc::channel(32);
+        let (tx_rest, rx_rest) = mpsc::channel(64);
 
         let tx_get_all = tx_rest.clone();
 
@@ -200,9 +201,10 @@ impl WebApiManager {
             responder: tx_resp,
         };
 
+        println!("Sending POST REQ {}", get_epoch_ms());
         tx_rest.send(m).await.unwrap();
-
         let resp = rx_resp.await.unwrap();
+        println!("Received POST RESP {}", get_epoch_ms());
 
         match resp {
             Ok(resp) => (StatusCode::OK, Json(resp)),