Searched defs:TaskMessage (Results 1 – 11 of 11) sorted by relevance
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | task.rs | 46 async fn daemon_shell_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_shell_task()
95 async fn daemon_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_channel_close()
110 async fn daemon_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_file_task()
219 async fn daemon_hilog_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_hilog_task()
238 async fn daemon_bug_report_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_bug_report_task()
302 pub async fn dispatch_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in dispatch_task()
|
| D | auth.rs | 77 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() argument
140 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage { in make_sign_message()
156 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage { in make_ok_message()
191 pub async fn handshake_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in handshake_task()
|
| D | main.rs | 59 async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> { in handle_message()
130 handshake_message: TaskMessage, in uart_handshake()
|
| D | shell.rs | 184 ) -> io::Result<TaskMessage> { in pty_echo()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | base.rs | 72 tx: BoundedSender<TaskMessage>, in unpack_task_message_lock()
166 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message()
|
| D | tcp.rs | 54 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> { in unpack_task_message()
|
| D | buffer.rs | 77 async fn put(session_id: u32, data: TaskMessage) { in put()
197 pub async fn put(session_id: u32, data: TaskMessage) { in put()
264 pub fn usb_start_recv(fd: i32, _session_id: u32) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in usb_start_recv()
|
| D | uart_wrapper.rs | 499 pub async fn wrap_put(session_id: u32, data: TaskMessage, package_index: u32, option: u8) { in wrap_put()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | task.rs | 370 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_task_dispatch()
393 async fn session_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_file_task()
435 async fn session_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_channel_close()
|
| /developtools/hdc/hdc_rust/src/ |
| D | config.rs | 65 pub struct TaskMessage { struct
66 pub channel_id: u32,
67 pub command: HdcCommand,
68 pub payload: Vec<u8>,
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | hdctransfer.rs | 158 ) -> JoinHandle<(bool, TaskMessage)> { in spawn_handler() argument
|