rtps 0.2.3

OMG RTPS 2.2
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

use rtps::cdr::{CdrSerializer};
use rtps::common_types as t;
use rtps::message::*;
use rtps::submessage::*;
use serde::ser::Serialize;

#[test]
fn test_message_serialize() {
    let submessage = Submessage {
        variant: SubmessageVariant::Data {
            reader_id: t::EntityId{ entity_key: [0,0,0], entity_kind: t::EntityKind::BuiltInReader },
            writer_id: t::EntityId{ entity_key: [0,0,0], entity_kind: t::EntityKind::BuiltInWriter },
            writer_sn: 5,
            serialized_payload: t::ArcBuffer::from_vec(vec![1,2,3,4])
        }
    };
    let message = Message::new(vec![submessage]);

    let buf : Vec<u8> = vec![];
    let mut serializer = CdrSerializer{
        endianness: t::Endianness::Big,
        write_handle: buf
    };
    message.serialize(&mut serializer).unwrap();
    let expected = vec![
            82, 84, 80, 83, // RTPS
            20, 10, // Protocol Type
            86, 19, // Vendor id
            0, 0, 0, 1, // Submessage count
            21, 0, // submessage id byte (data = 21), flags byte (null), first two bytes len u32
            0, 0, 0, 255, // second two bytes len u32
            0, 0, 0, 196, // reader entity id (builtin = 0xc4 = 196)
            0, 0, 0, 195, // writer entity id (builtin = 0xc3 = 195)
            0, 0, 0, 0, 0, 0, 0, 5, // writer sn 64 bit number
            0, 0, 0, 4,
            1, 2, 3, 4
        ];
    assert_eq!(serializer.write_handle, expected);
//    [82, 84, 80, 83, 20, 10, 86, 19, 0, 0, 0, 1, 21, 0, 0, 0, 0, 255, 0, 0, 0, 196, 0, 0, 0, 195, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 4, 1, 2, 3, 4]
//    [82, 84, 80, 83, 20, 10, 86, 19, 0, 0, 0, 1, 21, 0, 0, 0, 0, 255, 0, 0, 196, 0, 0, 0, 3, 0, 0, 0, 195, 0, 0, 0, 0, 0, 0, 0, 5, 0, 0, 0, 4, 1, 2, 3, 4]
}