YPC
0.2.0
|
Public Types | |
typedef processor_base< InputObjType, InputObjType > | base |
![]() | |
typedef ::hpda::internal::processor_with_input< InputObjType > | base |
![]() | |
typedef InputObjType | output_type |
![]() | |
typedef InputObjType | input_type |
Public Member Functions | |
concat_impl (::hpda::internal::processor_with_output< InputObjType > *upper_stream) | |
void | add_upper_stream (::hpda::internal::processor_with_output< InputObjType > *upper_stream) |
virtual bool | process () |
virtual InputObjType | output_value () |
![]() | |
processor_base (::hpda::internal::processor_with_output< InputObjType > *upper_stream) | |
InputObjType | input_value () const |
![]() | |
void | reset_done_value () |
virtual void | done_value () |
bool | has_value () const |
engine * | get_engine () const |
void | set_engine (engine *e) |
void | add_predecessor (functor *pred) |
const std::vector< functor * > | predecessors () const |
![]() | |
processor_with_input (processor_with_output< InputObjType > *input) | |
InputObjType | input_value () const |
bool | has_input_value () const |
void | consume_input_value () |
void | change_upper_stream (processor_with_output< InputObjType > *input) |
Protected Types | |
typedef ::hpda::internal::processor_with_output< InputObjType > | upper_stream_t |
Protected Attributes | |
size_t | m_index |
std::vector< upper_stream_t * > | m_upper_streams |
InputObjType | m_data |
![]() | |
bool | m_has_value |
std::vector< functor * > | m_predecessors |
engine * | m_engine |
uint32_t | m_status |
![]() | |
internal::processor_with_output< InputObjType > * | m_upper_stream |