_Handle_message(message< _Target_type > *_PMessage) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprivate |
_Invoke_link_source(ITarget< _TargetLinkRegistry::type::type > *_PLinkFrom) | Concurrency::ISource< _TargetLinkRegistry::type::type > | inlineprotected |
_Invoke_unlink_source(ITarget< _TargetLinkRegistry::type::type > *_PUnlinkFrom) | Concurrency::ISource< _TargetLinkRegistry::type::type > | inlineprotected |
_M_connectedTargets | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protected |
_M_internalLock | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | private |
_M_messageProcessor | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protected |
_M_pReservedFor | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protected |
_M_referenceCount | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | private |
_M_reservedId | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protected |
_Process_message(message< _Target_type > *_PMessage) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprivate |
_Propagate_message() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprivate |
_Target_type typedef | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | |
_Wait_on_ref(long _RefCount=0) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprivate |
accept(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
accept_message(runtime_object_identity _MsgId)=0 | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protectedpure virtual |
acquire_ref(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
async_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
consume(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
consume_message(runtime_object_identity _MsgId)=0 | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protectedpure virtual |
enable_batched_processing() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotected |
initialize_source(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotected |
link_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
link_target_notification(_Inout_ ITarget< _Target_type > *) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
process_input_messages(_Inout_ message< _Target_type > *_PMessage) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
propagate_output_messages() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
propagate_to_any_targets(_Inout_opt_ message< _Target_type > *_PMessage) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
release(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
release_message(runtime_object_identity _MsgId)=0 | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protectedpure virtual |
release_ref(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
remove_targets() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotected |
reserve(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
reserve_message(runtime_object_identity _MsgId)=0 | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protectedpure virtual |
resume_propagation()=0 | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | protectedpure virtual |
source_block() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inline |
source_type typedef | Concurrency::ISource< _TargetLinkRegistry::type::type > | |
sync_send(_Inout_opt_ message< _Target_type > *_Msg) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
target_iterator typedef | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | |
unlink_target(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
unlink_target_notification(_Inout_ ITarget< _Target_type > *_PTarget) | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotectedvirtual |
unlink_targets() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |
wait_for_outstanding_async_sends() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlineprotected |
~ISource() | Concurrency::ISource< _TargetLinkRegistry::type::type > | inlinevirtual |
~source_block() | Concurrency::source_block< _TargetLinkRegistry, _MessageProcessorType > | inlinevirtual |