Lines Matching refs:instance
74 let instance = Self::get_instance(); in start_session() localVariable
75 instance.response_waiters.insert(session_id, Waiter::new()); in start_session()
76 instance.empty_waiters.insert(session_id, Waiter::new()); in start_session()
81 let instance = Self::get_instance(); in wait_response() localVariable
82 let waiter = instance.response_waiters.get(&session_id); in wait_response()
90 let instance = Self::get_instance(); in wakeup_response_wait() localVariable
91 let waiter = instance.response_waiters.get(&session_id); in wakeup_response_wait()
99 let instance = Self::get_instance(); in wait_empty() localVariable
100 let waiter = instance.empty_waiters.get(&session_id); in wait_empty()
108 let instance = Self::get_instance(); in wakeup_empty_wait() localVariable
109 let waiter = instance.empty_waiters.get(&session_id); in wakeup_empty_wait()
177 let instance = Self::get_instance(); in get_package() localVariable
178 let mtx = instance.lock().await; in get_package()
192 let instance = Self::get_instance(); in put_package() localVariable
193 let mut mtx = instance.lock().await; in put_package()
209 let instance = Self::get_instance(); in update_package() localVariable
210 let mtx = instance.lock().await; in update_package()
225 let instance = Self::get_instance(); in get_stop_flag() localVariable
226 let mtx = instance.lock().await; in get_stop_flag()
238 let instance = Self::get_instance(); in set_stop_flag() localVariable
239 let mut mtx = instance.lock().await; in set_stop_flag()
245 let instance = Self::get_instance(); in remove_package() localVariable
246 let mtx = instance.lock().await; in remove_package()
259 let instance = Self::get_instance(); in remove_session() localVariable
260 let mut mtx = instance.lock().await; in remove_session()
382 let instance = QueueManager::get_instance(); in start_session() localVariable
383 let mut mtx = instance.lock().await; in start_session()
400 let instance = QueueManager::get_instance(); in stop_session() localVariable
401 let mut mtx = instance.lock().await; in stop_session()
410 let instance = QueueManager::get_instance(); in stop_other_session() localVariable
411 let mtx = instance.lock().await; in stop_other_session()