Lines Matching defs:task
73 let task = map.get(&(session_id, channel_id));
74 task.is_some()
86 let Some(task) = map.get(&(session_id, channel_id)) else {
94 Some(task.clone())
105 let mut task = _iter.1.lock().await;
106 task.transfer.stop_run = true;
115 let task = _iter.1.lock().await;
116 let command = task.transfer.command_str.clone();
154 let mut task = arc.lock().await;
159 task.transfer.transfer_config.options = transconfig.options.clone();
160 task.transfer.transfer_config.function_name = transconfig.function_name.clone();
163 task.transfer.command_str = format!(
167 task.transfer.is_master = false;
168 task.transfer.local_path = local_path;
169 task.transfer.file_size = transconfig.file_size;
170 task.transfer.index = 0;
174 return File::create(task.transfer.local_path.clone()).is_ok();
179 return File::create(task.transfer.local_path.clone()).is_ok();
211 let mut task = arc.lock().await;
212 task.result_msg.append(&mut result.to_vec());
213 msg.append(&mut task.result_msg.clone());
305 let task = arc.lock().await;
306 let options = task.transfer.transfer_config.options.clone();
307 let mut local_path = task.transfer.local_path.clone();
308 drop(task);
361 let task = arc.lock().await;
362 let function_name = task.transfer.transfer_config.function_name.clone();
363 drop(task);
408 let mut task = arc.lock().await;
409 if task.transfer.stop_run {
410 crate::error!("stop_run {}", task.transfer.stop_run);
413 if hdctransfer::transfer_data(&mut task.transfer, _payload) {
414 drop(task);