Searched defs:BufferReleaseMsg (Results 1 – 1 of 1) sorted by relevance
563 subscribers: &Arc<Mutex<HashMap<usize, Sender<BufferReleaseMsg>>>>, in recv_buffer_status_msg()616 tx_subscribers: Arc<Mutex<HashMap<usize, Sender<BufferReleaseMsg>>>>, in spawn_recv_thread()664 let BufferReleaseMsg { in await_status() localVariable816 struct BufferReleaseMsg { struct817 status: u32,818 latency: u32,819 consumed_len: usize,