Lines Matching defs:u32
59 pub async fn put(session_id: u32, conn_type: ConnectType) { in put()
72 pub async fn del(session_id: u32) { in del()
127 async fn put(session_id: u32, data: TaskMessage) { in put()
139 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message()
162 pub async fn start(id: u32, wr: SplitWriteHalf) { in start()
171 pub async fn end(id: u32) { in end()
203 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put()
245 pub async fn start(session_id: u32, wr: UsbWriter) { in start()
268 pub async fn end(session_id: u32) { in end()
307 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> { in put()
318 pub async fn start(session_id: u32, wr: UartWriter) { in start()
331 pub async fn put(session_id: u32, data: TaskMessage) { in put()
362 pub async fn send_channel_data(channel_id: u32, data: Vec<u8>) { in send_channel_data()
384 pub async fn send_channel_msg(channel_id: u32, level: EchoLevel, msg: String) -> io::Result<()> { in send_channel_msg()
427 pub fn usb_start_recv(fd: i32, _session_id: u32) -> mpsc::BoundedReceiver<(TaskMessage, u32, u32)> { in usb_start_recv() argument
462 pub async fn add(session_id: u32) { in add()