fluvio_protocol/core/
zerocopy.rs

1#[cfg(test)]
2mod test {
3
4    use std::slice::from_raw_parts;
5    use std::mem::size_of;
6
7    //use super::BigU32;
8
9    #[repr(C)]
10    struct Buffer {
11        i1: u16,
12        i2: u16,
13    }
14
15    // doing basic test of big integration conversion and so forth
16    #[test]
17    fn test_zero_copy() {
18        let b = Buffer {
19            i1: (10u16).to_be(),
20            i2: 11,
21        };
22
23        let p: *const Buffer = &b;
24        let p: *const u8 = p as *const u8;
25        let bytes = unsafe { from_raw_parts(p, size_of::<Buffer>()) };
26
27        println!("{:X}{:X}{:X}{:X}", bytes[0], bytes[1], bytes[2], bytes[3]);
28
29        // should print out as 0AB0
30
31        let z: *const Buffer = p as *const Buffer;
32        let k: &Buffer = unsafe { &*z };
33        assert_eq!(k.i2, 11);
34        assert_eq!(k.i1.to_be(), 10);
35    }
36}
fluvio_protocol/core/zerocopy.rs

fluvio_protocol/core/
zerocopy.rs
