Skip to main content

GuardCondition

Struct GuardCondition 

Source
pub struct GuardCondition { /* private fields */ }

Implementations§

Source§

impl GuardCondition

Source

pub fn new(participant: &DomainParticipant) -> DdsResult<Self>

Create a guard condition on participant, holding it alive.

Source

pub unsafe fn from_entity(participant: dds_entity_t) -> DdsResult<Self>

Create a guard condition from a raw participant handle.

§Safety

Does not hold the participant alive. Prefer GuardCondition::new.

Source

pub fn set_triggered(&self, triggered: bool) -> DdsResult<()>

Source

pub fn read(&self) -> DdsResult<bool>

Read the current trigger state without consuming it.

Source

pub fn take(&self) -> DdsResult<bool>

Take (read and reset) the current trigger state.

Trait Implementations§

Source§

impl DdsEntity for GuardCondition

Source§

fn entity(&self) -> dds_entity_t

The raw CycloneDDS handle behind this wrapper. Read more
Source§

fn get_parent(&self) -> DdsResult<dds_entity_t>

Source§

fn get_participant(&self) -> DdsResult<dds_entity_t>

Source§

fn get_publisher(&self) -> DdsResult<dds_entity_t>

Source§

fn get_subscriber(&self) -> DdsResult<dds_entity_t>

Source§

fn get_datareader(&self) -> DdsResult<dds_entity_t>

Source§

fn get_topic(&self) -> DdsResult<dds_entity_t>

Source§

fn get_children(&self) -> DdsResult<Vec<dds_entity_t>>

Source§

fn get_name(&self) -> DdsResult<String>

Source§

fn get_type_name(&self) -> DdsResult<String>

Source§

fn get_domain_id(&self) -> DdsResult<u32>

Source§

fn get_instance_handle(&self) -> DdsResult<dds_instance_handle_t>

Source§

fn get_guid(&self) -> DdsResult<dds_guid_t>

Source§

fn guid(&self) -> DdsResult<dds_guid_t>

Convenience alias for Self::get_guid.
Source§

fn status(&self) -> DdsResult<EntityStatus>

Read a consolidated status snapshot for this entity. Read more
Source§

fn enable(&self) -> DdsResult<()>

Source§

fn get_status_mask(&self) -> DdsResult<u32>

Source§

fn set_status_mask(&self, mask: u32) -> DdsResult<()>

Source§

fn get_status_changes(&self) -> DdsResult<u32>

Source§

fn read_status(&self, mask: u32) -> DdsResult<u32>

Source§

fn take_status(&self, mask: u32) -> DdsResult<u32>

Source§

fn status_changes(&self) -> DdsResult<u32>

Get the set of triggered status bits that have changed since the last time they were read.
Source§

fn triggered(&self) -> DdsResult<bool>

Source§

fn is_shared_memory_available(&self) -> bool

Source§

fn create_statistics(&self) -> DdsResult<Statistics>

Source§

fn get_qos(&self) -> DdsResult<Qos>

Source§

fn get_sertype(&self) -> DdsResult<SertypeHandle>

Source§

fn get_type_info(&self) -> DdsResult<TypeInfo>

Source§

fn get_type_object( &self, type_id: *const dds_typeid_t, timeout: dds_duration_t, ) -> DdsResult<TypeObject>

Source§

fn get_minimal_type_object( &self, timeout: dds_duration_t, ) -> DdsResult<Option<TypeObject>>

Source§

fn get_complete_type_object( &self, timeout: dds_duration_t, ) -> DdsResult<Option<TypeObject>>

Source§

fn matches_entity_type_info<E: DdsEntity>(&self, other: &E) -> DdsResult<bool>

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T> StatusExt for T
where T: DdsEntity + ?Sized,

Source§

fn inconsistent_topic_status(&self) -> DdsResult<InconsistentTopicStatus>

Get the inconsistent-topic status (valid for Topic entities). Read more
Source§

fn liveliness_lost_status(&self) -> DdsResult<LivelinessLostStatus>

Get the liveliness-lost status (valid for DataWriter entities). Read more
Source§

fn liveliness_changed_status(&self) -> DdsResult<LivelinessChangedStatus>

Get the liveliness-changed status (valid for DataReader entities). Read more
Source§

fn offered_deadline_missed_status( &self, ) -> DdsResult<OfferedDeadlineMissedStatus>

Get the offered-deadline-missed status (valid for DataWriter entities). Read more
Source§

fn offered_incompatible_qos_status( &self, ) -> DdsResult<OfferedIncompatibleQosStatus>

Get the offered-incompatible-QoS status (valid for DataWriter entities). Read more
Source§

fn requested_deadline_missed_status( &self, ) -> DdsResult<RequestedDeadlineMissedStatus>

Get the requested-deadline-missed status (valid for DataReader entities). Read more
Source§

fn requested_incompatible_qos_status( &self, ) -> DdsResult<RequestedIncompatibleQosStatus>

Get the requested-incompatible-QoS status (valid for DataReader entities). Read more
Source§

fn sample_lost_status(&self) -> DdsResult<SampleLostStatus>

Get the sample-lost status (valid for DataReader entities). Read more
Source§

fn sample_rejected_status(&self) -> DdsResult<SampleRejectedStatus>

Get the sample-rejected status (valid for DataReader entities). Read more
Source§

fn publication_matched_status(&self) -> DdsResult<PublicationMatchedStatus>

Get the publication-matched status (valid for DataWriter entities). Read more
Source§

fn subscription_matched_status(&self) -> DdsResult<SubscriptionMatchedStatus>

Get the subscription-matched status (valid for DataReader entities). Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more