JANA2
JEventProcessorArrow Member List

This is the complete list of members for JEventProcessorArrow, including all inherited members.

_status (defined in JActivable)JActivableprotected
add_processor(JEventProcessor *processor) (defined in JEventProcessorArrow)JEventProcessorArrow
attach_downstream(JActivable *activable) (defined in JActivable)JActivableinline
attach_upstream(JActivable *activable) (defined in JActivable)JActivableinline
BackoffStrategy enum name (defined in JArrow)JArrow
duration_t typedef (defined in JArrow)JArrow
Event typedef (defined in JEventProcessorArrow)JEventProcessorArrow
EventQueue typedef (defined in JEventProcessorArrow)JEventProcessorArrow
execute(JArrowMetrics &result, size_t location_id) final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
finalize() final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
get_backoff_strategy() const (defined in JArrow)JArrowinline
get_backoff_tries() const (defined in JArrow)JArrowinline
get_checkin_time() const (defined in JArrow)JArrowinline
get_chunksize() const (defined in JArrow)JArrowinline
get_initial_backoff_time() const (defined in JArrow)JArrowinline
get_metrics() (defined in JArrow)JArrowinline
get_name() (defined in JArrow)JArrowinline
get_pending() final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
get_status() (defined in JArrow)JArrowinline
get_thread_count() (defined in JArrow)JArrowinline
get_threshold() final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
get_type() (defined in JArrow)JArrowinline
initialize() final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
is_active() (defined in JActivable)JActivableinlinevirtual
is_parallel() (defined in JArrow)JArrowinline
is_upstream_finished() (defined in JArrow)JArrowinline
JArrow(std::string name, bool is_parallel, NodeType arrow_type, size_t chunksize=16) (defined in JArrow)JArrowinline
JEventProcessorArrow(std::string name, EventQueue *input_queue, EventQueue *output_queue, std::shared_ptr< JEventPool > pool) (defined in JEventProcessorArrow)JEventProcessorArrow
NodeType enum name (defined in JArrow)JArrow
notify_downstream(bool is_active) (defined in JActivable)JActivableinline
set_active(bool is_active) override (defined in JArrow)JArrowinlinevirtual
set_backoff_strategy(BackoffStrategy backoff_strategy) (defined in JArrow)JArrowinline
set_backoff_tries(unsigned backoff_tries) (defined in JArrow)JArrowinline
set_checkin_time(const duration_t &checkin_time) (defined in JArrow)JArrowinline
set_chunksize(size_t chunksize) (defined in JArrow)JArrowinline
set_initial_backoff_time(const duration_t &initial_backoff_time) (defined in JArrow)JArrowinline
set_status(Status status) (defined in JArrow)JArrowinlineprotected
set_threshold(size_t) final (defined in JEventProcessorArrow)JEventProcessorArrowvirtual
set_upstream_finished(bool upstream_finished) (defined in JArrow)JArrowinlineprotected
Status enum name (defined in JActivable)JActivable
update_activeness(bool is_active) (defined in JActivable)JActivableinline
update_thread_count(int thread_count_delta) (defined in JArrow)JArrowinline
~JArrow()=default (defined in JArrow)JArrowvirtual