CommRaT 2.0.0
C++20 Real-Time Messaging Framework
Loading...
Searching...
No Matches
commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes > Member List

This is the complete list of members for commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >, including all inherited members.

add_subscriber_to_output(uint32_t subscriber_base_addr, uint8_t mailbox_index, std::size_t output_idx=0)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
cmd_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
command_loop()commrat::CommandDispatcher< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, CommandTypes... >inlineprotected
command_thread_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
CommandDispatcher< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, CommandTypes... >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
config_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
continuous_loop()commrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
create_mailbox_infrastructure(const ModuleConfig &config)commrat::MailboxInfrastructureBuilder< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry >inlineprotectedstatic
create_mailbox_set(const ModuleConfig &config)commrat::MailboxInfrastructureBuilder< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry >inlineprotectedstatic
create_mailbox_sets_impl(const ModuleConfig &config, std::index_sequence< Is... >)commrat::MailboxInfrastructureBuilder< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry >inlineprotectedstatic
create_tims_message(T &&payload, uint64_t timestamp_ns)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotectedstatic
data_mailbox_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
data_thread_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
derived()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
derived() constcommrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
find_output_index_by_type_id(uint16_t type_id_low) constcommrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
free_loop()commrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
get_cmd_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
get_cmd_mailbox_public()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
get_input_metadata() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
get_input_metadata() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
get_input_timestamp() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
get_input_timestamp() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
get_mailbox_set()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
get_output_subscribers(std::size_t output_idx) constcommrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inline
get_publish_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
get_publish_mailbox_public()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
get_work_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
handle_subscribe_reply(const SubscribeReplyPayload &reply)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
handle_subscribe_request(const SubscribeRequestPayload &req, std::size_t output_idx=0)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
handle_unsubscribe_request(const UnsubscribeRequestPayload &req)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
handle_user_command(const CmdT &cmd)commrat::CommandDispatcher< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, CommandTypes... >inlineprotected
has_continuous_inputcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >static
has_loop_inputcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >static
has_multi_outputcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >static
has_new_data() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
has_new_data() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
has_periodic_inputcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >static
initialize_mailbox_infrastructure_impl(const ModuleConfig &config, std::index_sequence< Is... >)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
initialize_output_subscribers()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
input_metadata_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
InputData typedefcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
InputMetadataManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
is_input_valid() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
is_input_valid() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
is_running() constcommrat::LifecycleManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
join_output_work_threads()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
LifecycleManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
mailbox_infrastructure_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
MailboxInfrastructureBuilder< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
mark_input_invalid(std::size_t index)commrat::InputMetadataManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
Module(const ModuleConfig &config)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineexplicit
Module(const Module &)=deletecommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
Module(Module &&)=deletecommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >::module()commrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >::module() constcommrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >::module()commrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >::module() constcommrat::InputMetadataAccessors< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
multi_input_loop()commrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
MultiInputInfrastructure< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, typename module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::InputTypesTuple, module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::InputCount >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
MultiInputProcessor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, typename module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::InputTypesTuple, typename module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::OutputData, typename module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::OutputTypesTuple, module_traits::ModuleTypes< UserRegistry, OutputSpec_, InputSpec_ >::InputCount >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, typename OutputTypesTuple< typename NormalizeOutput< OutputSpec_ >::Type >::type >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
num_inputscommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protectedstatic
on_cleanup()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlinevirtual
on_command(const CmdT &cmd)commrat::CommandDispatcher< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, CommandTypes... >inlineprotected
on_init()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlinevirtual
on_start()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlinevirtual
on_stop()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlinevirtual
operator=(const Module &)=deletecommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
operator=(Module &&)=deletecommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
output_subscribers_commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >protected
output_subscribers_mutex_commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >mutableprotected
output_work_loop()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
output_work_threads_commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >protected
OutputData typedefcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >
periodic_loop()commrat::LoopExecutor< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
process(const ExtractInputPayload< NormalizeInput< InputSpec_ >::Type >::type &input, ExtractOutputPayload< NormalizeOutput< OutputSpec_ >::Type >::type &output)commrat::ContinuousProcessorBase< ExtractInputPayload< NormalizeInput< InputSpec_ >::Type >::type, ExtractOutputPayload< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotectedvirtual
process_dispatch(const T &input, O &output)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publish_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publish_multi_outputs(std::tuple< Ts... > &outputs)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publish_multi_outputs_with_timestamp(std::tuple< Ts... > &outputs, uint64_t timestamp_ns)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publish_tims_message(TimsMessage< T > &tims_msg)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publish_to_subscribers(T &data)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
publisher_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
PublisherType typedefcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
remove_subscriber(uint32_t subscriber_base_addr)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inline
running_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
spawn_all_output_work_threads(std::index_sequence< Is... >)commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
spawn_output_work_thread()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
start()commrat::LifecycleManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
start_all_mailbox_sets(std::index_sequence< Is... >)commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
start_mailbox_set()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
stop()commrat::LifecycleManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inline
stop_all_mailbox_sets(std::index_sequence< Is... >)commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
stop_mailbox_set()commrat::MultiOutputManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... >, UserRegistry, OutputTypesTuple< NormalizeOutput< OutputSpec_ >::Type >::type >inlineprotected
subscribe_to_all_sources()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
subscribe_to_source(uint8_t source_system_id, uint8_t source_instance_id)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
subscription_protocol_commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
SubscriptionProtocolType typedefcommrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >protected
unsubscribe_from_multi_input_source(const MultiInputConfig::InputSource &source)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
unsubscribe_from_source(uint8_t source_system_id, uint8_t source_instance_id)commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
update_input_metadata(std::size_t index, const TimsMessage< T > &received, bool is_new)commrat::InputMetadataManager< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
work_loop()commrat::WorkLoopHandler< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >inlineprotected
work_mailbox()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlineprotected
WorkLoopHandler< Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes... > >commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >friend
~Module()commrat::Module< UserRegistry, OutputSpec_, InputSpec_, CommandTypes >inlinevirtual