Function test_read_serialize

block-buffer/tests/mod.rs:336–381

()

#[test]
fn test_read_serialize() {
    type Buf = ReadBuffer<U4>;

    let mut n = 0u8;
    let mut g = |block: &mut Array<u8, U4>| {
        block.iter_mut().for_each(|b| {
            *b = n;
            n += 1;
        });
    };

    let mut buf = Buf::default();
    let ser1 = buf.serialize();
    assert_eq!(&ser1[..], &[4, 0, 0, 0]);
    assert_eq!(Buf::deserialize(&ser1).unwrap().serialize(), ser1);

    let mut buf1 = Buf::deserialize(&ser1).unwrap();
    assert_eq!(buf1.serialize(), ser1);
    assert_eq!(buf1.remaining(), 0);
    assert_eq!(buf1.read_cached(10), []);

    buf.write_block(2, &mut g, |buf| assert_eq!(buf, [0, 1]));

    let ser2 = buf.serialize();
    assert_eq!(&ser2[..], &[2, 0, 2, 3]);

    let mut buf2 = Buf::deserialize(&ser2).unwrap();
    assert_eq!(buf2.serialize(), ser2);
    assert_eq!(buf2.remaining(), 2);
    assert_eq!(buf2.read_cached(10), [2, 3]);

    // Invalid position
    let buf = Array([0, 0, 0, 0]);
    assert!(Buf::deserialize(&buf).is_err());
    let buf = Array([5, 0, 0, 0]);
    assert!(Buf::deserialize(&buf).is_err());
    let buf = Array([10, 0, 0, 0]);
    assert!(Buf::deserialize(&buf).is_err());
    // "Garbage" bytes are not zeroized
    let buf = Array([2, 1, 0, 0]);
    assert!(Buf::deserialize(&buf).is_err());
    let buf = Array([3, 0, 1, 0]);
    assert!(Buf::deserialize(&buf).is_err());
    let buf = Array([4, 0, 0, 1]);
    assert!(Buf::deserialize(&buf).is_err());
}

#[test]
fn eager_buffer_exception_safety() {