Lines Matching refs:transfer
40 use crate::transfer;
42 use crate::transfer::base::Reader;
44 use crate::transfer::uart::UartReader;
46 use crate::transfer::uart_wrapper;
47 use crate::transfer::buffer::DiedSession;
138 transfer::put(session_id, send_msg).await;
141 transfer::put(
153 let ret = handle_message(transfer::tcp::unpack_task_message(&rd).await, session_id).await;
168 let msg = transfer::tcp::unpack_task_message(&mut rd).await?;
174 transfer::TcpMap::start(session_id, wr).await;
177 transfer::TcpMap::end(session_id).await;
183 transfer::tcp::unpack_task_message(&mut rd).await,
224 let fd = transfer::uart::uart_init()?;
228 transfer::uart::uart_close(fd);
242 let wr = transfer::uart::UartWriter { fd };
243 transfer::start_uart(session_id, wr).await;
244 transfer::start_session(session_id).await;
253 transfer::wrap_put(session_id, send_msg, package_index, 0).await;
256 transfer::put(
271 let mut rd = transfer::uart::UartReader { fd, head: None };
275 let mut rd = transfer::uart::UartReader { fd, head: None };
277 transfer::base::unpack_task_message_lock(&mut rd, packet_size, tx.clone()).await
318 let mut rd = transfer::uart::UartReader { fd, head: None };
320 transfer::base::unpack_task_message_lock(&mut rd, packet_size, tx.clone()).await
359 let ret = transfer::usb::usb_init();
363 transfer::usb::usb_close(config_fd, bulkin_fd, bulkout_fd);
375 let _rd = transfer::usb::UsbReader { fd: bulkin_fd };
376 let mut rx = transfer::usb_start_recv(bulkin_fd, 0);
386 let wr = transfer::usb::UsbWriter { fd: bulkout_fd };
387 transfer::UsbMap::start(session_id_in_msg, wr).await;