Searched refs:queue_sync (Results 1 – 1 of 1) sorted by relevance
25 queue_sync: std::sync::Mutex<Option<fmq::MessageQueue<i32>>>, field49 *self.queue_sync.lock().unwrap() = Some(fmq::MessageQueue::from_desc(mq_desc, false)); in configureFmqSyncReadWrite()68 let mut queue_guard = self.queue_sync.lock().unwrap(); in requestReadFmqSync()96 let mut queue_guard = self.queue_sync.lock().unwrap(); in requestWriteFmqSync()