use hashmap instead of vector to store config table

Author: habby1012

examples/examples/receiver.rs

@@ -12,9 +12,9 @@ fn main() {
 
     // Subscribe to "data1"
     let _sub_data1 = session
-        .declare_subscriber("UserDefined/test/data1")
+        .declare_subscriber("system/emergency/hazard_status")
         .callback(|sample| {
-            handle_sample("UserDefined/test/data1", sample.payload().to_bytes());
+            handle_sample("system/emergency/hazard_status", sample.payload().to_bytes());
         })
         .background()
         .wait()

examples/examples/sender.rs

@@ -15,7 +15,7 @@ fn main() {
 
     // Publisher 1: user-specified priority
     let pub1 = session
-        .declare_publisher("UserDefined/test/data1")
+        .declare_publisher("system/emergency/hazard_status")
         .congestion_control(CongestionControl::Block)
         .priority(user_priority)
         .express(express)

zenoh/src/api/session.rs

@@ -1234,15 +1234,18 @@ pub struct TopicInfo {
     pub bandwidth: String,
 }
 
-pub static TOPIC_TABLE: OnceCell<Vec<TopicInfo>> = OnceCell::new();
+pub static TOPIC_TABLE: OnceCell<HashMap<String, TopicInfo>> = OnceCell::new();
 
-fn read_topic_table(path: &str) -> Vec<TopicInfo> {
+fn read_topic_table(path: &str) -> HashMap<String, TopicInfo> {
     let mut rdr = csv::ReaderBuilder::new()
         .has_headers(false)
         .from_path(path)
         .expect("Cannot open CSV");
     rdr.deserialize()
-        .map(|res| res.expect("CSV parse error"))
+        .map(|res| {
+            let info: TopicInfo = res.expect("CSV parse error");
+            (info.topic.clone(), info)
+        })
         .collect()
 }
 

zenoh/src/net/routing/dispatcher/pubsub.rs

@@ -304,13 +304,9 @@ pub fn route_data(
             let flow_name = format!("{}{}", prefix.expr(), wire_expr.suffix.as_ref());
 
             if let Some(table) = TOPIC_TABLE.get() {
-                for info in table {
-                    if info.topic == flow_name {
-                        println!("Match: {:?}", info);
-                    }
+                if let Some(info) = table.get(&flow_name) {
+                   tracing::debug!("Match: {:?}", info);
                 }
-            } else {
-                println!("TOPIC_TABLE not initialized");
             }
 
             tracing::trace!(