Method try_turn_end_lock

atomic-agent/src/turn/orchestrator/turn.rs:436–479

(&self, session_id: &str)

    }

    fn try_turn_end_lock(&self, session_id: &str) -> TurnEndLock {
        use fs2::FileExt;

        let dir = self.session_graph_dir(session_id);
        if let Err(e) = std::fs::create_dir_all(&dir) {
            log::warn!(
                "Failed to create turn-end lock dir for session {}: {}",
                session_id,
                e
            );
            return TurnEndLock::Unavailable;
        }

        let lock_path = dir.join(TURN_END_LOCK_FILENAME);
        let file = match std::fs::OpenOptions::new()
            .create(true)
            .write(true)
            .truncate(false)
            .open(&lock_path)
        {
            Ok(file) => file,
            Err(e) => {
                log::warn!(
                    "Failed to open turn-end lock for session {}: {}",
                    session_id,
                    e
                );
                return TurnEndLock::Unavailable;
            }
        };

        match file.try_lock_exclusive() {
            Ok(()) => TurnEndLock::Acquired(TurnEndLockGuard { file }),
            Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => TurnEndLock::Busy,
            Err(e) => {
                log::warn!(
                    "Failed to acquire turn-end lock for session {}: {}",
                    session_id,
                    e
                );
                TurnEndLock::Unavailable
            }
        }
    }
}