Lines Matching refs:ForwardTaskMap
312 pub struct ForwardTaskMap {} struct
313 impl ForwardTaskMap { implementation
427 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in free_channel_task()
464 ForwardTaskMap::remove(session_id, channel_id).await; in free_channel_task()
468 ForwardTaskMap::clear(session_id).await; in stop_task()
472 ForwardTaskMap::dump_task().await in dump_task()
1305 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in begin_forward()
1320 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in begin_forward()
1325 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in begin_forward()
1493 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in forward_command_dispatch()
1530 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in print_error_info()