Lines Matching defs:task
106 hdc::error!("Get host app task failed");
109 let mut task = arc_task.lock().await;
110 let msg = str[task.printed_msg_len..].to_owned();
111 let local_path = if !task.transfer.local_tar_raw_path.is_empty() {
112 &task.transfer.local_tar_raw_path
114 &task.transfer.local_path
117 format!("{} path:{}, queuesize:{}, msg:{}", mode_desc, local_path, task.transfer.task_queue.len(), msg);
119 task.printed_msg_len = str.len();
121 if task.transfer.task_queue.is_empty() {
127 drop(task);
181 hdc::error!("Get host app task failed");
184 let task = arc_task.lock().await;
189 payload: task.transfer.transfer_config.serialize(),
196 hdc::error!("Get host app task failed");
199 let mut task = arc_task.lock().await;
200 match task.transfer.task_queue.pop() {
204 task.transfer.local_path = loc_path;
205 task.transfer.local_tar_raw_path = String::new();
210 task.transfer.local_path = tar_file;
211 task.transfer.local_tar_raw_path = loc_path;
227 let local_path = task.transfer.local_path.clone();
232 task.transfer.transfer_config.file_size = file_size;
233 task.transfer.file_size = file_size;
234 task.transfer.transfer_config.optional_name = utils::get_pseudo_random_u32().to_string();
237 task.transfer
242 task.transfer.transfer_config.path = task.transfer.remote_path.clone();
258 hdc::error!("Get host app task failed");
261 let mut task = arc_task.lock().await;
267 task.transfer.transfer_config.client_cwd = argv[i + 1].clone();
278 &task.transfer.transfer_config.client_cwd,
282 task.transfer.task_queue.push(path);
286 task.transfer.task_queue.push(path);
293 if task.transfer.task_queue.is_empty() {
297 task.transfer.transfer_config.options = options.clone();
298 task.transfer.transfer_config.function_name = TRANSFER_FUNC_NAME.to_string();
299 task.transfer.is_master = true;
300 drop(task);
363 hdc::error!("Get host app task failed");
370 let task = arc_task.lock().await;
372 hdctransfer::transfer_begin(&task.transfer, HdcCommand::AppData).await;