Public Member Functions |
Private Types |
Private Attributes |
Static Private Attributes |
List of all members
SizeNode< ValueType > Class Template Referencefinal
Detailed Description
template<typename ValueType>
class thrill::api::SizeNode< ValueType >
Inheritance diagram for SizeNode< ValueType >: Collaboration diagram for SizeNode< ValueType >:#include <size.hpp>
Public Member Functions | |
| template<typename ParentDIA > | |
| SizeNode (const ParentDIA &parent) | |
| void | Execute () final |
| Executes the size operation. More... | |
| bool | OnPreOpFile (const data::File &file, size_t) final |
| Receive a whole data::File of ValueType, but only if our stack is empty. More... | |
| const size_t & | result () const final |
| Returns result of global size. More... | |
| Public Member Functions inherited from ActionResultNode< size_t > | |
| ActionResultNode (Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | |
| Public Member Functions inherited from ActionNode | |
| ActionNode (Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | |
| std::vector< DIABase * > | children () const final |
| ActionNodes do not have children. More... | |
| void | DecConsumeCounter (size_t) final |
| void | IncConsumeCounter (size_t) final |
| void | PushData (bool) final |
| ActionNodes do not push data, they only Execute. More... | |
| void | RemoveAllChildren () final |
| ActionNodes do not have children. More... | |
| void | RemoveChild (DIABase *) final |
| ActionNodes do not have children. More... | |
| void | RunPushData () final |
| ActionNodes do not push data, they only Execute. More... | |
| void | SetConsumeCounter (size_t) final |
| Public Member Functions inherited from DIABase | |
| DIABase (Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | |
| The constructor for a DIABase. More... | |
| DIABase (Context &ctx, const char *label, std::vector< size_t > &&parent_ids, std::vector< DIABasePtr > &&parents) | |
| The constructor for a DIABase. More... | |
| DIABase (const DIABase &)=delete | |
| non-copyable: delete copy-constructor More... | |
| DIABase (DIABase &&)=default | |
| move-constructor: default More... | |
| virtual | ~DIABase () |
| Virtual destructor for a DIABase. More... | |
| virtual size_t | consume_counter () const |
| Returns consume_counter_. More... | |
| Context & | context () |
| Returns the api::Context of this DIABase. More... | |
| const size_t & | dia_id () const |
| return unique id of DIANode subclass as stored by StatsNode More... | |
| virtual bool | ForwardDataOnly () const |
| const char * | label () const |
| return label() of DIANode subclass as stored by StatsNode More... | |
| mem::Manager & | mem_manager () |
| Return the Context's memory manager. More... | |
| DIABase & | operator= (const DIABase &)=delete |
| non-copyable: delete assignment operator More... | |
| DIABase & | operator= (DIABase &&)=default |
| move-assignment operator: default More... | |
| std::vector< size_t > | parent_ids () const |
| Returns the parents of this DIABase. More... | |
| const std::vector< DIABasePtr > & | parents () const |
| Returns the parents of this DIABase. More... | |
| void | RemoveParent (DIABase *p) |
| Remove a parent. More... | |
| virtual bool | RequireParentPushData (size_t) const |
| void | RunScope () |
| void | set_mem_limit (const DIAMemUse &mem_limit) |
| void | set_state (const DIAState &state) |
| DIAState | state () const |
| virtual DIAMemUse | PreOpMemUse () |
| Amount of RAM used by PreOp after StartPreOp() More... | |
| virtual void | StartPreOp (size_t) |
| Virtual method for preparing start of PushData. More... | |
| virtual void | StopPreOp (size_t) |
| Virtual method for preparing end of PushData. More... | |
| virtual DIAMemUse | ExecuteMemUse () |
| Amount of RAM used by Execute() More... | |
| virtual DIAMemUse | PushDataMemUse () |
| Amount of RAM used by PushData() More... | |
| virtual void | Dispose () |
| Virtual clear method. Triggers actual disposing in sub-classes. More... | |
| Public Member Functions inherited from ReferenceCounter | |
| ReferenceCounter () noexcept | |
| new objects have zero reference count More... | |
| ReferenceCounter (const ReferenceCounter &) noexcept | |
| coping still creates a new object with zero reference count More... | |
| ~ReferenceCounter () | |
| bool | dec_reference () const noexcept |
| Call whenever resetting (i.e. More... | |
| void | inc_reference () const noexcept |
| Call whenever setting a pointer to the object. More... | |
| ReferenceCounter & | operator= (const ReferenceCounter &) noexcept |
| assignment operator, leaves pointers unchanged More... | |
| size_t | reference_count () const noexcept |
| Return the number of references to this object (for debugging) More... | |
| bool | unique () const noexcept |
| Test if the ReferenceCounter is referenced by only one CountingPtr. More... | |
Private Types | |
| using | Super = ActionResultNode< size_t > |
Private Attributes | |
| size_t | global_size_ = 0 |
| size_t | local_size_ = 0 |
| const bool | parent_stack_empty_ |
| Whether the parent stack is empty. More... | |
Static Private Attributes | |
| static constexpr bool | debug = false |
Additional Inherited Members | |
| Public Types inherited from DIABase | |
| using | DIABasePtr = tlx::CountingPtr< DIABase > |
| Public Attributes inherited from DIABase | |
| common::JsonLogger | logger_ |
| Static Public Attributes inherited from DIABase | |
| static constexpr size_t | kNeverConsume = static_cast<size_t>(-1) |
| Never full consume. More... | |
| Protected Attributes inherited from DIABase | |
| Context & | context_ |
| associated Context More... | |
| const size_t | dia_id_ |
| DIA serial id. More... | |
| const char *const | label_ |
| DOp node static label. More... | |
| DIAState | state_ = DIAState::NEW |
| State of the DIANode. State is NEW on creation. More... | |
| std::vector< DIABasePtr > | parents_ |
| Parents of this DIABase. More... | |
| DIAMemUse | mem_limit_ = 0 |
| size_t | consume_counter_ = 1 |
Member Typedef Documentation
◆ Super
|
private |
Constructor & Destructor Documentation
◆ SizeNode()
|
inlineexplicit |
Definition at line 37 of file size.hpp.
References SizeNode< ValueType >::local_size_, and SizeNode< ValueType >::parent_stack_empty_.
Member Function Documentation
◆ Execute()
|
inlinefinalvirtual |
Executes the size operation.
Implements DIABase.
Definition at line 64 of file size.hpp.
References FlowControlChannel::AllReduce(), DIABase::context_, SizeNode< ValueType >::global_size_, SizeNode< ValueType >::local_size_, LOG, and Context::net.
◆ OnPreOpFile()
|
inlinefinalvirtual |
Receive a whole data::File of ValueType, but only if our stack is empty.
Reimplemented from DIABase.
Definition at line 49 of file size.hpp.
References DIABase::dia_id(), thrill::common::g_debug_push_file, SizeNode< ValueType >::local_size_, LOGC, and SizeNode< ValueType >::parent_stack_empty_.
◆ result()
|
inlinefinalvirtual |
Returns result of global size.
Implements ActionResultNode< size_t >.
Definition at line 73 of file size.hpp.
References SizeNode< ValueType >::global_size_.
Member Data Documentation
◆ debug
◆ global_size_
|
private |
Definition at line 83 of file size.hpp.
Referenced by SizeNode< ValueType >::Execute(), and SizeNode< ValueType >::result().
◆ local_size_
|
private |
Definition at line 81 of file size.hpp.
Referenced by SizeNode< ValueType >::Execute(), SizeNode< ValueType >::OnPreOpFile(), and SizeNode< ValueType >::SizeNode().
◆ parent_stack_empty_
|
private |
Whether the parent stack is empty.
Definition at line 79 of file size.hpp.
Referenced by SizeNode< ValueType >::OnPreOpFile(), and SizeNode< ValueType >::SizeNode().
The documentation for this class was generated from the following file:
- thrill/api/size.hpp
