Lines Matching refs:FileTaskMap
65 pub struct FileTaskMap {} struct
66 impl FileTaskMap { impl
137 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_local_path()
210 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in begin_transfer()
237 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in set_master_parameters()
337 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in put_file_check()
350 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_slaver()
412 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in transfer_next()
436 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in on_all_transfer_finish()
500 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in is_task_queue_empty()
535 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in put_file_finish()
586 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in command_dispatch()
596 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in command_dispatch()
636 FileTaskMap::stop_task(session_id).await; in stop_task()
640 FileTaskMap::dump_task().await in dump_task()
644 let message = match FileTaskMap::get(session_id, channel_id).await { in echo_fail()