Lines Matching refs:map
52 let mut map = arc_map.write().await; in put() localVariable
53 map.insert(session_id, conn_type); in put()
58 let map = arc_map.read().await; in get() localVariable
59 map.get(&session_id).unwrap().clone() in get()
80 let map = instance.read().await; in put() localVariable
81 let arc_wr = map.get(&session_id).unwrap(); in put()
94 let map = instance.read().await; in send_channel_message() localVariable
95 if let Some(guard) = map.get(&channel_id) { in send_channel_message()
105 let mut map = instance.write().await; in start() localVariable
107 map.insert(id, arc_wr); in start()
113 let mut map = instance.write().await; in end() localVariable
114 if let Some(arc_wr) = map.remove(&id) { in end()
142 let map = instance.read().await; in put() localVariable
143 let arc_wr = map.get(&session_id).unwrap(); in put()
153 let mut map = buffer_map.write().await; in start() localVariable
155 map.insert(session_id, arc_wr); in start()
177 let map = instance.read().await; in put() localVariable
178 let arc_wr = map.get(&session_id).unwrap(); in put()
186 let mut map = instance.write().await; in start() localVariable
188 if map.contains_key(&session_id) { in start()
192 map.insert(session_id, arc_wr); in start()
250 let mut map = instance.write().await; in start() localVariable
252 map.insert(0, arc_rd); in start()
257 let map = instance.read().await; in recv() localVariable
258 let arc_rd = map.get(&0).unwrap(); in recv()