Intel(R) Threading Building Blocks Doxygen Documentation
version 4.2.3
|
An executable node that acts as a source, i.e. it has no predecessors. More...
#include <flow_graph.h>
Public Types | |
typedef Output | output_type |
The type of the output message, which is complete. More... | |
typedef sender< output_type >::successor_type | successor_type |
The type of successors of this node. More... | |
typedef null_type | input_type |
![]() | |
typedef Output | output_type |
The output type of this sender. More... | |
typedef internal::async_helpers< Output >::filtered_type | filtered_type |
![]() | |
typedef untyped_receiver | successor_type |
The successor type for this node. More... | |
Public Member Functions | |
template<typename Body > | |
source_node (graph &g, Body body, bool is_active=true) | |
Constructor for a node with a successor. More... | |
source_node (const source_node &src) | |
Copy constructor. More... | |
~source_node () | |
The destructor. More... | |
bool | register_successor (successor_type &r) __TBB_override |
Add a new successor to this node. More... | |
bool | remove_successor (successor_type &r) __TBB_override |
Removes a successor from this node. More... | |
bool | try_get (output_type &v) __TBB_override |
Request an item from the node. More... | |
bool | try_reserve (output_type &v) __TBB_override |
Reserves an item. More... | |
bool | try_release () __TBB_override |
Release a reserved item. More... | |
bool | try_consume () __TBB_override |
Consumes a reserved item. More... | |
void | activate () |
Activates a node that was created in the inactive state. More... | |
template<typename Body > | |
Body | copy_function_object () |
![]() | |
graph_node (graph &g) | |
virtual | ~graph_node () |
![]() | |
virtual | ~untyped_sender () |
Protected Member Functions | |
void | reset_node (reset_flags f) __TBB_override |
resets the source_node to its initial state More... | |
![]() | |
virtual bool | try_get_wrapper (void *p, bool is_async) __TBB_override |
virtual bool | try_reserve_wrapper (void *p, bool is_async) __TBB_override |
![]() | |
template<typename X > | |
bool | try_get (X &t) |
Request an item from the sender. More... | |
template<typename X > | |
bool | try_reserve (X &t) |
Reserves an item in the sender. More... | |
Private Member Functions | |
bool | try_reserve_apply_body (output_type &v) |
task * | create_put_task () |
void | spawn_put () |
Spawns a task that applies the body. More... | |
task * | apply_body_bypass () |
Applies the body. Returning SUCCESSFULLY_ENQUEUED okay; forward_task_bypass will handle it. More... | |
Private Attributes | |
spin_mutex | my_mutex |
bool | my_active |
bool | init_my_active |
internal::source_body< output_type > * | my_body |
internal::source_body< output_type > * | my_init_body |
internal::broadcast_cache< output_type > | my_successors |
bool | my_reserved |
bool | my_has_cached_item |
output_type | my_cached_item |
Friends | |
class | internal::source_task_bypass< source_node< output_type > > |
Additional Inherited Members | |
![]() | |
graph & | my_graph |
graph_node * | next |
graph_node * | prev |
An executable node that acts as a source, i.e. it has no predecessors.
Definition at line 863 of file flow_graph.h.
typedef null_type tbb::flow::interface10::source_node< Output >::input_type |
Definition at line 872 of file flow_graph.h.
typedef Output tbb::flow::interface10::source_node< Output >::output_type |
The type of the output message, which is complete.
Definition at line 866 of file flow_graph.h.
typedef sender<output_type>::successor_type tbb::flow::interface10::source_node< Output >::successor_type |
The type of successors of this node.
Definition at line 869 of file flow_graph.h.
|
inline |
Constructor for a node with a successor.
Definition at line 881 of file flow_graph.h.
|
inline |
Copy constructor.
Definition at line 893 of file flow_graph.h.
References tbb::internal::fgt_node_with_body().
|
inline |
The destructor.
Definition at line 905 of file flow_graph.h.
|
inline |
Activates a node that was created in the inactive state.
Definition at line 1011 of file flow_graph.h.
|
inlineprivate |
Applies the body. Returning SUCCESSFULLY_ENQUEUED okay; forward_task_bypass will handle it.
Definition at line 1104 of file flow_graph.h.
References tbb::flow::interface10::internal::broadcast_cache< T, M >::try_put_task().
|
inline |
Definition at line 1019 of file flow_graph.h.
|
inlineprivate |
Definition at line 1090 of file flow_graph.h.
|
inlinevirtual |
Add a new successor to this node.
Implements tbb::flow::interface10::internal::untyped_sender.
Definition at line 914 of file flow_graph.h.
References lock.
|
inlinevirtual |
Removes a successor from this node.
Implements tbb::flow::interface10::internal::untyped_sender.
Definition at line 923 of file flow_graph.h.
|
inlineprotectedvirtual |
resets the source_node to its initial state
Implements tbb::flow::interface10::graph_node.
Definition at line 1036 of file flow_graph.h.
|
inlineprivate |
Spawns a task that applies the body.
Definition at line 1096 of file flow_graph.h.
References tbb::flow::interface10::internal::is_graph_active(), and tbb::flow::interface10::internal::spawn_in_graph_arena().
|
inlinevirtual |
Consumes a reserved item.
Reimplemented from tbb::flow::interface10::internal::untyped_sender.
Definition at line 999 of file flow_graph.h.
References __TBB_ASSERT, and lock.
|
inlinevirtual |
Request an item from the node.
Reimplemented from tbb::flow::interface10::sender< Output >.
Definition at line 955 of file flow_graph.h.
References lock.
|
inlinevirtual |
Release a reserved item.
true = item has been released and so remains in sender, dest must request or reserve future items
Reimplemented from tbb::flow::interface10::internal::untyped_sender.
Definition at line 989 of file flow_graph.h.
References __TBB_ASSERT, and lock.
|
inlinevirtual |
Reserves an item.
Reimplemented from tbb::flow::interface10::sender< Output >.
Definition at line 972 of file flow_graph.h.
References lock.
|
inlineprivate |
Definition at line 1064 of file flow_graph.h.
|
friend |
Definition at line 1102 of file flow_graph.h.
|
private |
Definition at line 1055 of file flow_graph.h.
|
private |
Definition at line 1054 of file flow_graph.h.
|
private |
Definition at line 1056 of file flow_graph.h.
|
private |
Definition at line 1061 of file flow_graph.h.
|
private |
Definition at line 1060 of file flow_graph.h.
|
private |
Definition at line 1057 of file flow_graph.h.
|
private |
Definition at line 1053 of file flow_graph.h.
|
private |
Definition at line 1059 of file flow_graph.h.
|
private |
Definition at line 1058 of file flow_graph.h.