Fmt

.gitignore

@@ -8,4 +8,5 @@ src/.vscode/launch.json
 .vscode/*
 .idea/
 logging-config.yaml
-dev
+dev
+FastDDS_security_interoperability_test

src/dds/statusevents.rs

@@ -25,13 +25,12 @@ use crate::{
     qos::QosPolicyId,
     result::{ReadError, ReadResult},
   },
-  Duration, GUID, Topic, QosPolicies,
-  messages::{protocol_version::ProtocolVersion, vendor_id::VendorId,},
+  messages::{protocol_version::ProtocolVersion, vendor_id::VendorId},
   mio_source::*,
   read_error_poisoned,
   structure::guid::GuidPrefix,
+  Duration, QosPolicies, Topic, GUID,
 };
-
 #[cfg(feature = "security")]
 use crate::discovery::secure_discovery::AuthenticationStatus;
 
@@ -233,21 +232,20 @@ impl<'a, T> FusedStream for StatusReceiverStream<'a, T> {
 
 #[derive(Debug, Clone)]
 pub enum DomainParticipantStatusEvent {
-  ParticipantDiscovered { 
-    dpd: ParticipantDescription, 
+  ParticipantDiscovered {
+    dpd: ParticipantDescription,
   },
-  ParticipantLost{ 
-    id: GuidPrefix, 
+  ParticipantLost {
+    id: GuidPrefix,
     reason: LostReason,
   },
-  InconsistentTopic { 
+  InconsistentTopic {
     previous_specs: Topic, // What was our ide aof the Topic
-    discovered_as: Topic, // What incoming Discovery data tells us about Topic
-    discovery_from: GUID, // Who sent the Disocvery data
+    discovered_as: Topic,  // What incoming Discovery data tells us about Topic
+    discovery_from: GUID,  // Who sent the Discovery data
   },
   /// Discovery detects a new topic
-  TopicDetected {
-  },
+  TopicDetected {},
   /// New Reader detected (or created locally). Detection happens regardless of
   /// the remote being matched or not by a local Endpoint.
   ReaderDetected {
@@ -263,19 +261,20 @@ pub enum DomainParticipantStatusEvent {
   },
   WriterLost {
     guid: GUID,
-    reason: LostReason,    
+    reason: LostReason,
   },
 
   #[cfg(feature = "security")]
   Authentication {
     status: AuthenticationStatus,
   },
   /// The CA has revoked the identity of some Participant.
-  /// We may be currently communicating with the Participant, or it may be unknown to us.
+  /// We may be currently communicating with the Participant, or it may be
+  /// unknown to us.
   #[cfg(feature = "security")]
   IdentityRevoked {
     participant: GUID,
-  }, 
+  },
   /// Domain access permissions of some Participant have been revoked / changed.
   #[cfg(feature = "security")]
   PermissionsRevoked {
@@ -290,15 +289,15 @@ pub enum LostReason {
   /// Participant announced via Discovery that it is leaving
   Disposed,
   /// Lease time exceeded => timeout
-  Timout { 
-    lease: Duration,  // What was the discovered lease duration
+  Timeout {
+    lease: Duration,   // What was the discovered lease duration
     elapsed: Duration, // How much time has actually elapsed from last contact
-  }
+  },
 }
 
 /// This is a rewrite/summary of SpdpDiscoveredParticipantData from discovery.
-/// The original is not used to avoid circular dependency between participant and discovery.
-/// Some of the more technical details have been left out
+/// The original is not used to avoid circular dependency between participant
+/// and discovery. Some of the more technical details have been left out
 #[derive(Debug, Clone)]
 pub struct ParticipantDescription {
   pub updated_time: chrono::DateTime<Utc>,
@@ -311,8 +310,9 @@ pub struct ParticipantDescription {
   pub supports_security: bool,
 }
 
-/// This is a summary of SubscriptionBuiltinTopicData / PublicationBuiltinTopicData from discovery.
-/// The original is not used to avoid circular dependency between participant and discovery.
+/// This is a summary of SubscriptionBuiltinTopicData /
+/// PublicationBuiltinTopicData from discovery. The original is not used to
+/// avoid circular dependency between participant and discovery.
 #[derive(Debug, Clone)]
 pub struct EndpointDescription {
   pub updated_time: chrono::DateTime<Utc>,
@@ -322,7 +322,6 @@ pub struct EndpointDescription {
   pub qos: QosPolicies,
 }
 
-
 #[derive(Debug, Clone)]
 pub enum DataReaderStatus {
   /// Sample was rejected, because resource limits would have been exceeded.