Searched defs:TaskMessage (Results 1 – 14 of 14) sorted by relevance
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| D | task.rs | 33 async fn daemon_shell_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_shell_task()
103 async fn daemon_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_channel_close()
123 async fn daemon_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_file_task()
239 async fn daemon_hilog_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_hilog_task()
258 async fn daemon_bug_report_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_bug_report_task()
321 pub async fn dispatch_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in dispatch_task()
|
| D | auth.rs | 98 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() argument
164 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage { in make_sign_message()
180 async fn make_bypass_message(session_id: u32, channel_id: u32, host_ver: &str) -> TaskMessage { in make_bypass_message()
228 async fn make_emg_message(session_id: u32, channel_id: u32, emgmsg: &str) -> TaskMessage { in make_emg_message()
256 ) -> TaskMessage { in make_reject_message()
293 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage { in make_ok_message()
358 pub async fn make_channel_close_message(channel_id: u32) -> TaskMessage { in make_channel_close_message()
556 pub async fn handshake_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in handshake_task()
|
| D | mod.rs | 69 pub async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> { in handle_message()
234 handshake_message: TaskMessage, in uart_handshake()
|
| D | bridge.rs | 149 pub async fn put(session_id: u32, data: TaskMessage) { in put()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | task.rs | 466 pub async fn usb_handle_deamon(ptr: u64, mut rx: mpsc::BoundedReceiver<(TaskMessage, u32)>, session… in usb_handle_deamon()
604 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32, connect_key: String) -> … in session_task_dispatch()
665 async fn session_forward_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_forward_task()
677 async fn session_forward_success(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_forward_success()
682 async fn session_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_file_task()
770 pub async fn session_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_channel_close()
|
| D | auth.rs | 121 pub async fn handshake_task(msg: TaskMessage, session_id: u32, connect_key: String) -> io::Result<(… in handshake_task()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | base.rs | 77 tx: BoundedSender<TaskMessage>, in unpack_task_message_lock()
171 tx: BoundedSender<(TaskMessage, u32, u32)>, in unpack_task_message()
|
| D | tcp.rs | 56 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> { in unpack_task_message()
|
| D | buffer.rs | 127 async fn put(session_id: u32, data: TaskMessage) { in put()
331 pub async fn put(session_id: u32, data: TaskMessage) { in put()
427 pub fn usb_start_recv(fd: i32, _session_id: u32) -> mpsc::BoundedReceiver<(TaskMessage, u32, u32)> { in usb_start_recv()
|
| D | uart_wrapper.rs | 518 pub async fn wrap_put(session_id: u32, data: TaskMessage, package_index: u32, option: u8) { in wrap_put()
|
| /developtools/hdc/hdc_rust/src/host_transfer/ |
| D | host_usb.rs | 213 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message()
268 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in start_recv()
286 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in start_recv_once()
|
| /developtools/hdc/hdc_rust/src/ |
| D | config.rs | 67 pub struct TaskMessage { struct
68 pub channel_id: u32,
69 pub command: HdcCommand,
70 pub payload: Vec<u8>,
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | hdctransfer.rs | 267 ) -> JoinHandle<(bool, TaskMessage)> { in spawn_handler() argument
|
| D | forward.rs | 539 pub async fn on_forward_success(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in on_forward_success()
|