Lines Matching refs:u32
162 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> {
176 Ok((u32::from_be(head.data_size), 0, head.session_id))
195 pub fn build_header(session_id: u32, option: u8, length: usize) -> Vec<u8> {
197 session_id: u32::to_be(session_id),
200 data_size: u32::to_be(length as u32),
207 let expected_size = u32::from_be_bytes(data.try_into().unwrap());
213 tx: BoundedSender<(TaskMessage, u32)>,
224 let expected_data_size = u32::from_be(payload_head.data_size) as usize;
267 _session_id: u32,
268 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> {
269 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32)>(config::USB_QUEUE_LEN);
285 _session_id: u32,
286 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> {
287 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32)>(config::USB_QUEUE_LEN);
298 type HostUsbMap_ = Arc<RwLock<HashMap<u32, HostUsbWriter_>>>;
312 pub async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> {
319 let map: ylong_runtime::sync::RwLockReadGuard<'_, HashMap<u32, Arc<Mutex<HostUsbWriter>>>> =
330 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> {
333 u32::to_be_bytes(buf.len() as u32).as_slice(),
347 pub async fn start(session_id: u32, wr: HostUsbWriter) {
360 pub async fn end(id: u32) {