STLdoc
STLdocumentation
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Concurrency::transformer< _Input, _Output > Member List

This is the complete list of members for Concurrency::transformer< _Input, _Output >, including all inherited members.

_Delete_stored_messages()Concurrency::transformer< _Input, _Output >inlineprivate
_Invoke_link_source(ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PLinkFrom)Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >inlineprotected
_Invoke_unlink_source(ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PUnlinkFrom)Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >inlineprotected
_M_connectedSourcesConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >protected
_M_connectedTargetsConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >protected
_M_fDeclineMessagesConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >protected
_M_inputMessagesConcurrency::transformer< _Input, _Output >private
_M_messageBufferConcurrency::transformer< _Input, _Output >private
_M_messageProcessorConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >protected
_M_pFilterConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >protected
_M_pFuncConcurrency::transformer< _Input, _Output >private
_M_pReservedForConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >protected
_M_reservedIdConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >protected
_Propagate_priority_order(::Concurrency::details::_Queue< message< _Target_type >> &_MessageBuffer)Concurrency::transformer< _Input, _Output >inlineprivate
_Source_type typedefConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >
_SourceLinkManager typedefConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >
_SourceLinkRegistry typedefConcurrency::transformer< _Input, _Output >private
_Target_type typedefConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >
_TargetLinkRegistry typedefConcurrency::transformer< _Input, _Output >private
_Transform_method typedefConcurrency::transformer< _Input, _Output >private
accept(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::accept(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
accept_message(runtime_object_identity _MsgId)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
acquire_ref(_Inout_ ITarget< _Target_type > *)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::acquire_ref(_Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
async_send(_Inout_opt_ message< _Target_type > *_Msg)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
consume(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::consume(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
consume_message(runtime_object_identity _MsgId)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
decline_incoming_messages()Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotected
enable_batched_processing()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotected
filter_method typedefConcurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >
initialize_source(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotected
initialize_source_and_target(_Inout_opt_ Scheduler *_PScheduler=NULL, _Inout_opt_ ScheduleGroup *_PScheduleGroup=NULL)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotected
link_source(_Inout_ ISource< _Source_type > *_PSource)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotectedvirtual
ITarget< multi_link_registry< ISource< _Input > >::type::source_type >::link_source(_Inout_ ISource< multi_link_registry< ISource< _Input > >::type::source_type > *_PSource)=0Concurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >protectedpure virtual
link_target(_Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::link_target(_Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
link_target_notification(_Inout_ ITarget< _Output > *)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >::link_target_notification(_Inout_ ITarget< _Target_type > *)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
operator=(transformer const &)Concurrency::transformer< _Input, _Output >private
process_input_messages(_Inout_ message< _Target_type > *_PMessage)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotectedvirtual
propagate(_Inout_opt_ message< _Source_type > *_PMessage, _Inout_opt_ ISource< _Source_type > *_PSource)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlinevirtual
ITarget< multi_link_registry< ISource< _Input > >::type::source_type >::propagate(_Inout_opt_ message< multi_link_registry< ISource< _Input > >::type::source_type > *_PMessage, _Inout_opt_ ISource< multi_link_registry< ISource< _Input > >::type::source_type > *_PSource)=0Concurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >pure virtual
propagate_message(_Inout_ message< _Input > *_PMessage, _Inout_ ISource< _Input > *_PSource)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >::propagate_message(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource)=0Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >protectedpure virtual
propagate_output_messages()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
propagate_to_any_targets(_Inout_opt_ message< _Output > *)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >::propagate_to_any_targets(_Inout_opt_ message< _Target_type > *_PMessage)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
propagator_block()Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inline
register_filter(filter_method const &_Filter)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotected
release(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::release(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
release_message(runtime_object_identity _MsgId)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
release_ref(_Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::release_ref(_Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
remove_network_links()Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotected
remove_targets()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotected
reserve(runtime_object_identity _MsgId, _Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::reserve(runtime_object_identity _MsgId, _Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
reserve_message(runtime_object_identity _MsgId)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
resume_propagation()Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
send(_Inout_ message< _Source_type > *_PMessage, _Inout_ ISource< _Source_type > *_PSource)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlinevirtual
ITarget< multi_link_registry< ISource< _Input > >::type::source_type >::send(_Inout_ message< multi_link_registry< ISource< _Input > >::type::source_type > *_PMessage, _Inout_ ISource< multi_link_registry< ISource< _Input > >::type::source_type > *_PSource)=0Concurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >pure virtual
send_message(_Inout_ message< _Input > *_PMessage, _Inout_ ISource< _Input > *_PSource)Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >::send_message(_Inout_ message< _Source_type > *, _Inout_ ISource< _Source_type > *)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotectedvirtual
source_block()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inline
source_iterator typedefConcurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >
source_type typedefConcurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >
supports_anonymous_source()Concurrency::transformer< _Input, _Output >inlineprotectedvirtual
sync_send(_Inout_opt_ message< _Target_type > *_Msg)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
target_iterator typedefConcurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >
transformer(_Transform_method const &_Func, _Inout_opt_ ITarget< _Output > *_PTarget=NULL)Concurrency::transformer< _Input, _Output >inline
transformer(_Transform_method const &_Func, _Inout_opt_ ITarget< _Output > *_PTarget, filter_method const &_Filter)Concurrency::transformer< _Input, _Output >inline
transformer(transformer const &)Concurrency::transformer< _Input, _Output >private
type typedefConcurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >
unlink_source(_Inout_ ISource< _Source_type > *_PSource)Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotectedvirtual
ITarget< multi_link_registry< ISource< _Input > >::type::source_type >::unlink_source(_Inout_ ISource< multi_link_registry< ISource< _Input > >::type::source_type > *_PSource)=0Concurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >protectedpure virtual
unlink_sources()Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlineprotectedvirtual
unlink_target(_Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
ISource< single_link_registry< ITarget< _Output > >::type::type >::unlink_target(_Inout_ ITarget< single_link_registry< ITarget< _Output > >::type::type > *_PTarget)=0Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >pure virtual
unlink_target_notification(_Inout_ ITarget< _Target_type > *_PTarget)Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotectedvirtual
unlink_targets()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
wait_for_outstanding_async_sends()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlineprotected
~ISource()Concurrency::ISource< single_link_registry< ITarget< _Output > >::type::type >inlinevirtual
~ITarget()Concurrency::ITarget< multi_link_registry< ISource< _Input > >::type::source_type >inlinevirtual
~propagator_block()Concurrency::propagator_block< single_link_registry< ITarget< _Output > >, multi_link_registry< ISource< _Input > > >inlinevirtual
~source_block()Concurrency::source_block< single_link_registry< ITarget< _Output > >, _MessageProcessorType >inlinevirtual
~transformer()Concurrency::transformer< _Input, _Output >inline