_Consume_received_message() | Concurrency::_Non_greedy_node< _Type > | inline |
_Create_send_message() | Concurrency::_Order_node_base< _Type > | inlineprotected |
_Initialize_order_node(ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget, Scheduler *_PScheduler=NULL, ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::_Order_node_base< _Type > | inlineprotected |
_Invoke_link_source(ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PLinkFrom) | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | inlineprotected |
_Invoke_unlink_source(ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PUnlinkFrom) | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | inlineprotected |
_M_connectedSources | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | protected |
_M_connectedTargets | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | protected |
_M_fDeclineMessages | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | protected |
_M_fIsInitialized | Concurrency::_Non_greedy_node< _Type > | private |
_M_index | Concurrency::_Order_node_base< _Type > | protected |
_M_messageProcessor | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | protected |
_M_pFilter | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | protected |
_M_pReceiveMessage | Concurrency::_Order_node_base< _Type > | protected |
_M_pReservedFor | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | protected |
_M_pReservedSource | Concurrency::_Non_greedy_node< _Type > | private |
_M_pSendMessage | Concurrency::_Order_node_base< _Type > | protected |
_M_reservedId | Concurrency::_Non_greedy_node< _Type > | private |
_M_resetLock | Concurrency::_Non_greedy_node< _Type > | private |
_M_savedId | Concurrency::_Non_greedy_node< _Type > | private |
_Non_greedy_node(ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget=NULL) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget, filter_method const &_Filter) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(Scheduler &_PScheduler, ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget=NULL) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(Scheduler &_PScheduler, ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget, filter_method const &_Filter) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(ScheduleGroup &_PScheduleGroup, ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget=NULL) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(ScheduleGroup &_PScheduleGroup, ISource< _Type > *_PSource, size_t _Index, ITarget< size_t > *_PTarget, filter_method const &_Filter) | Concurrency::_Non_greedy_node< _Type > | inline |
_Non_greedy_node(_Non_greedy_node const &) | Concurrency::_Non_greedy_node< _Type > | private |
_Order_node_base() | Concurrency::_Order_node_base< _Type > | inline |
_Release_received_message() | Concurrency::_Non_greedy_node< _Type > | inline |
_Reserve_received_message() | Concurrency::_Non_greedy_node< _Type > | inline |
_Reset() | Concurrency::_Non_greedy_node< _Type > | inlinevirtual |
_Source_type typedef | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | |
_SourceLinkManager typedef | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | |
_SourceLinkRegistry typedef | Concurrency::_Non_greedy_node< _Type > | private |
_Target_type typedef | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | |
_TargetLinkRegistry typedef | Concurrency::_Non_greedy_node< _Type > | private |
accept(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::accept(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
accept_message(runtime_object_identity _MsgId) | Concurrency::_Non_greedy_node< _Type > | inlineprotectedvirtual |
acquire_ref(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::acquire_ref(_Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
async_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
consume(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::consume(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
consume_message(runtime_object_identity) | Concurrency::_Order_node_base< _Type > | inlinevirtual |
decline_incoming_messages() | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotected |
enable_batched_processing() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotected |
filter_method typedef | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | |
has_value() const | Concurrency::_Order_node_base< _Type > | inline |
initialize_source(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotected |
initialize_source_and_target(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotected |
link_source(_Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotectedvirtual |
ITarget< multi_link_registry< ISource< _Type > >::type::source_type >::link_source(_Inout_ ISource< multi_link_registry< ISource< _Type > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | protectedpure virtual |
link_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::link_target(_Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
link_target_notification(_Inout_ ITarget< size_t > *) | Concurrency::_Order_node_base< _Type > | inlineprotectedvirtual |
propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > >::link_target_notification(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
operator=(_Non_greedy_node const &) | Concurrency::_Non_greedy_node< _Type > | private |
process_input_messages(_Inout_ message< _Target_type > *_PMessage) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotectedvirtual |
propagate(_Inout_opt_ message< _Source_type > *_PMessage, _Inout_opt_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlinevirtual |
ITarget< multi_link_registry< ISource< _Type > >::type::source_type >::propagate(_Inout_opt_ message< multi_link_registry< ISource< _Type > >::type::source_type > *_PMessage, _Inout_opt_ ISource< multi_link_registry< ISource< _Type > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | pure virtual |
propagate_message(message< _Type > *_PMessage, ISource< _Type > *) | Concurrency::_Non_greedy_node< _Type > | inlineprotectedvirtual |
Concurrency::_Order_node_base::propagate_message(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource)=0 | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | protectedpure virtual |
propagate_output_messages() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
propagate_to_any_targets(_Inout_opt_ message< size_t > *) | Concurrency::_Non_greedy_node< _Type > | inlineprotectedvirtual |
Concurrency::_Order_node_base::propagate_to_any_targets(_Inout_opt_ message< _Target_type > *_PMessage) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
propagator_block() | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inline |
register_filter(filter_method const &_Filter) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotected |
release(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::release(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
release_message(runtime_object_identity) | Concurrency::_Order_node_base< _Type > | inlinevirtual |
release_ref(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::release_ref(_Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
remove_network_links() | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotected |
remove_targets() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotected |
reserve(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::reserve(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
reserve_message(runtime_object_identity) | Concurrency::_Order_node_base< _Type > | inlinevirtual |
resume_propagation() | Concurrency::_Order_node_base< _Type > | inlineprotectedvirtual |
send(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlinevirtual |
ITarget< multi_link_registry< ISource< _Type > >::type::source_type >::send(_Inout_ message< multi_link_registry< ISource< _Type > >::type::source_type > *_PMessage, _Inout_ ISource< multi_link_registry< ISource< _Type > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | pure virtual |
send_message(_Inout_ message< _Source_type > *, _Inout_ ISource< _Source_type > *) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotectedvirtual |
source_block() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inline |
source_iterator typedef | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | |
source_type typedef | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | |
supports_anonymous_source() | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | inlinevirtual |
sync_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
target_iterator typedef | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | |
type typedef | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | |
unlink_source(_Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotectedvirtual |
ITarget< multi_link_registry< ISource< _Type > >::type::source_type >::unlink_source(_Inout_ ISource< multi_link_registry< ISource< _Type > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | protectedpure virtual |
unlink_sources() | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlineprotectedvirtual |
unlink_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
ISource< single_link_registry< ITarget< size_t > >::type::type >::unlink_target(_Inout_ ITarget< single_link_registry< ITarget< size_t > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | pure virtual |
unlink_target_notification(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotectedvirtual |
unlink_targets() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |
value() | Concurrency::_Order_node_base< _Type > | inline |
wait_for_outstanding_async_sends() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlineprotected |
~_Non_greedy_node() | Concurrency::_Non_greedy_node< _Type > | inline |
~_Order_node_base() | Concurrency::_Order_node_base< _Type > | inline |
~ISource() | Concurrency::ISource< single_link_registry< ITarget< size_t > >::type::type > | inlinevirtual |
~ITarget() | Concurrency::ITarget< multi_link_registry< ISource< _Type > >::type::source_type > | inlinevirtual |
~propagator_block() | Concurrency::propagator_block< single_link_registry< ITarget< size_t > >, multi_link_registry< ISource< _Type > > > | inlinevirtual |
~source_block() | Concurrency::source_block< single_link_registry< ITarget< size_t > >, _MessageProcessorType > | inlinevirtual |