Method start_new_segment

crates/commitlog/src/commitlog.rs:251–263

Start a new segment, preserving the current head's `Commit`. The caller must ensure that the current head is synced to disk as appropriate. It is not appropriate to sync after a write error, as that is likely to return an error as well: the `Commit` will be written to the new segment anyway.

(&mut self)

    /// is likely to return an error as well: the `Commit` will be written to
    /// the new segment anyway.
    fn start_new_segment(&mut self) -> io::Result<&mut Writer<R::SegmentWriter>> {
        debug!(
            "starting new segment offset={} prev-offset={}",
            self.head.next_tx_offset(),
            self.head.min_tx_offset()
        );
        let new = repo::create_segment_writer(&self.repo, self.opts, self.head.epoch(), self.head.next_tx_offset())?;
        let old = mem::replace(&mut self.head, new);
        self.tail.push(old.min_tx_offset());
        self.head.commit = old.commit;

        Ok(&mut self.head)
    }
}

impl<R: Repo, T: Encode> Generic<R, T> {