Method open

crates/commitlog/src/commitlog.rs:57–93

(repo: R, opts: Options)

impl<R: Repo, T> Generic<R, T> {
    pub fn open(repo: R, opts: Options) -> io::Result<Self> {
        let mut tail = repo.existing_offsets()?;
        if !tail.is_empty() {
            debug!("segments: {tail:?}");
        }

        // Resume the last segment for writing, or
        // create a new segment starting from the last good commit + 1.
        let head = loop {
            if let Some(last) = tail.pop() {
                info!("repo {}: resuming last segment: {}", repo, last);
                match repo::resume_segment_writer(&repo, opts, last)? {
                    repo::ResumedSegment::Empty => {
                        repo.remove_segment(last)?;
                        continue;
                    }
                    repo::ResumedSegment::Resumed(writer) => break writer,
                    repo::ResumedSegment::Sealed(meta) | repo::ResumedSegment::Corrupted(meta) => {
                        tail.push(meta.tx_range.start);
                        break repo::create_segment_writer(&repo, opts, meta.max_epoch, meta.tx_range.end)?;
                    }
                }
            } else {
                info!("repo {}: starting fresh log", repo);
                break repo::create_segment_writer(&repo, opts, Commit::DEFAULT_EPOCH, 0)?;
            }
        };

        Ok(Self {
            repo,
            head,
            tail,
            opts,
            _record: PhantomData,
            panicked: false,
        })
    }

    /// Get the current epoch.
    ///