Struct ActiveSessionManager 

pub struct ActiveSessionManager {
    pub session_path: PathBuf,
    pub auto_save_interval: Duration,
    /* private fields */
}

活跃会话管理器 - 负责会话的加载、保存和自动保存

Fields

session_path: PathBuf

会话文件路径

auto_save_interval: Duration

自动保存间隔

Implementations

impl ActiveSessionManager

pub fn new(session_path: PathBuf, auto_save_interval: Duration) -> Self

创建新的活跃会话管理器

参数

• session_path: 会话文件保存路径
• auto_save_interval: 自动保存的时间间隔

示例

let manager = ActiveSessionManager::new(
    PathBuf::from("/tmp/session.txt"),
    Duration::from_secs(60),
);

pub async fn load_session(&self) -> Result<Vec<SessionEntry>, String>

从文件加载会话数据

如果文件不存在，返回空的 Vec（不视为错误）

返回值

• Ok(Vec<SessionEntry>): 成功加载的会话条目列表
• Err(String): 加载失败时的错误信息

pub async fn save_session( &self, groups: &[Arc<RwLock<RequestGroup>>], ) -> Result<usize, String>

保存所有下载组的状态到会话文件

使用原子写入策略：先写入临时文件 (.sess.tmp)，然后重命名为目标文件。 这确保在写入过程中如果发生崩溃，不会损坏原有的会话文件。

参数

• groups: 需要保存状态的下载组列表

返回值

• Ok(usize): 成功保存的条目数量
• Err(String): 保存失败时的错误信息

pub fn mark_dirty(&self)

标记会话为脏状态（有未保存的更改）

pub fn is_dirty(&self) -> bool

检查会话是否有未保存的更改

pub fn start_auto_save( self: &Arc<Self>, groups: Arc<RwLock<Vec<Arc<RwLock<RequestGroup>>>>>, )

启动自动保存后台任务

在后台循环中定期检查脏标记，如果有未保存的更改则自动保存。 该方法会在后台启动一个 Tokio 任务，不会阻塞当前线程。

参数

• self: 必须通过 Arc 包装，以便在后台任务中共享
• groups: 所有活动下载组的共享引用

注意事项

• 此方法会启动一个无限循环的后台任务
• 只有当 dirty flag 为 true 时才会执行保存操作
• 保存成功后会清除 dirty flag