Function commits

crates/commitlog/src/segment.rs:857–892

()

    #[test]
    fn commits() {
        let repo = repo::Memory::unlimited();
        let commits = vec![
            vec![(0, [1; 32]), (1, [2; 32])],
            vec![(2, [3; 32])],
            vec![(3, [4; 32]), (4, [5; 32])],
        ];

        let mut writer = repo::create_segment_writer(&repo, <_>::default(), Commit::DEFAULT_EPOCH, 0).unwrap();

        for commit in &commits {
            writer.commit(commit.clone()).unwrap();
        }

        writer.flush().unwrap();

        let reader = repo::open_segment_reader(&repo, DEFAULT_LOG_FORMAT_VERSION, 0).unwrap();
        let mut commits1 = Vec::with_capacity(commits.len());
        let mut min_tx_offset = 0;
        for txs in commits {
            let n = txs.len();
            commits1.push(Commit {
                min_tx_offset,
                n: n as u16,
                records: itertools::concat(txs.into_iter().map(|(_, payload)| payload.to_vec())),
                epoch: 0,
            });
            min_tx_offset += n as u64;
        }
        let commits2 = reader
            .commits()
            .map_ok(Into::into)
            .collect::<Result<Vec<Commit>, _>>()
            .unwrap();
        assert_eq!(commits1, commits2);
    }

    #[test]
    fn transactions() {