Class SubscriberImpl

Defined in File subscriber_impl.h

Inheritance Relationships

Derived Types

public swri::BindSubscriberImpl< M > (Template Class BindSubscriberImpl)
public swri::BindUniqueSubscriberImpl< M > (Template Class BindUniqueSubscriberImpl)
public swri::StorageSubscriberImpl< M > (Template Class StorageSubscriberImpl)
public swri::TypedSubscriberImpl< M, T > (Template Class TypedSubscriberImpl)
public swri::TypedUniqueSubscriberImpl< M, T > (Template Class TypedUniqueSubscriberImpl)

Class Documentation

class SubscriberImpl

Subclassed by swri::BindSubscriberImpl< M >, swri::BindUniqueSubscriberImpl< M >, swri::StorageSubscriberImpl< M >, swri::TypedSubscriberImpl< M, T >, swri::TypedUniqueSubscriberImpl< M, T >

Public Functions

inline SubscriberImpl()

inline const std::string &unmappedTopic() const

inline int numPublishers() const

inline void resetStatistics()

inline int messageCount() const

inline rclcpp::Duration age(const rclcpp::Time &now) const

inline rclcpp::Duration meanLatency() const

inline rclcpp::Duration minLatency() const

inline rclcpp::Duration maxLatency() const

inline double meanFrequencyHz() const

inline rclcpp::Duration meanPeriod() const

inline rclcpp::Duration minPeriod() const

inline rclcpp::Duration maxPeriod() const

inline void setTimeout(const rclcpp::Duration &time_out)

inline bool blockTimeouts(bool block)

inline bool timeoutsBlocked() const

inline rclcpp::Duration timeout() const

inline bool timeoutEnabled() const

inline bool inTimeout()

inline int timeoutCount()

Public Members

rclcpp::Node *nh_

Protected Functions

inline void processHeader(const rclcpp::Time &stamp)

inline void checkTimeout(const rclcpp::Time &now)

Protected Attributes

rclcpp::SubscriptionBase::SharedPtr sub_

std::string unmapped_topic_

int message_count_

rclcpp::Time last_header_stamp_ = rclcpp::Time(0, 0, RCL_ROS_TIME)

rclcpp::Time last_receive_time_ = rclcpp::Time(0, 0, RCL_ROS_TIME)

rclcpp::Duration total_latency_ = rclcpp::Duration(std::chrono::nanoseconds::zero())

rclcpp::Duration min_latency_ = rclcpp::Duration::max()

rclcpp::Duration max_latency_ = rclcpp::Duration(std::chrono::nanoseconds::zero())

rclcpp::Duration total_periods_ = rclcpp::Duration::max()

rclcpp::Duration min_period_ = rclcpp::Duration::max()

rclcpp::Duration max_period_ = rclcpp::Duration(std::chrono::nanoseconds::zero())

rclcpp::Duration timeout_ = rclcpp::Duration(std::chrono::nanoseconds::zero())

bool in_timeout_

int timeout_count_

bool blocking_timeout_