Retire the notion of Epoch and replace it with an optional, limited-use WallClock and use it only where a wall clock is strictly necessary

Author: ivmarkov

bloat-check/src/bin/bloat-check.rs

@@ -89,7 +89,6 @@ use rs_matter::transport::network::mdns::builtin::{BuiltinMdnsResponder, Host};
 use rs_matter::transport::network::{
     Address, ChainedNetwork, Ipv4Addr, Ipv6Addr, NetworkReceive, NetworkSend, NoNetwork,
 };
-use rs_matter::utils::epoch::dummy_epoch;
 use rs_matter::utils::init::{init, Init, InitMaybeUninit};
 use rs_matter::utils::storage::pooled::PooledBuffers;
 use rs_matter::utils::sync::DynBase;
@@ -174,12 +173,11 @@ impl<'a> MatterStack<'a> {
                 &TEST_DEV_DET,
                 TEST_DEV_COMM,
                 &TEST_DEV_ATT,
-                dummy_epoch,
                 MATTER_PORT,
             ),
             buffers <- PooledBuffers::init(0),
             subscriptions <- Subscriptions::init(),
-            events <- Events::init(dummy_epoch),
+            events <- Events::init(),
             networks <- SharedNetworks::init(WifiNetworks::init()),
             net_ctl_state <- NetCtlState::init_with_mutex(),
             btp <- Btp::init(),

examples/src/bin/bridge.rs

@@ -69,10 +69,10 @@ fn main() -> Result<(), Error> {
     );
 
     // Create the Matter object
-    let mut matter = Matter::new_default(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
+    let mut matter = Matter::new(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
 
     // Create the events
-    let mut events: Events = Events::new_default();
+    let mut events: Events = Events::new();
 
     // Persistence
     let mut kv_buf = [0; 4096];

examples/src/bin/camera_tests.rs

@@ -406,7 +406,6 @@ fn main() -> Result<(), Error> {
         &BASIC_INFO,
         TEST_DEV_COMM,
         &TEST_DEV_ATT,
-        rs_matter::utils::epoch::sys_epoch,
         MATTER_PORT,
     ));
 
@@ -566,7 +565,7 @@ fn main() -> Result<(), Error> {
         core::mem::size_of::<PooledBuffers<10, rs_matter::dm::IMBuffer>>(),
     );
 
-    let events = NoEvents::new_default();
+    let events = NoEvents::new();
     let dm = DataModel::new(
         matter,
         &crypto,

examples/src/bin/chip_tool_tests.rs

@@ -146,16 +146,13 @@ fn main() -> Result<(), Error> {
         comm_data.discriminator, passcode, port,
     );
 
-    let matter = MATTER.uninit().init_with(Matter::init(
-        &BASIC_INFO,
-        comm_data,
-        &TEST_DEV_ATT,
-        rs_matter::utils::epoch::sys_epoch,
-        port,
-    ));
+    let matter =
+        MATTER
+            .uninit()
+            .init_with(Matter::init(&BASIC_INFO, comm_data, &TEST_DEV_ATT, port));
 
     // Create the event queue
-    let events = EVENTS.uninit().init_with(Events::init_default());
+    let events = EVENTS.uninit().init_with(Events::init());
 
     // Persistence
     let kv_buf = KV_BUF.uninit().init_zeroed().as_mut_slice();

examples/src/bin/dimmable_light.rs

@@ -125,12 +125,11 @@ fn run() -> Result<(), Error> {
         &TEST_DEV_DET,
         TEST_DEV_COMM,
         &TEST_DEV_ATT,
-        rs_matter::utils::epoch::sys_epoch,
         MATTER_PORT,
     ));
 
     // Create the event queue
-    let events = EVENTS.uninit().init_with(Events::init_default());
+    let events = EVENTS.uninit().init_with(Events::init());
 
     // Persistence
     let kv_buf = KV_BUF.uninit().init_zeroed().as_mut_slice();

examples/src/bin/media_player.rs

@@ -85,10 +85,10 @@ fn main() -> Result<(), Error> {
     );
 
     // Create the Matter object
-    let mut matter = Matter::new_default(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
+    let mut matter = Matter::new(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
 
     // Create the event queue
-    let mut events: Events = Events::new_default();
+    let mut events: Events = Events::new();
 
     // Persistence
     let mut kv_buf = [0; 4096];

examples/src/bin/onoff_light.rs

@@ -99,7 +99,6 @@ fn run() -> Result<(), Error> {
         &TEST_DEV_DET,
         TEST_DEV_COMM,
         &TEST_DEV_ATT,
-        rs_matter::utils::epoch::sys_epoch,
         MATTER_PORT,
     ));
 
@@ -126,7 +125,7 @@ fn run() -> Result<(), Error> {
         TestOnOffDeviceLogic::new(true),
     );
 
-    let events = NoEvents::new_default();
+    let events = NoEvents::new();
 
     // Create the Data Model instance
     let dm = DataModel::new(

examples/src/bin/onoff_light_bt.rs

@@ -119,13 +119,13 @@ fn main() -> Result<(), Error> {
 
 fn run<N: NetCtl + WifiDiag>(connection: &Connection, net_ctl: N) -> Result<(), Error> {
     // Create the Matter object
-    let mut matter = Matter::new_default(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
+    let mut matter = Matter::new(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
 
     // A storage for the Wifi networks
     let mut networks = WifiNetworks::<3>::new();
 
     // Create the event queue
-    let mut events: Events = Events::new_default();
+    let mut events: Events = Events::new();
 
     // Persistence
     let mut kv_buf = [0; 4096];

examples/src/bin/onoff_light_work_stealing.rs

@@ -106,12 +106,11 @@ fn run() -> Result<(), Error> {
         &TEST_DEV_DET,
         TEST_DEV_COMM,
         &TEST_DEV_ATT,
-        rs_matter::utils::epoch::sys_epoch,
         MATTER_PORT,
     ));
 
     // Create the events
-    let events = EVENTS.uninit().init_with(Events::init_default());
+    let events = EVENTS.uninit().init_with(Events::init());
 
     // Persistence
     let kv_buf = KV_BUF.uninit().init_zeroed().as_mut_slice();

examples/src/bin/speaker.rs

@@ -64,10 +64,10 @@ fn main() -> Result<(), Error> {
     );
 
     // Create the Matter object
-    let mut matter = Matter::new_default(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
+    let mut matter = Matter::new(&TEST_DEV_DET, TEST_DEV_COMM, &TEST_DEV_ATT, MATTER_PORT);
 
     // Create the event queue
-    let mut events: Events = Events::new_default();
+    let mut events: Events = Events::new();
 
     // Persistence
     let mut kv_buf = [0; 4096];