Fix OAM handling

eclipse-zenoh · Jan 10, 2024 · b69ae82 · b69ae82
1 parent 458e64c
commit b69ae82
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/zenoh/src/net/primitives/demux.rs b/zenoh/src/net/primitives/demux.rs
@@ -62,7 +62,13 @@ impl TransportPeerEventHandler for DeMux {
             NetworkBody::Request(m) => self.face.send_request(m),
             NetworkBody::Response(m) => self.face.send_response(m),
             NetworkBody::ResponseFinal(m) => self.face.send_response_final(m),
-            NetworkBody::OAM(_m) => (),
+            NetworkBody::OAM(m) => {
+                if let Some(transport) = self.transport.as_ref() {
+                    let ctrl_lock = zlock!(self.face.tables.ctrl_lock);
+                    let mut tables = zwrite!(self.face.tables.tables);
+                    ctrl_lock.handle_oam(&mut tables, &self.face.tables, m, transport)?
+                }
+            }
         }
 
         // match ctx.msg.body {