| _Create_send_message() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Delete_stored_messages() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Invoke_link_source(ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PLinkFrom) | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | inlineprotected |
| _Invoke_unlink_source(ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PUnlinkFrom) | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | inlineprotected |
| _Join_node() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inline |
| _Join_node(Scheduler &_PScheduler) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inline |
| _Join_node(ScheduleGroup &_PScheduleGroup) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inline |
| _Join_node(const _Join_node &_Join) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _M_connectedSources | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | protected |
| _M_connectedTargets | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | protected |
| _M_counter | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _M_fDeclineMessages | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | protected |
| _M_messageBuffer | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _M_messageProcessor | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | protected |
| _M_pFilter | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | protected |
| _M_pReservedFor | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | protected |
| _M_reservedId | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | protected |
| _M_sourceTuple | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _Non_greedy_acquire_messages() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Populate_destination_tuple(_Destination_type &_Destination_tuple, ISource< size_t > **_Sources) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Populate_destination_tuple(_Destination_type &, ISource< size_t > **) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Propagate_priority_order(::Concurrency::details::_Queue< message< _Target_type >> &_MessageBuffer) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Source_type typedef | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | |
| _SourceLinkManager typedef | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | |
| _SourceLinkRegistry typedef | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _Target_type typedef | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | |
| _TargetLinkRegistry typedef | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| _Try_consume_source_messages(_Destination_type &_Destination_tuple, ISource< size_t > **_Sources) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| _Try_consume_source_messages(_Destination_type &, ISource< size_t > **) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprivate |
| accept(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::accept(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| accept_message(runtime_object_identity _MsgId) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| acquire_ref(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::acquire_ref(_Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| async_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| consume(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::consume(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| consume_message(runtime_object_identity _MsgId) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| decline_incoming_messages() | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotected |
| enable_batched_processing() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotected |
| filter_method typedef | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | |
| initialize_source(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotected |
| initialize_source_and_target(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotected |
| link_source(_Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotectedvirtual |
| ITarget< multi_link_registry< ISource< size_t > >::type::source_type >::link_source(_Inout_ ISource< multi_link_registry< ISource< size_t > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | protectedpure virtual |
| link_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::link_target(_Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| link_target_notification(_Inout_ ITarget< _Destination_type > *) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > >::link_target_notification(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| operator=(_Join_node const &) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | private |
| process_input_messages(_Inout_ message< _Target_type > *_PMessage) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotectedvirtual |
| propagate(_Inout_opt_ message< _Source_type > *_PMessage, _Inout_opt_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlinevirtual |
| ITarget< multi_link_registry< ISource< size_t > >::type::source_type >::propagate(_Inout_opt_ message< multi_link_registry< ISource< size_t > >::type::source_type > *_PMessage, _Inout_opt_ ISource< multi_link_registry< ISource< size_t > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | pure virtual |
| propagate_message(message< size_t > *_PMessage, ISource< size_t > *_PSource) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > >::propagate_message(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource)=0 | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | protectedpure virtual |
| propagate_output_messages() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| propagate_to_any_targets(_Inout_opt_ message< _Destination_type > *) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > >::propagate_to_any_targets(_Inout_opt_ message< _Target_type > *_PMessage) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| propagator_block() | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inline |
| register_filter(filter_method const &_Filter) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotected |
| release(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::release(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| release_message(runtime_object_identity _MsgId) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| release_ref(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::release_ref(_Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| remove_network_links() | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotected |
| remove_targets() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotected |
| reserve(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::reserve(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| reserve_message(runtime_object_identity _MsgId) | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| resume_propagation() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inlineprotectedvirtual |
| send(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlinevirtual |
| ITarget< multi_link_registry< ISource< size_t > >::type::source_type >::send(_Inout_ message< multi_link_registry< ISource< size_t > >::type::source_type > *_PMessage, _Inout_ ISource< multi_link_registry< ISource< size_t > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | pure virtual |
| send_message(_Inout_ message< _Source_type > *, _Inout_ ISource< _Source_type > *) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotectedvirtual |
| source_block() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inline |
| source_iterator typedef | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | |
| source_type typedef | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | |
| supports_anonymous_source() | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | inlinevirtual |
| sync_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| target_iterator typedef | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | |
| type typedef | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | |
| unlink_source(_Inout_ ISource< _Source_type > *_PSource) | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotectedvirtual |
| ITarget< multi_link_registry< ISource< size_t > >::type::source_type >::unlink_source(_Inout_ ISource< multi_link_registry< ISource< size_t > >::type::source_type > *_PSource)=0 | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | protectedpure virtual |
| unlink_sources() | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlineprotectedvirtual |
| unlink_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| ISource< single_link_registry< ITarget< _Destination_type > >::type::type >::unlink_target(_Inout_ ITarget< single_link_registry< ITarget< _Destination_type > >::type::type > *_PTarget)=0 | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | pure virtual |
| unlink_target_notification(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotectedvirtual |
| unlink_targets() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
| wait_for_outstanding_async_sends() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlineprotected |
| ~_Join_node() | Concurrency::_Join_node< _Type, _Destination_type, _Jtype > | inline |
| ~ISource() | Concurrency::ISource< single_link_registry< ITarget< _Destination_type > >::type::type > | inlinevirtual |
| ~ITarget() | Concurrency::ITarget< multi_link_registry< ISource< size_t > >::type::source_type > | inlinevirtual |
| ~propagator_block() | Concurrency::propagator_block< single_link_registry< ITarget< _Destination_type > >, multi_link_registry< ISource< size_t > > > | inlinevirtual |
| ~source_block() | Concurrency::source_block< single_link_registry< ITarget< _Destination_type > >, _MessageProcessorType > | inlinevirtual |
1.8.8
