rustdds 0.11.8

Native Rust DDS implementation with RTPS
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use speedy::{Readable, Writable};

#[derive(Debug, PartialEq, Eq, Copy, Clone, Readable, Writable)]
pub struct BuiltinEndpointSet {
  value: u32,
}

impl BuiltinEndpointSet {
  // Note: Names are abbreviated. The common prefix is dropped, because
  // the data type BuiltinEndpointSet provides an enclosing namespace.
  pub const PARTICIPANT_ANNOUNCER: u32 = 0x00000001;
  pub const PARTICIPANT_DETECTOR: u32 = 0x000000002;
  pub const PUBLICATIONS_ANNOUNCER: u32 = 0x00000004;
  pub const PUBLICATIONS_DETECTOR: u32 = 0x00000008;
  pub const SUBSCRIPTIONS_ANNOUNCER: u32 = 0x00000010;
  pub const SUBSCRIPTIONS_DETECTOR: u32 = 0x00000020;

  pub const PARTICIPANT_MESSAGE_DATA_WRITER: u32 = 0x00000400;
  pub const PARTICIPANT_MESSAGE_DATA_READER: u32 = 0x00000800;

  // DDS Security spec v1.1
  // Section 7.4.1.4 Extension to RTPS Standard DCPSParticipants Builtin Topic
  // Table 11
  pub const PUBLICATIONS_SECURE_WRITER: u32 = 1 << 16;
  pub const PUBLICATIONS_SECURE_READER: u32 = 1 << 17;

  pub const SUBSCRIPTIONS_SECURE_WRITER: u32 = 1 << 18;
  pub const SUBSCRIPTIONS_SECURE_READER: u32 = 1 << 19;

  pub const PARTICIPANT_MESSAGE_SECURE_WRITER: u32 = 1 << 20;
  pub const PARTICIPANT_MESSAGE_SECURE_READER: u32 = 1 << 21;

  pub const PARTICIPANT_STATELESS_MESSAGE_WRITER: u32 = 1 << 22;
  pub const PARTICIPANT_STATELESS_MESSAGE_READER: u32 = 1 << 23;

  pub const PARTICIPANT_VOLATILE_MESSAGE_SECURE_WRITER: u32 = 1 << 24;
  pub const PARTICIPANT_VOLATILE_MESSAGE_SECURE_READER: u32 = 1 << 25;

  pub const PARTICIPANT_SECURE_WRITER: u32 = 1 << 26;
  pub const PARTICIPANT_SECURE_READER: u32 = 1 << 27;

  // non-security again
  pub const TOPICS_ANNOUNCER: u32 = 0x08000000;
  pub const TOPICS_DETECTOR: u32 = 0x10000000;

  pub fn from_u32(val: u32) -> Self {
    Self { value: val }
  }

  pub fn contains(&self, other: u32) -> bool {
    (self.value & other) == other
  }
}

#[derive(Debug, PartialEq, Eq, Copy, Clone, Readable, Writable)]
pub struct BuiltinEndpointQos {
  value: u32,
}

impl BuiltinEndpointQos {
  pub const BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER: u32 = 0x00000001;

  pub fn is_best_effort(&self) -> bool {
    self.value == Self::BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER
  }
}