71         let task = map.get(&(session_id, channel_id));  in exsit()  localVariable
72         task.is_some()  in exsit()
84         let Some(task) = map.get(&(session_id, channel_id)) else {  in get()
92         Some(task.clone())  in get()
103             let mut task = _iter.1.lock().await;  in stop_task()  localVariable
104             task.transfer.stop_run = true;  in stop_task()
113             let task = _iter.1.lock().await;  in dump_task()  localVariable
114             let command = task.transfer.command_str.clone();  in dump_task()
134     let mut task = arc.lock().await;  in do_app_check()  localVariable
139     task.transfer.transfer_config.options = transconfig.options.clone();  in do_app_check()
140     task.transfer.transfer_config.function_name = transconfig.function_name.clone();  in do_app_check()
143     task.transfer.command_str = format!(  in do_app_check()
147     task.transfer.is_master = false;  in do_app_check()
148     task.transfer.local_path = local_path;  in do_app_check()
149     task.transfer.file_size = transconfig.file_size;  in do_app_check()
150     task.transfer.index = 0;  in do_app_check()
154             return File::create(task.transfer.local_path.clone()).is_ok();  in do_app_check()
159         return File::create(task.transfer.local_path.clone()).is_ok();  in do_app_check()
191     let mut task = arc.lock().await;  in put_app_finish()  localVariable
192     task.result_msg.append(&mut result.to_vec());  in put_app_finish()
193     msg.append(&mut task.result_msg.clone());  in put_app_finish()
285     let task = arc.lock().await;  in do_app_install()  localVariable
286     let options = task.transfer.transfer_config.options.clone();  in do_app_install()
287     let local_path = task.transfer.local_path.clone();  in do_app_install()
288     drop(task);  in do_app_install()
330     let task = arc.lock().await;  in on_transfer_finish()  localVariable
331     let function_name = task.transfer.transfer_config.function_name.clone();  in on_transfer_finish()
332     drop(task);  in on_transfer_finish()
377             let mut task = arc.lock().await;  in command_dispatch()  localVariable
378             if task.transfer.stop_run {  in command_dispatch()
379                 hdc::error!("stop_run {}", task.transfer.stop_run);  in command_dispatch()
382             if hdctransfer::transfer_data(&mut task.transfer, _payload) {  in command_dispatch()
383                 drop(task);  in command_dispatch()