Searched defs:BufferReleaseMsg (Results 1 – 1 of 1) sorted by relevance
576 subscribers: &Arc<Mutex<HashMap<usize, Sender<BufferReleaseMsg>>>>, in recv_buffer_status_msg()629 tx_subscribers: Arc<Mutex<HashMap<usize, Sender<BufferReleaseMsg>>>>, in spawn_recv_thread()680 let BufferReleaseMsg { in await_status() localVariable831 struct BufferReleaseMsg { struct832 status: u32,833 latency: u32,834 consumed_len: usize,