| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| D | daemon_unity.rs | 36 async fn echo_client(session_id: u32, channel_id: u32, message: &str, level: MessageLevel) { in echo_client() 40 async fn echo_device_mode_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_device_mode_result() 56 async fn echo_reboot_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_reboot_result() 72 async fn echo_root_run_mode_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_root_run_mode_result() 83 async fn set_root_run_enable(session_id: u32, channel_id: u32, root: bool) { in set_root_run_enable() 102 async fn set_root_run(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_root_run() 126 async fn reboot_device(session_id: u32, channel_id: u32, _payload: &[u8]) { in reboot_device() 146 async fn remount_device(session_id: u32, channel_id: u32) { in remount_device() 169 async fn set_device_mode(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_device_mode() 208 async fn do_jdwp_list(session_id: u32, channel_id: u32) { in do_jdwp_list() [all …]
|
| D | daemon_app.rs | 44 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 64 pub async fn put(session_id: u32, channel_id: u32, value: DaemonAppTask) { in put() 70 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() 77 pub async fn remove(session_id: u32, channel_id: u32) -> Option<DaemonAppTask_> { in remove() 83 pub async fn get(session_id: u32, channel_id: u32) -> Option<DaemonAppTask_> { in get() 97 async fn stop_task(session_id: u32) { in stop_task() 145 async fn do_app_check(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in do_app_check() 184 async fn put_file_begin(session_id: u32, channel_id: u32) { in put_file_begin() 194 session_id: u32, in put_app_finish() 195 channel_id: u32, in put_app_finish() [all …]
|
| D | auth.rs | 76 async fn put(session_id: u32, auth_status: AuthStatus) { in put() 87 pub async fn remove(session_id: u32) { in remove() 98 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() 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() 207 async fn create_basic_channel(session_id: u32, channel_id: u32, host_ver: &str) { in create_basic_channel() 228 async fn make_emg_message(session_id: u32, channel_id: u32, emgmsg: &str) -> TaskMessage { in make_emg_message() 252 session_id: u32, in make_reject_message() 253 channel_id: u32, in make_reject_message() 281 async fn send_reject_message(session_id: u32, channel_id: u32, host_ver: &str) { in send_reject_message() [all …]
|
| D | shell.rs | 63 async fn shell_channel_close(channel_id: u32, session_id: u32){ in shell_channel_close() 72 pub async fn stop_task(session_id: u32) { in stop_task() 167 session_id: u32, in subprocess_task() 168 channel_id: u32, in subprocess_task() 315 session_id: u32, in new() 316 channel_id: u32, in new() 363 pub async fn get(session_id: u32, channel_id: u32) -> Option<Child_> { in get() 373 pub async fn put(session_id: u32, channel_id: u32, pty_child: Child_) { in put() 379 pub async fn del(session_id: u32, channel_id: u32) { in del() 398 pub async fn get(session_id: u32, channel_id: u32) -> Option<Arc<PtyTask>> { in get() [all …]
|
| D | task_manager.rs | 42 pub async fn free_session(session_id: u32) { in free_session() 67 pub async fn stop_task(session_id: u32) { in stop_task()
|
| D | bridge.rs | 115 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head() argument 149 pub async fn put(session_id: u32, data: TaskMessage) { in put() 160 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message() 183 pub async fn start(id: u32, wr: BridgeWriter) { in start() 191 pub async fn end(id: u32) { in end()
|
| D | task.rs | 90 async fn remove_task(session_id: u32, channel_id: u32) { in remove_task()
|
| D | mod.rs | 237 package_index: u32, in uart_handshake() 238 ) -> io::Result<u32> { in uart_handshake()
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | hdcfile.rs | 56 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 75 pub async fn put(session_id: u32, channel_id: u32, value: HdcFile) { in put() 81 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() 88 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HdcFile_> { in remove() 94 pub async fn get(session_id: u32, channel_id: u32) -> Option<HdcFile_> { in get() 101 async fn stop_task(session_id: u32) { in stop_task() 136 async fn check_local_path(session_id: u32, channel_id: u32) -> bool { in check_local_path() 180 async fn echo_finish(session_id: u32, channel_id: u32, msg: String) { in echo_finish() 191 pub async fn begin_transfer(session_id: u32, channel_id: u32, command: &String) -> bool { in begin_transfer() 231 session_id: u32, in set_master_parameters() [all …]
|
| D | forward.rs | 74 session_id: u32, in new() 75 channel_id: u32, in new() 205 async fn put(id: u32, wr: SplitWriteHalf) { in put() 212 async fn write(id: u32, data: Vec<u8>) -> bool { in write() 227 pub async fn end(id: u32) { in end() 250 async fn put(id: u32, listener: JoinHandle<()>) { in put() 258 pub async fn end(id: u32) { in end() 283 pub async fn update(cid: u32, value: ContextForward) { in update() 289 pub async fn remove(cid: u32) { in remove() 322 pub async fn update(session_id: u32, channel_id: u32, value: HdcForward) { in update() [all …]
|
| D | hdctransfer.rs | 91 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 277 _channel_id_: u32, in spawn_handler() 411 session_id: u32, in read_and_send_data() 412 _channel_id_: u32, in read_and_send_data() 538 async fn put_last_error(error: std::io::Error, session_id: u32, channel_id: u32) ->bool { in put_last_error() 614 pub async fn transfer_task_finish(channel_id: u32, _session_id: u32) { in transfer_task_finish() 623 pub async fn transfer_file_finish(channel_id: u32, _session_id: u32, comamnd_finish: HdcCommand) { in transfer_file_finish() 632 pub async fn close_channel(channel_id: u32) { in close_channel() 636 pub async fn echo_client(_session_id: u32, channel_id: u32, message: &str, level: MessageLevel) { in echo_client()
|
| D | jdwp.rs | 91 async fn put_socketpair(&self, target_pid: u32, fd: i32, fd2: i32) { in put_socketpair() 103 …pub async fn send_fd_to_target(&self, target_pid: u32, fd: i32, fd2: i32, parameter: &str) -> bool… in send_fd_to_target() 148 pub async fn add_tracker(&self, channel_id: u32, session_id: u32, display: DisplayType) { in add_tracker() 364 pub async fn stop_session_task(session_id: u32) { in stop_session_task() 370 pub async fn stop_task(session_id: u32, channel_id: u32) { in stop_task()
|
| D | taskbase.rs | 29 fn channel_id(&self) -> u32 { in channel_id()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | host_app.rs | 42 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 64 pub async fn put(session_id: u32, channel_id: u32, host_app_task: HostAppTask) { in put() 73 pub async fn exist(session_id: u32, channel_id: u32) -> Result<bool, ()> { in exist() 79 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HostAppTask_> { in remove() 85 pub async fn get(session_id: u32, channel_id: u32) -> Option<HostAppTask_> { in get() 96 session_id: u32, in check_install_continue() 97 channel_id: u32, in check_install_continue() 137 async fn do_app_uninstall(session_id: u32, channel_id: u32, payload: Vec<u8>) { in do_app_uninstall() 143 async fn do_app_finish(session_id: u32, channel_id: u32, payload: &[u8]) -> bool { in do_app_finish() 174 async fn task_finish(session_id: u32, channel_id: u32) { in task_finish() [all …]
|
| D | auth.rs | 37 connect_key: String, session_id: u32, channel_id: u32, conn_type: ConnectType, in start_handshake_with_daemon() 121 pub async fn handshake_task(msg: TaskMessage, session_id: u32, connect_key: String) -> io::Result<(… in handshake_task() 225 async fn send_handshake_to_daemon(handshake: &SessionHandShake, channel_id: u32) { in send_handshake_to_daemon()
|
| D | task.rs | 462 …dle_deamon(ptr: u64, mut rx: mpsc::BoundedReceiver<(TaskMessage, u32)>, session_id: u32, connect_k… in usb_handle_deamon() argument 576 session_id: u32, in tcp_handle_deamon() 600 async fn session_task_dispatch(task_message: TaskMessage, session_id: u32, connect_key: String) -> … in session_task_dispatch() 915 pub async fn get_session_id(connect_key: String) -> Option<u32> { in get_session_id() 934 async fn get_valid_session_id(connect_key: String, channel_id: u32) -> io::Result<u32> { in get_valid_session_id()
|
| D | tty_utility.rs | 71 fn get_unicode_len(input_char: i32) -> u32 { in get_unicode_len()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | uart_wrapper.rs | 76 async fn start_session(session_id: u32) { in start_session() 83 async fn wait_response(session_id: u32) { in wait_response() 92 async fn wakeup_response_wait(session_id: u32) { in wakeup_response_wait() 101 async fn wait_empty(session_id: u32) { in wait_empty() 110 async fn wakeup_empty_wait(session_id: u32) { in wakeup_empty_wait() 179 async fn get_package(session_id: u32, index: usize) -> Option<OutputData> { in get_package() 197 async fn put_package(session_id: u32, data: OutputData) { in put_package() 214 async fn update_package(session_id: u32, index: usize, data: OutputData) -> bool { in update_package() 246 async fn set_stop_flag(session_id: u32) { in set_stop_flag() 253 async fn remove_package(session_id: u32, index: usize) -> bool { in remove_package() [all …]
|
| D | buffer.rs | 61 pub async fn put(session_id: u32, conn_type: ConnectType) { in put() 74 pub async fn del(session_id: u32) { in del() 129 async fn put(session_id: u32, data: TaskMessage) { in put() 141 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message() 164 pub async fn start(id: u32, wr: SplitWriteHalf) { in start() 173 pub async fn end(id: u32) { in end() 207 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put() 255 pub async fn start(session_id: u32, wr: UsbWriter) { in start() 278 pub async fn end(session_id: u32) { in end() 317 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> { in put() [all …]
|
| D | base.rs | 66 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head() argument 76 pack_size: u32, in unpack_task_message_lock() 171 tx: BoundedSender<(TaskMessage, u32, u32)>, in unpack_task_message() argument
|
| D | uart.rs | 123 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head() argument 174 pub fn build_header(session_id: u32, option: u16, length: usize, package_index: u32) -> Vec<u8> { in build_header() 188 session_id: u32, in build_header_obj() 191 package_index: u32, in build_header_obj()
|
| D | usb.rs | 161 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head() argument 216 pub fn build_header(session_id: u32, option: u8, length: usize) -> Vec<u8> { in build_header()
|
| /developtools/hdc/hdc_rust/src/host_transfer/ |
| D | host_usb.rs | 162 fn check_protocol_head(&mut self) -> io::Result<(u32, u32, u32)> { in check_protocol_head() argument 195 pub fn build_header(session_id: u32, option: u8, length: usize) -> Vec<u8> { in build_header() 213 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message() argument 267 _session_id: u32, in start_recv() 268 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in start_recv() argument 285 _session_id: u32, in start_recv_once() 286 ) -> mpsc::BoundedReceiver<(TaskMessage, u32)> { in start_recv_once() argument 312 pub async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put() 330 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message() 347 pub async fn start(session_id: u32, wr: HostUsbWriter) { in start() [all …]
|
| /developtools/hdc/hdc_rust/src/tar/ |
| D | header.rs | 169 fn convert_octal_string_to_u32(data: &[u8]) -> u32 { in convert_octal_string_to_u32() 184 fn convert_u32_to_octal_string(dst: &mut [u8], len: usize, data: u32) { in convert_u32_to_octal_string() 232 fn mode(&self) -> u32 { in mode()
|
| /developtools/profiler/proto_encoder/test/unittest/ |
| D | varint_encode_unittest.cpp | 279 uint32_t u32 = std::numeric_limits<uint32_t>::min(); variable
|