Lines Matching refs:io
32 use std::io::{self, Error, ErrorKind};
51 pub async fn channel_task_dispatch(task_info: TaskInfo) -> io::Result<()> {
142 async fn channel_forward_task(task_info: TaskInfo) -> io::Result<()> {
168 async fn channel_forward_remove(task_info: TaskInfo, forward_or_reverse: bool) -> io::Result<()> {
205 async fn channel_forward_list(task_info: TaskInfo, forward_or_reverse: bool) -> io::Result<()> {
241 async fn channel_jdwp_task(task_info: TaskInfo) -> io::Result<()> {
260 async fn channel_hilog_task(task_info: TaskInfo) -> io::Result<()> {
280 async fn channel_bug_report_task(task_info: TaskInfo) -> io::Result<()> {
295 async fn channel_file_task(task_info: TaskInfo) -> io::Result<()> {
312 return Err(io::Error::new(
313 io::ErrorKind::Other,
355 async fn send_to_daemon(task_info: TaskInfo, _cmd: HdcCommand, param_start_idx: usize, async_flag: bool) -> io::Result<()> {
374 async fn channel_unity_task(task_info: TaskInfo) -> io::Result<()> {
397 async fn channel_shell_task(task_info: TaskInfo) -> io::Result<()> {
447 async fn channel_connect_task(task_info: TaskInfo) -> io::Result<()> {
462 pub async fn usb_handle_deamon(ptr: u64, mut rx: mpsc::BoundedReceiver<(TaskMessage, u32)>, session_id: u32, connect_key: String) -> io::Result<()> {
499 async fn start_tcp_daemon_session(connect_key: String, task_info: &TaskInfo) -> io::Result<()> {
530 async fn channel_list_targets_task(task_info: TaskInfo) -> io::Result<()> {
544 async fn channel_wait_for_any(task_info: TaskInfo) -> io::Result<()> {
578 ) -> io::Result<()> {
600 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32, connect_key: String) -> io::Result<()> {
661 async fn session_forward_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
673 async fn session_forward_success(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
678 async fn session_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
765 pub async fn session_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
779 async fn check_server_task(task_info: TaskInfo) -> io::Result<()> {
934 async fn get_valid_session_id(connect_key: String, channel_id: u32) -> io::Result<u32> {