CommRaT 2.0.0
C++20 Real-Time Messaging Framework
Loading...
Searching...
No Matches
Public Member Functions | Protected Types | Protected Member Functions | Protected Attributes | List of all members
commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple > Class Template Reference

Subscription protocol handler. More...

#include <commrat/module/services/subscription.hpp>

Public Member Functions

void set_config (const ModuleConfig *cfg)
 
void set_work_mailbox (RegistryMailbox< SystemRegistry > *mbx)
 
void set_module_name (const std::string &name)
 
void subscribe_to_all_sources ()
 Subscribe to all configured input sources.
 
void subscribe_to_source (uint8_t source_system_id, uint8_t source_instance_id)
 Legacy single-input subscription (backward compatible)
 
void unsubscribe_from_source (uint8_t source_system_id, uint8_t source_instance_id)
 Unsubscribe from single-input source.
 
void unsubscribe_from_multi_input_source (const MultiInputConfig::InputSource &source)
 Unsubscribe from multi-input source.
 
template<typename SubscriberMgr >
void handle_subscribe_request (const SubscribeRequestType &req, SubscriberMgr &sub_mgr, std::size_t output_idx=0)
 Handle incoming SubscribeRequest (producer side)
 
void handle_subscribe_reply (const SubscribeReplyType &reply)
 Handle incoming SubscribeReply (consumer side)
 
template<typename SubscriberMgr >
void handle_unsubscribe_request (const UnsubscribeRequestType &req, SubscriberMgr &sub_mgr)
 Handle incoming UnsubscribeRequest (producer side)
 

Protected Types

using SubscribeRequestType = SubscribeRequestPayload
 
using SubscribeReplyType = SubscribeReplyPayload
 
using UnsubscribeRequestType = UnsubscribeRequestPayload
 
using UnsubscribeReplyType = UnsubscribeReplyPayload
 

Protected Member Functions

void subscribe_to_source_impl (uint8_t source_system_id, uint8_t source_instance_id, size_t source_index)
 Internal implementation: send SubscribeRequest to one source.
 
template<size_t... Is>
uint32_t get_input_type_id_at_index_impl (size_t index, std::index_sequence< Is... >) const
 Helper: Get message ID for input type at runtime index.
 
uint32_t get_input_type_id_at_index (size_t index) const
 

Protected Attributes

std::vector< SubscriptionState > input_subscriptions_
 
std::mutex subscription_mutex_
 
const ModuleConfig * config_ {nullptr}
 
RegistryMailbox< SystemRegistry > * work_mailbox_ {nullptr}
 
std::string module_name_
 

Detailed Description

template<typename Registry, bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
class commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >

Subscription protocol handler.

Template parameters:

  • Registry: Message registry (for message ID lookups)
  • has_continuous_input: Module has single continuous input
  • has_multi_input: Module has multiple synchronized inputs
  • InputData: Single input type (for has_continuous_input)
  • InputTypesTuple: Tuple of input types (for has_multi_input)
  • InputCount: Number of inputs (for has_multi_input)
  • OutputData: Single output type (or void for multi-output)
  • OutputTypesTuple: Tuple of output types (for address calculation)

Definition at line 60 of file subscription.hpp.

Member Typedef Documentation

◆ SubscribeReplyType

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
using commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::SubscribeReplyType = SubscribeReplyPayload
protected

Definition at line 63 of file subscription.hpp.

◆ SubscribeRequestType

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
using commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::SubscribeRequestType = SubscribeRequestPayload
protected

Definition at line 62 of file subscription.hpp.

◆ UnsubscribeReplyType

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
using commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::UnsubscribeReplyType = UnsubscribeReplyPayload
protected

Definition at line 65 of file subscription.hpp.

◆ UnsubscribeRequestType

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
using commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::UnsubscribeRequestType = UnsubscribeRequestPayload
protected

Definition at line 64 of file subscription.hpp.

Member Function Documentation

◆ get_input_type_id_at_index()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
uint32_t commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index ( size_t  index) const
inlineprotected

Definition at line 341 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index_impl().

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_multi_input_source().

◆ get_input_type_id_at_index_impl()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
template<size_t... Is>
uint32_t commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index_impl ( size_t  index,
std::index_sequence< Is... >   
) const
inlineprotected

Helper: Get message ID for input type at runtime index.

Definition at line 335 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index().

◆ handle_subscribe_reply()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_reply ( const SubscribeReplyType &  reply)
inline

Handle incoming SubscribeReply (consumer side)

Definition at line 226 of file subscription.hpp.

References commrat::SubscribeReplyPayload::actual_period_ms, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::input_subscriptions_, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscription_mutex_, and commrat::SubscribeReplyPayload::success.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::handle_subscribe_reply().

◆ handle_subscribe_request()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
template<typename SubscriberMgr >
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_request ( const SubscribeRequestType &  req,
SubscriberMgr &  sub_mgr,
std::size_t  output_idx = 0 
)
inline

Handle incoming SubscribeRequest (producer side)

Definition at line 190 of file subscription.hpp.

References commrat::SubscribeReplyPayload::actual_period_ms, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_, commrat::SubscribeRequestPayload::mailbox_index, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_, commrat::ModuleConfig::period, commrat::SubscribeRequestPayload::subscriber_base_addr, commrat::WORK, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::handle_subscribe_request().

◆ handle_unsubscribe_request()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
template<typename SubscriberMgr >
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_unsubscribe_request ( const UnsubscribeRequestType &  req,
SubscriberMgr &  sub_mgr 
)
inline

Handle incoming UnsubscribeRequest (producer side)

Definition at line 248 of file subscription.hpp.

References commrat::UnsubscribeRequestPayload::subscriber_base_addr, commrat::UnsubscribeReplyPayload::success, commrat::WORK, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::handle_unsubscribe_request().

◆ set_config()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_config ( const ModuleConfig *  cfg)
inline

Definition at line 78 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::Module().

◆ set_module_name()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_module_name ( const std::string &  name)
inline

Definition at line 80 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::Module().

◆ set_work_mailbox()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_work_mailbox ( RegistryMailbox< SystemRegistry > *  mbx)
inline

Definition at line 79 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::Module().

◆ subscribe_to_all_sources()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources ( )
inline

Subscribe to all configured input sources.

For multi-input modules: subscribes to each source in config_.input_sources For single-input modules: subscribes using legacy config fields

Definition at line 88 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_, commrat::ModuleConfig::has_single_input(), commrat::ModuleConfig::input_instance_id(), commrat::ModuleConfig::input_sources(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::input_subscriptions_, commrat::ModuleConfig::input_system_id(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_, commrat::ModuleConfig::source_instance_id(), commrat::ModuleConfig::source_system_id(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscription_mutex_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::subscribe_to_all_sources().

◆ subscribe_to_source()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source ( uint8_t  source_system_id,
uint8_t  source_instance_id 
)
inline

Legacy single-input subscription (backward compatible)

Definition at line 120 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::input_subscriptions_, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl().

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::subscribe_to_source().

◆ subscribe_to_source_impl()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl ( uint8_t  source_system_id,
uint8_t  source_instance_id,
size_t  source_index 
)
inlineprotected

Internal implementation: send SubscribeRequest to one source.

Definition at line 260 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_, commrat::get_data_mbx_base(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::input_subscriptions_, commrat::ModuleConfig::instance_id(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_, commrat::ModuleConfig::period, commrat::SubscribeRequestPayload::subscriber_base_addr, commrat::ModuleConfig::system_id(), commrat::WORK, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source().

◆ unsubscribe_from_multi_input_source()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_multi_input_source ( const MultiInputConfig::InputSource &  source)
inline

Unsubscribe from multi-input source.

Unsubscribe from multi-input source

Requires InputSource.input_index to be set (auto-populated during subscription)

Definition at line 163 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_, commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::get_input_type_id_at_index(), commrat::MultiInputConfig::InputSource::input_index, commrat::MultiInputConfig::InputSource::instance_id, commrat::ModuleConfig::instance_id(), commrat::UnsubscribeRequestPayload::subscriber_base_addr, commrat::MultiInputConfig::InputSource::system_id, commrat::ModuleConfig::system_id(), commrat::WORK, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::unsubscribe_from_multi_input_source().

◆ unsubscribe_from_source()

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
void commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_source ( uint8_t  source_system_id,
uint8_t  source_instance_id 
)
inline

Unsubscribe from single-input source.

Definition at line 129 of file subscription.hpp.

References commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_, commrat::ModuleConfig::instance_id(), commrat::UnsubscribeRequestPayload::subscriber_base_addr, commrat::ModuleConfig::system_id(), commrat::WORK, and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_.

Referenced by commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >::unsubscribe_from_source().

Member Data Documentation

◆ config_

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
const ModuleConfig* commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::config_ {nullptr}
protected

Definition at line 71 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_request(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_config(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_multi_input_source(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_source().

◆ input_subscriptions_

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
std::vector<SubscriptionState> commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::input_subscriptions_
protected

Definition at line 67 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_reply(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl().

◆ module_name_

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
std::string commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::module_name_
protected

Definition at line 73 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_reply(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_request(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_module_name(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl().

◆ subscription_mutex_

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
std::mutex commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscription_mutex_
mutableprotected

Definition at line 68 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_reply(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_all_sources().

◆ work_mailbox_

template<typename Registry , bool has_continuous_input, bool has_multi_input, typename InputData = void, typename InputTypesTuple = std::tuple<>, size_t InputCount = 0, typename OutputData = void, typename OutputTypesTuple = std::tuple<>>
RegistryMailbox<SystemRegistry>* commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::work_mailbox_ {nullptr}
protected

Definition at line 72 of file subscription.hpp.

Referenced by commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_subscribe_request(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::handle_unsubscribe_request(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::set_work_mailbox(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::subscribe_to_source_impl(), commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_multi_input_source(), and commrat::SubscriptionProtocol< Registry, has_continuous_input, has_multi_input, InputData, InputTypesTuple, InputCount, OutputData, OutputTypesTuple >::unsubscribe_from_source().

The documentation for this class was generated from the following file: