| /developtools/hdc/hdc_rust/src/transfer/ |
| D | base.rs | 20 use crate::config::TaskMessage;
72 tx: BoundedSender<TaskMessage>, in unpack_task_message_lock() argument
110 .send(TaskMessage { in unpack_task_message_lock()
132 .send(TaskMessage { in unpack_task_message_lock()
149 .send(TaskMessage { in unpack_task_message_lock()
166 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message() argument
208 TaskMessage { in unpack_task_message()
|
| D | buffer.rs | 23 use crate::config::TaskMessage;
77 async fn put(session_id: u32, data: TaskMessage) { in put() argument
136 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put()
197 pub async fn put(session_id: u32, data: TaskMessage) { in put() argument
264 pub fn usb_start_recv(fd: i32, _session_id: u32) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in usb_start_recv() argument
265 let (tx, rx) = mpsc::bounded_channel::<(TaskMessage, u32)>(config::USB_QUEUE_LEN); in usb_start_recv()
|
| D | tcp.rs | 54 pub async fn unpack_task_message(rd: &mut SplitReadHalf) -> io::Result<TaskMessage> { in unpack_task_message() argument
80 Ok(TaskMessage { in unpack_task_message()
|
| D | uart_wrapper.rs | 19 use crate::config::{self, TaskMessage};
499 pub async fn wrap_put(session_id: u32, data: TaskMessage, package_index: u32, option: u8) { in wrap_put() argument
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | auth.rs | 77 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() argument
132 let message = TaskMessage { in handshake_init()
140 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage { in make_sign_message() argument
149 TaskMessage { in make_sign_message()
156 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage { in make_ok_message() argument
170 TaskMessage { in make_ok_message()
185 pub async fn get_new_session_id(task_message: &TaskMessage) -> io::Result<u32> { in get_new_session_id()
191 pub async fn handshake_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in handshake_task() argument
300 TaskMessage { in handshake_task()
478 TaskMessage { in handshake_fail()
|
| D | task.rs | 46 async fn daemon_shell_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_shell_task() argument
95 async fn daemon_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_channel_close() argument
100 let message = TaskMessage { in daemon_channel_close()
110 async fn daemon_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_file_task() argument
219 async fn daemon_hilog_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_hilog_task() argument
238 async fn daemon_bug_report_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in daemon_bug_report_task() argument
302 pub async fn dispatch_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in dispatch_task() argument
311 TaskMessage { in dispatch_task()
|
| D | main.rs | 35 use hdc::config::TaskMessage;
59 async fn handle_message(res: io::Result<TaskMessage>, session_id: u32) -> io::Result<()> { in handle_message() argument
92 TaskMessage { in tcp_handle_client()
130 handshake_message: TaskMessage, in uart_handshake() argument
149 TaskMessage { in uart_handshake()
163 let (tx, mut rx) = mpsc::bounded_channel::<TaskMessage>(config::USB_QUEUE_LEN); in uart_handle_client()
201 let (tx, mut rx) = mpsc::bounded_channel::<TaskMessage>(config::USB_QUEUE_LEN); in uart_handle_client()
279 TaskMessage { in usb_handle_client()
304 TaskMessage { in usb_handle_client()
|
| D | shell.rs | 19 use hdc::config::TaskMessage;
184 ) -> io::Result<TaskMessage> { in pty_echo() argument
187 let message = TaskMessage { in pty_echo()
279 let message = TaskMessage { in subprocess_task()
|
| D | daemon_app.rs | 22 use hdc::config::TaskMessage;
116 let file_begin_message = TaskMessage { in put_file_begin()
139 let app_finish_message = TaskMessage { in put_app_finish()
|
| D | daemon_unity.rs | 19 use hdc::config::TaskMessage;
35 let echo_message = TaskMessage { in echo_client()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | task.rs | 103 TaskMessage { in channel_hilog_task()
118 TaskMessage { in channel_bug_report_task()
198 TaskMessage { in channel_unity_task()
221 TaskMessage { in channel_shell_task()
232 TaskMessage { in channel_shell_task()
244 TaskMessage { in channel_shell_task()
370 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_task_dispatch() argument
393 async fn session_file_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_file_task() argument
435 async fn session_channel_close(task_message: TaskMessage, session_id: u32) -> io::Result<()> { in session_channel_close() argument
437 let message = TaskMessage { in session_channel_close()
|
| D | host_app.rs | 21 use hdc::config::TaskMessage;
126 let file_check_message = TaskMessage { in put_app_check()
147 let app_uninstall_message = TaskMessage { in do_app_uninstall()
|
| D | auth.rs | 21 use hdc::config::TaskMessage;
148 TaskMessage { in send_handshake_to_daemon()
|
| D | server.rs | 20 use hdc::config::TaskMessage;
127 let message = TaskMessage { in handle_client()
|
| /developtools/hdc/hdc_rust/src/serializer/ |
| D | pack_assemble.rs | 18 use crate::config::TaskMessage;
56 pub fn concat_pack(task_message: TaskMessage) -> Vec<u8> { in concat_pack()
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | hdctransfer.rs | 22 use crate::config::TaskMessage;
158 ) -> JoinHandle<(bool, TaskMessage)> { in spawn_handler() argument
215 let _data_message = TaskMessage { in spawn_handler()
364 let task_message = TaskMessage { in transfer_task_finish()
373 let task_message = TaskMessage { in transfer_file_finish()
386 let echo_message = TaskMessage { in echo_client()
|
| D | hdcfile.rs | 30 use crate::config::TaskMessage;
244 let file_check_message = TaskMessage { in put_file_check()
284 let file_begin_message = TaskMessage { in put_file_begin()
339 let _finish_message = TaskMessage { in do_file_finish()
359 let task_finish_message = TaskMessage { in put_file_finish()
|
| D | jdwp.rs | 20 use crate::config::TaskMessage;
107 let data = TaskMessage { in send_process_list()
|
| D | forward.rs | 31 use crate::config::TaskMessage;
291 let file_check_message = TaskMessage { in check_command()
724 let echo_message = TaskMessage { in echo_client()
833 let file_check_message = TaskMessage { in send_to_task()
936 let wake_up_message = TaskMessage { in begin_forward()
|
| /developtools/hdc/hdc_rust/src/ |
| D | config.rs | 65 pub struct TaskMessage { struct
|