Class CSubGate

Defined in File ecal_subgate.h

Class Documentation

class CSubGate

Public Functions

CSubGate()

~CSubGate()

void Start()

void Stop()

bool Register(const std::string &topic_name_, const std::shared_ptr<CSubscriberImpl> &datareader_)

bool Unregister(const std::string &topic_name_, const std::shared_ptr<CSubscriberImpl> &datareader_)

bool HasSample(const std::string &sample_name_)

bool ApplySample(const char *serialized_sample_data_, size_t serialized_sample_size_, eTLayerType layer_)

bool ApplySample(const Payload::TopicInfo &topic_info_, const char *buf_, size_t len_, long long id_, long long clock_, long long time_, size_t hash_, eTLayerType layer_)

void ApplyPublisherRegistration(const Registration::Sample &ecal_sample_)

void ApplyPublisherUnregistration(const Registration::Sample &ecal_sample_)

void GetRegistrations(Registration::SampleList &reg_sample_list_)

Protected Types

using TopicNameSubscriberMapT = std::unordered_multimap<std::string, std::shared_ptr<CSubscriberImpl>>

Protected Attributes

std::shared_timed_mutex m_topic_name_subscriber_mutex

TopicNameSubscriberMapT m_topic_name_subscriber_map

Protected Static Attributes

static std::atomic<bool> m_created

Eclipse Foundation