Lines Matching refs:task
150 let mut task = HostAppTask::new(session_id, task_info.channel_id); in channel_file_task() localVariable
151 task.transfer.server_or_daemon = true; in channel_file_task()
152 e.insert(Arc::new(Mutex::new(task))); in channel_file_task()
155 let mut task = HdcFile::new(session_id, task_info.channel_id); in channel_file_task() localVariable
156 task.transfer.server_or_daemon = true; in channel_file_task()
157 e.insert(Arc::new(Mutex::new(task))); in channel_file_task()
164 let task = session.map_tasks.get(&task_info.channel_id).unwrap(); in channel_file_task() localVariable
165 let task_ = &mut task.lock().await; in channel_file_task()
413 let mut task = HostAppTask::new(session_id, channel_id); in session_file_task() localVariable
414 task.transfer.server_or_daemon = true; in session_file_task()
415 e.insert(Arc::new(Mutex::new(task))); in session_file_task()
418 let mut task = HdcFile::new(session_id, channel_id); in session_file_task() localVariable
419 task.transfer.server_or_daemon = true; in session_file_task()
420 e.insert(Arc::new(Mutex::new(task))); in session_file_task()
427 let task = session.map_tasks.get(&channel_id).unwrap(); in session_file_task() localVariable
428 let task_ = &mut task.lock().await; in session_file_task()