Lines Matching defs:map
63 let mut map = arc_map.write().await;
64 map.insert(session_id, conn_type.clone());
65 crate::debug!("connect map: add {session_id}, {:?}", conn_type);
70 let map = arc_map.read().await;
71 map.get(&session_id).cloned()
76 let mut map = arc_map.write().await;
77 let item = map.remove(&session_id);
79 crate::debug!("connect map: del {session_id}: {:?}", item);
85 let map = arc_map.read().await;
86 for item in map.iter() {
94 let map = arc_map.read().await;
96 for item in map.iter() {
111 map: Mutex<HashMap<u32, TcpWriter_>>,
121 map: Mutex::new(HashMap::new())
132 let map = instance.map.lock().await;
133 let Some(arc_wr) = map.get(&session_id) else {
145 .map(|&c| format!("{c:02X}"))
155 let map = instance.map.lock().await;
156 if let Some(guard) = map.get(&channel_id) {
166 let mut map = instance.map.lock().await;
168 map.insert(id, arc_wr);
175 let mut map = instance.map.lock().await;
176 if let Some(arc_wr) = map.remove(&id) {
186 map: std::sync::Mutex<HashMap<u32, UsbWriter>>,
197 map: std::sync::Mutex::new(HashMap::new()),
214 let mut map = instance.map.lock().unwrap();
215 let Some(arc_wr) = map.get(&session_id) else {
262 if let Ok(mut map) = buffer_map.map.try_lock() {
263 map.insert(session_id, wr);
285 if let Ok(mut map) = buffer_map.map.try_lock() {
286 let _ = map.remove(&session_id);
319 let map = instance.read().await;
320 let Some(arc_wr) = map.get(&session_id) else {
330 let mut map = instance.write().await;
332 if map.contains_key(&session_id) {
336 map.insert(session_id, arc_wr);
422 let mut map = instance.write().await;
424 map.insert(0, arc_rd);
429 let map = instance.read().await;
430 let Some(arc_rd) = map.get(&0) else {