/developtools/hdc/hdc_rust/src/daemon/ |
D | daemon_unity.rs | 35 async fn echo_client(session_id: u32, channel_id: u32, message: &str, level: MessageLevel) { in echo_client() 39 async fn echo_device_mode_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_device_mode_result() 55 async fn echo_reboot_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_reboot_result() 71 async fn echo_root_run_mode_result(session_id: u32, channel_id: u32, result: bool, message: &str) { in echo_root_run_mode_result() 82 async fn set_root_run_enable(session_id: u32, channel_id: u32, root: bool) { in set_root_run_enable() 100 async fn set_root_run(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_root_run() 124 async fn reboot_device(session_id: u32, channel_id: u32, _payload: &[u8]) { in reboot_device() 145 async fn remount_device(session_id: u32, channel_id: u32) { in remount_device() 168 async fn set_device_mode(session_id: u32, channel_id: u32, _payload: &[u8]) { in set_device_mode() 205 async fn do_jdwp_list(session_id: u32, channel_id: u32) { in do_jdwp_list() [all …]
|
D | daemon_app.rs | 42 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 62 pub async fn put(session_id: u32, channel_id: u32, value: DaemonAppTask) { in put() 68 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() 75 pub async fn remove(session_id: u32, channel_id: u32) -> Option<DaemonAppTask_> { in remove() 81 pub async fn get(session_id: u32, channel_id: u32) -> Option<DaemonAppTask_> { in get() 95 async fn stop_task(session_id: u32) { in stop_task() 125 async fn do_app_check(session_id: u32, channel_id: u32, _payload: &[u8]) -> bool { in do_app_check() 164 async fn put_file_begin(session_id: u32, channel_id: u32) { in put_file_begin() 174 session_id: u32, in put_app_finish() 175 channel_id: u32, in put_app_finish() [all …]
|
D | auth.rs | 76 async fn put(session_id: u32, auth_status: AuthStatus) { in put() 88 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> { in handshake_init() 154 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage { in make_sign_message() 170 async fn make_bypass_message(session_id: u32, channel_id: u32, host_ver: &str) -> TaskMessage { in make_bypass_message() 194 async fn create_basic_channel(session_id: u32, channel_id: u32, host_ver: &str) { in create_basic_channel() 216 async fn make_emg_message(session_id: u32, channel_id: u32, emgmsg: &str) -> TaskMessage { in make_emg_message() 239 session_id: u32, in make_reject_message() 240 channel_id: u32, in make_reject_message() 268 async fn send_reject_message(session_id: u32, channel_id: u32, host_ver: &str) { in send_reject_message() 280 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage { in make_ok_message() [all …]
|
D | shell.rs | 137 session_id: u32, in subprocess_task() 138 channel_id: u32, in subprocess_task() 305 session_id: u32, in new() 306 channel_id: u32, in new() 353 pub async fn get(session_id: u32, channel_id: u32) -> Option<Child_> { in get() 363 pub async fn put(session_id: u32, channel_id: u32, pty_child: Child_) { in put() 369 pub async fn del(session_id: u32, channel_id: u32) { in del() 388 pub async fn get(session_id: u32, channel_id: u32) -> Option<Arc<PtyTask>> { in get() 397 pub async fn put(session_id: u32, channel_id: u32, pty_task: PtyTask) { in put() 404 pub async fn del(session_id: u32, channel_id: u32) { in del() [all …]
|
D | task_manager.rs | 29 pub async fn free_session(connect_type: ConnectType, session_id: u32) { in free_session() 49 pub async fn stop_task(session_id: u32) { in stop_task()
|
D | task.rs | 89 async fn remove_task(session_id: u32, channel_id: u32) { in remove_task()
|
D | main.rs | 231 package_index: u32, in uart_handshake() 232 ) -> io::Result<u32> { in uart_handshake()
|
/developtools/hdc/hdc_rust/src/common/ |
D | hdcfile.rs | 54 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 73 pub async fn put(session_id: u32, channel_id: u32, value: HdcFile) { in put() 79 pub async fn exsit(session_id: u32, channel_id: u32) -> bool { in exsit() 86 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HdcFile_> { in remove() 92 pub async fn get(session_id: u32, channel_id: u32) -> Option<HdcFile_> { in get() 99 async fn stop_task(session_id: u32) { in stop_task() 135 async fn check_local_path(session_id: u32, channel_id: u32) -> bool { in check_local_path() 179 async fn echo_finish(session_id: u32, channel_id: u32, msg: String) { in echo_finish() 190 pub async fn begin_transfer(session_id: u32, channel_id: u32, command: &String) -> bool { in begin_transfer() 223 session_id: u32, in set_master_parameters() [all …]
|
D | forward.rs | 74 session_id: u32, in new() 75 channel_id: u32, in new() 175 async fn put(id: u32, rd: SplitReadHalf) { in put() 182 async fn read(session_id: u32, channel_id: u32, cid: u32) { in read() 233 async fn put(id: u32, wr: SplitWriteHalf) { in put() 240 async fn write(id: u32, data: Vec<u8>) { in write() 251 pub async fn end(id: u32) { in end() 274 async fn put(id: u32, listener: JoinHandle<()>) { in put() 282 pub async fn end(id: u32) { in end() 328 pub async fn update(session_id: u32, channel_id: u32, value: HdcForward) { in update() [all …]
|
D | hdctransfer.rs | 89 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 200 _channel_id_: u32, in spawn_handler() 320 session_id: u32, in read_and_send_data() 321 _channel_id_: u32, in read_and_send_data() 488 pub async fn transfer_task_finish(channel_id: u32, _session_id: u32) { in transfer_task_finish() 497 pub async fn transfer_file_finish(channel_id: u32, _session_id: u32, comamnd_finish: HdcCommand) { in transfer_file_finish() 506 pub async fn close_channel(channel_id: u32) { in close_channel() 510 pub async fn echo_client(session_id: u32, channel_id: u32, payload: Vec<u8>, level: MessageLevel) { in echo_client()
|
D | taskbase.rs | 29 fn channel_id(&self) -> u32 { in channel_id()
|
D | jdwp.rs | 77 pub async fn send_fd_to_target(&self, target_pid: u32, fd: i32, parameter: &str) -> bool { in send_fd_to_target() 119 pub async fn add_tracker(&self, channel_id: u32, session_id: u32, debug_or_release: bool) { in add_tracker()
|
D | uds.rs | 45 pub fn new(fd: i32, ppid: u32, pkg_name: String, debug_or_release: bool) -> Self { in new() 185 pub fn wrap_poll(fds: &mut [PollNode], size: u32, timeout: i32) -> i32 { in wrap_poll()
|
/developtools/hdc/hdc_rust/src/host/ |
D | host_app.rs | 41 pub fn new(_session_id: u32, _channel_id: u32) -> Self { in new() 63 pub async fn put(session_id: u32, channel_id: u32, host_app_task: HostAppTask) { in put() 72 pub async fn exist(session_id: u32, channel_id: u32) -> Result<bool, ()> { in exist() 78 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HostAppTask_> { in remove() 84 pub async fn get(session_id: u32, channel_id: u32) -> HostAppTask_ { in get() 92 pub async fn send_to_client(channel_id: u32, level: EchoLevel, message: String) -> io::Result<()> { in send_to_client() 96 pub async fn echo_client(channel_id: u32, message: String) -> io::Result<()> { in echo_client() 101 session_id: u32, in check_install_continue() 102 channel_id: u32, in check_install_continue() 135 async fn do_app_uninstall(session_id: u32, channel_id: u32, _payload: &[u8]) { in do_app_uninstall() [all …]
|
D | auth.rs | 40 session_id: u32, in usb_handshake_with_daemon() 41 channel_id: u32, in usb_handshake_with_daemon() 100 session_id: u32, in handshake_with_daemon() 101 channel_id: u32, in handshake_with_daemon() 212 async fn send_handshake_to_daemon(handshake: &SessionHandShake, channel_id: u32) { in send_handshake_to_daemon()
|
D | task.rs | 460 pub async fn usb_handle_deamon(ptr: u64, session_id: u32, connect_key: String) -> io::Result<()> { in usb_handle_deamon() 625 session_id: u32, in tcp_handle_deamon() 929 pub async fn get_session_id(connect_key: String) -> Option<u32> { in get_session_id() 948 async fn get_valid_session_id(connect_key: String, channel_id: u32) -> io::Result<u32> { in get_valid_session_id()
|
D | server.rs | 291 ) -> io::Result<(String, u32)> { in handshake_with_client() argument
|
/developtools/hdc/hdc_rust/src/transfer/ |
D | uart_wrapper.rs | 75 async fn start_session(session_id: u32) { in start_session() 82 async fn wait_response(session_id: u32) { in wait_response() 91 async fn wakeup_response_wait(session_id: u32) { in wakeup_response_wait() 100 async fn wait_empty(session_id: u32) { in wait_empty() 109 async fn wakeup_empty_wait(session_id: u32) { in wakeup_empty_wait() 178 async fn get_package(session_id: u32, index: usize) -> Option<OutputData> { in get_package() 196 async fn put_package(session_id: u32, data: OutputData) { in put_package() 213 async fn update_package(session_id: u32, index: usize, data: OutputData) -> bool { in update_package() 245 async fn set_stop_flag(session_id: u32) { in set_stop_flag() 252 async fn remove_package(session_id: u32, index: usize) -> bool { in remove_package() [all …]
|
D | buffer.rs | 56 pub async fn put(session_id: u32, conn_type: ConnectType) { in put() 68 pub async fn del(session_id: u32) { in del() 104 async fn put(session_id: u32, data: TaskMessage) { in put() 116 pub async fn send_channel_message(channel_id: u32, buf: Vec<u8>) -> io::Result<()> { in send_channel_message() 139 pub async fn start(id: u32, wr: SplitWriteHalf) { in start() 147 pub async fn end(id: u32) { in end() 173 async fn put(session_id: u32, data: TaskMessage) -> io::Result<()> { in put() 221 pub async fn start(session_id: u32, wr: UsbWriter) { in start() 230 pub async fn end(session_id: u32) { in end() 254 pub async fn put(session_id: u32, data: Vec<u8>) -> io::Result<()> { in put() [all …]
|
D | uart.rs | 122 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument 170 pub fn build_header(session_id: u32, option: u16, length: usize, package_index: u32) -> Vec<u8> { in build_header() 184 session_id: u32, in build_header_obj() 187 package_index: u32, in build_header_obj()
|
D | base.rs | 65 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument 73 pack_size: u32, in unpack_task_message_lock() 169 tx: BoundedSender<(TaskMessage, u32)>, in unpack_task_message() argument
|
D | usb.rs | 141 fn check_protocol_head(&mut self) -> io::Result<(u32, u32)> { in check_protocol_head() argument 182 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)> { 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() 348 pub async fn start(session_id: u32, wr: HostUsbWriter) { in start() [all …]
|
/developtools/hdc/hdc_rust/src/daemon_lib/ |
D | bridge.rs | 115 fn check_protocol_head(&mut self) -> io::Result<(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()
|
/developtools/profiler/proto_encoder/test/unittest/ |
D | varint_encode_unittest.cpp | 279 uint32_t u32 = std::numeric_limits<uint32_t>::min(); variable
|