JANA2
|
Public Types | |
using | Event = std::shared_ptr< JEvent > |
using | EventQueue = JMailbox< Event > |
Public Types inherited from JArrow | |
enum | NodeType { Source, Sink, Stage, Group } |
enum | BackoffStrategy { Constant, Linear, Exponential } |
using | duration_t = std::chrono::steady_clock::duration |
Public Types inherited from JActivable | |
enum | Status { Unopened, Inactive, Running, Draining, Drained, Finished, Closed } |
Public Member Functions | |
JEventProcessorArrow (std::string name, EventQueue *input_queue, EventQueue *output_queue, std::shared_ptr< JEventPool > pool) | |
void | add_processor (JEventProcessor *processor) |
void | initialize () final |
void | finalize () final |
void | execute (JArrowMetrics &result, size_t location_id) final |
size_t | get_pending () final |
size_t | get_threshold () final |
void | set_threshold (size_t) final |
Public Member Functions inherited from JArrow | |
bool | is_parallel () |
std::string | get_name () |
bool | is_upstream_finished () |
void | set_chunksize (size_t chunksize) |
size_t | get_chunksize () const |
void | set_backoff_tries (unsigned backoff_tries) |
unsigned | get_backoff_tries () const |
BackoffStrategy | get_backoff_strategy () const |
void | set_backoff_strategy (BackoffStrategy backoff_strategy) |
duration_t | get_initial_backoff_time () const |
void | set_initial_backoff_time (const duration_t &initial_backoff_time) |
const duration_t & | get_checkin_time () const |
void | set_checkin_time (const duration_t &checkin_time) |
void | update_thread_count (int thread_count_delta) |
size_t | get_thread_count () |
JArrowMetrics & | get_metrics () |
Status | get_status () |
NodeType | get_type () |
JArrow (std::string name, bool is_parallel, NodeType arrow_type, size_t chunksize=16) | |
void | set_active (bool is_active) override |
Public Member Functions inherited from JActivable | |
virtual bool | is_active () |
void | update_activeness (bool is_active) |
void | notify_downstream (bool is_active) |
void | attach_upstream (JActivable *activable) |
void | attach_downstream (JActivable *activable) |
Additional Inherited Members | |
Protected Member Functions inherited from JArrow | |
void | set_upstream_finished (bool upstream_finished) |
void | set_status (Status status) |
Protected Attributes inherited from JActivable | |
std::atomic< Status > | _status {Status::Unopened} |