Merge pull request #188 from ivmarkov/supports-conc-conn

Re-introduce supports-concurrent-connections
project-chip · Jun 13, 2024 · 2076dc6 · 2076dc6
2 parents 3fbc047 + bac8d45
commit 2076dc6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/rs-matter/src/data_model/root_endpoint.rs b/rs-matter/src/data_model/root_endpoint.rs
@@ -121,6 +121,7 @@ where
         EthNwCommCluster::new(*matter.borrow()),
         ethernet_nw_diagnostics::ID,
         EthNwDiagCluster::new(*matter.borrow()),
+        true,
     )
 }
 
@@ -138,6 +139,7 @@ pub fn handler<'a, NWCOMM, NWDIAG, T>(
     nwcomm: NWCOMM,
     nwdiag_id: u32,
     nwdiag: NWDIAG,
+    supports_concurrent_connection: bool,
 ) -> RootEndpointHandler<'a, NWCOMM, NWDIAG>
 where
     T: Borrow<BasicInfoConfig<'a>>
@@ -167,6 +169,7 @@ where
         nwcomm,
         nwdiag_id,
         nwdiag,
+        supports_concurrent_connection,
     )
 }
 
@@ -186,6 +189,7 @@ fn wrap<'a, NWCOMM, NWDIAG>(
     nwcomm: NWCOMM,
     nwdiag_id: u32,
     nwdiag: NWDIAG,
+    supports_concurrent_connection: bool,
 ) -> RootEndpointHandler<'a, NWCOMM, NWDIAG> {
     EmptyHandler
         .chain(
@@ -225,7 +229,11 @@ fn wrap<'a, NWCOMM, NWDIAG>(
         .chain(
             endpoint_id,
             general_commissioning::ID,
-            HandlerCompat(GenCommCluster::new(failsafe, false, rand)),
+            HandlerCompat(GenCommCluster::new(
+                failsafe,
+                supports_concurrent_connection,
+                rand,
+            )),
         )
         .chain(
             endpoint_id,

diff --git a/rs-matter/src/transport/core.rs b/rs-matter/src/transport/core.rs
@@ -274,7 +274,7 @@ impl<'m> TransportMgr<'m> {
                 send,
                 recv,
                 &PacketBufferExternalAccess(&self.tx),
-                PacketBufferExternalAccess(&self.rx),
+                &PacketBufferExternalAccess(&self.rx),
                 host,
                 interface,
                 self.rand,