JANA2
|
Public Types | |
enum | Status { Inactive, Running, Draining, Finished } |
using | Event = std::shared_ptr< JEvent > |
using | EventQueue = JMailbox< Event > |
Public Types inherited from JActivable | |
enum | Status { Unopened, Inactive, Running, Draining, Drained, Finished, Closed } |
Public Member Functions | |
bool | is_active () override |
void | set_active (bool is_active) override |
Public Member Functions inherited from JActivable | |
void | update_activeness (bool is_active) |
void | notify_downstream (bool is_active) |
void | attach_upstream (JActivable *activable) |
void | attach_downstream (JActivable *activable) |
Static Public Member Functions | |
static JArrowTopology * | from_components (std::shared_ptr< JComponentManager >, std::shared_ptr< JParameterManager >, int nthreads) |
Public Attributes | |
std::shared_ptr< JComponentManager > | component_manager |
std::shared_ptr< JEventPool > | event_pool |
JPerfMetrics | metrics |
Status | status = Inactive |
std::vector< JArrow * > | arrows |
std::vector< JArrow * > | sources |
std::vector< JArrow * > | sinks |
std::vector< EventQueue * > | queues |
JProcessorMapping | mapping |
JLogger | _logger |
Additional Inherited Members | |
Protected Attributes inherited from JActivable | |
std::atomic< Status > | _status {Status::Unopened} |