Function batch_deferred_writes_and_flush

nodedb-wal/src/double_write.rs:553–586

()

    #[test]
    fn batch_deferred_writes_and_flush() {
        let dir = tempfile::tempdir().unwrap();
        let dwb_path = dir.path().join("batch.dwb");

        let mut dwb = open_buffered(&dwb_path);

        for lsn in 1..=5u64 {
            let record = WalRecord::new(
                RecordType::Put as u32,
                lsn,
                1,
                0,
                0,
                format!("batch-{lsn}").into_bytes(),
                None,
                None,
            )
            .unwrap();
            dwb.write_record_deferred(&record).unwrap();
        }

        assert!(dwb.dirty);
        dwb.flush().unwrap();
        assert!(!dwb.dirty);

        for lsn in 1..=5u64 {
            let recovered = dwb.recover_record(lsn).unwrap();
            assert!(recovered.is_some(), "LSN {lsn} should be recoverable");
            assert_eq!(
                recovered.unwrap().payload,
                format!("batch-{lsn}").into_bytes()
            );
        }
    }

    #[test]
    fn flush_is_idempotent() {