Function update_operation_stats_test

src/rocksdb/tests/basic.rs:264–309

unsupported operation: can't call foreign function `rocksdb_create_default_env` on OS `linux`

()

#[mz_ore::test(tokio::test)]
#[cfg_attr(miri, ignore)] // unsupported operation: can't call foreign function `rocksdb_create_default_env` on OS `linux`
async fn update_operation_stats_test() -> Result<(), anyhow::Error> {
    // If the test aborts, this may not be cleaned up.
    let t = tempfile::tempdir()?;

    let mut instance = RocksDBInstance::<String, String>::new(
        t.path().join("5").as_path(),
        InstanceOptions::<bincode::DefaultOptions, String, StubMergeOperator<String>>::new(
            rocksdb::Env::new()?,
            2,
            None,
            bincode::DefaultOptions::new(),
        ),
        RocksDBConfig::new(Default::default(), None),
        shared_metrics_for_tests()?,
        instance_metrics_for_tests()?,
    )?;

    let stats = instance
        .multi_update(vec![
            (
                "two".to_string(),
                KeyUpdate::Put("twov1".to_string()),
                Some(Diff::ONE),
            ),
            (
                "two".to_string(),
                KeyUpdate::Put("twov1".to_string()),
                Some(Diff::MINUS_ONE),
            ),
            (
                "two".to_string(),
                KeyUpdate::Put("twov2".to_string()),
                Some(Diff::ONE),
            ),
        ])
        .await?;
    assert_eq!(stats.processed_updates, 3);
    assert_eq!(
        Diff::try_from(stats.size_written).unwrap(),
        Diff::from(3) * stats.size_diff.unwrap()
    );

    instance.close().await?;

    Ok(())
}

#[mz_ore::test(tokio::test)]
#[cfg_attr(miri, ignore)] // unsupported operation: can't call foreign function `rocksdb_create_default_env` on OS `linux`