txmap 1.1.0

A concurrent transactional hash map for Rust with fine-grained locking, internal mutability and composable transactions
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

#[cfg(test)]
mod tests {
    use crate::{new_types::ShardIndex, prelude::*};

    #[test]
    fn shard_indexes() {
        assert_eq!(u8::from(ShardCount::_8), 8);
        assert_eq!(u8::from(ShardCount::_16), 16);
        assert_eq!(u8::from(ShardCount::_32), 32);
        assert_eq!(u8::from(ShardCount::_64), 64);
        assert_eq!(u8::from(ShardCount::_128), 128);
    }

    #[test]
    fn bitmasks() {
        assert_eq!(ShardIndex(u8::from(ShardCount::_8) - 1).bitmask().0, 1 << 7);
        assert_eq!(
            ShardIndex(u8::from(ShardCount::_16) - 1).bitmask().0,
            1 << 15
        );
        assert_eq!(
            ShardIndex(u8::from(ShardCount::_32) - 1).bitmask().0,
            1 << 31
        );
        assert_eq!(
            ShardIndex(u8::from(ShardCount::_64) - 1).bitmask().0,
            1 << 63
        );
        assert_eq!(
            ShardIndex(u8::from(ShardCount::_128) - 1).bitmask().0,
            1 << 127
        );
    }

    #[test]
    fn sanity_check() {
        for sc in [
            ShardCount::_8,
            ShardCount::_16,
            ShardCount::_32,
            ShardCount::_64,
            ShardCount::_128,
        ] {
            let map: TxMap<u64, u64> = TxMap::new(sc);
            assert!(map.is_empty());
            map.insert(1, 10);
            assert_eq!(map.len(), 1);
            assert_eq!(map.get_with(&1, |v| *v), Some(10));
        }
    }
}