|
gstreamer
|
#include <gSROFactory.h>
Public Member Functions | |
| GSROFactory (std::shared_ptr< GSROImplementation > implementation, std::string output_basename) | |
| void | begin_run (int run_id, GSROEventId event_count) |
| void | create_crate_thread_if_needed (GSROCrateId crate) |
| void | dispatch_payload_to_crate (GSROPayload payload) |
| void | complete_event (GSROEventId event) |
| void | interrupt_run () |
| void | cancel_run (std::exception_ptr error) |
| void | finish_run (bool all_events_processed) |
| void | rethrow_if_failed () const |
| GSROEventContext | event_context (GSROEventId event) const |
Static Public Member Functions | |
| static std::shared_ptr< GSROFactory > | from_options (const std::shared_ptr< GOptions > &options) |
| Return null when SRO is disabled. Load the selected implementation before workers are created. | |
Generic sro output factory, upcoming in the next release. Shared by master and worker actions. The run owner calls begin_run before workers and finish_run after workers. Each worker dispatches synchronously through its event callback; no hits, callbacks, or mutable digitizer state may escape it. Ordinary event streamers do not load this factory or produce per-worker SRO files.
Definition at line 14 of file gSROFactory.h.
| GSROFactory::GSROFactory | ( | std::shared_ptr< GSROImplementation > | implementation, |
| std::string | output_basename ) |
Definition at line 20 of file gSROFactory.cc.
| void GSROFactory::begin_run | ( | int | run_id, |
| GSROEventId | event_count ) |
Definition at line 25 of file gSROFactory.cc.
| void GSROFactory::cancel_run | ( | std::exception_ptr | error | ) |
Definition at line 42 of file gSROFactory.cc.
| void GSROFactory::complete_event | ( | GSROEventId | event | ) |
Definition at line 41 of file gSROFactory.cc.
| void GSROFactory::create_crate_thread_if_needed | ( | GSROCrateId | crate | ) |
Definition at line 35 of file gSROFactory.cc.
| void GSROFactory::dispatch_payload_to_crate | ( | GSROPayload | payload | ) |
Definition at line 38 of file gSROFactory.cc.
|
inline |
Definition at line 28 of file gSROFactory.h.
| void GSROFactory::finish_run | ( | bool | all_events_processed | ) |
Definition at line 46 of file gSROFactory.cc.
|
static |
Definition at line 6 of file gSROFactory.cc.
|
inline |
Definition at line 24 of file gSROFactory.h.
| void GSROFactory::rethrow_if_failed | ( | ) | const |
Definition at line 51 of file gSROFactory.cc.