| /developtools/hdc/hdc_rust/src/common/ |
| D | hdcfile.rs | 137 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_local_path() localVariable
210 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in begin_transfer() localVariable
237 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in set_master_parameters() localVariable
337 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in put_file_check() localVariable
350 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_slaver() localVariable
412 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in transfer_next() localVariable
419 let Some(local_path) = task.transfer.task_queue.pop() else { in transfer_next() localVariable
436 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in on_all_transfer_finish() localVariable
500 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in is_task_queue_empty() localVariable
535 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in put_file_finish() localVariable
[all …]
|
| D | base.rs | 209 let Some(tag) = tlv.get(cur_index..(cur_index + TLV_TAG_LEN)) else { in tlv_to_stringmap() localVariable
215 let Some(svlen) = tlv.get(cur_index..(cur_index + TLV_VAL_LEN)) else { in tlv_to_stringmap() localVariable
225 let Some(val) = tlv.get(cur_index..(cur_index + vlen)) else { in tlv_to_stringmap() localVariable
|
| D | forward.rs | 213 let Some(arc_wr) = map.get(&id) else { in write() localVariable
427 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in free_channel_task() localVariable
693 let Some(context_forward) = ForwardContextMap::get(cid).await else { in on_accept() localVariable
717 let Some(context_forward) = ForwardContextMap::get(cid).await else { in daemon_connect_tcp() localVariable
803 let Some(context_forward) = ForwardContextMap::get(cid).await else { in free_context() localVariable
1305 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in begin_forward() localVariable
1493 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in forward_command_dispatch() localVariable
1503 let Some(context_forward) = ForwardContextMap::get(cid).await else { in forward_command_dispatch() localVariable
1530 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in print_error_info() localVariable
|
| D | hdctransfer.rs | 433 let Some(handler) = queue.pop_front() else { in read_and_send_data() localVariable
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | host_app.rs | 89 let Some(arc_task) = map.get(&(session_id, channel_id)) else { in get() localVariable
115 let Some(arc_task) = HostAppTaskMap::get(session_id, channel_id).await else { in check_install_continue() localVariable
187 let Some(arc_task) = HostAppTaskMap::get(session_id, channel_id).await else { in put_app_check() localVariable
201 let Some(arc_task) = HostAppTaskMap::get(session_id, channel_id).await else { in install_single() localVariable
243 let Some(arc_task) = HostAppTaskMap::get(session_id, channel_id).await else { in init_install() localVariable
326 let Some(arc_task) = HostAppTaskMap::get(session_id, channel_id).await else { in command_dispatch() localVariable
|
| D | logger.rs | 136 let Some(file) = record.file() else { in log() localVariable
|
| D | client.rs | 93 let Some(command) = parsed_cmd.command else { in new() localVariable
|
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| D | daemon_app.rs | 86 let Some(task) = map.get(&(session_id, channel_id)) else { in get() localVariable
146 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in do_app_check() localVariable
203 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in put_app_finish() localVariable
297 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in do_app_install() localVariable
353 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in on_transfer_finish() localVariable
400 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in command_dispatch() localVariable
|
| D | mod.rs | 246 let Some(head) = rd.head.clone() else { in uart_handshake() localVariable
302 let Some(head) = rd.head.clone() else { in uart_handle_client() localVariable
|
| D | bridge.rs | 153 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | uart_wrapper.rs | 186 let Some(arc) = vec.get(index) else { in get_package() localVariable
221 let Some(arc) = vec.get(index) else { in update_package() localVariable
308 let Some(mut first_pkg) = first_pkg else { in session_loop() localVariable
340 let Some(mut first_pkg) = Self::get_package(session_id, 0).await else { in session_loop() localVariable
368 let Some(first_pkg) = Self::get_package(session_id, 0).await else { in session_loop() localVariable
379 let Some(first_pkg) = Self::get_package(session_id, 0).await else { in session_loop() localVariable
478 let Some(mut pkg) = QueueManager::get_package(session_id, 0).await else { in on_read_head() localVariable
|
| D | buffer.rs | 131 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
212 let Some(wr) = map.get(&session_id) else { in put() localVariable
310 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
419 let Some(arc_rd) = map.get(&0) else { in recv() localVariable
|