gstreamer
Loading...
Searching...
No Matches

#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.

Detailed Description

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.

Constructor & Destructor Documentation

◆ GSROFactory()

GSROFactory::GSROFactory ( std::shared_ptr< GSROImplementation > implementation,
std::string output_basename )

Definition at line 20 of file gSROFactory.cc.

Member Function Documentation

◆ begin_run()

void GSROFactory::begin_run ( int run_id,
GSROEventId event_count )

Definition at line 25 of file gSROFactory.cc.

◆ cancel_run()

void GSROFactory::cancel_run ( std::exception_ptr error)

Definition at line 42 of file gSROFactory.cc.

◆ complete_event()

void GSROFactory::complete_event ( GSROEventId event)

Definition at line 41 of file gSROFactory.cc.

◆ create_crate_thread_if_needed()

void GSROFactory::create_crate_thread_if_needed ( GSROCrateId crate)

Definition at line 35 of file gSROFactory.cc.

◆ dispatch_payload_to_crate()

void GSROFactory::dispatch_payload_to_crate ( GSROPayload payload)

Definition at line 38 of file gSROFactory.cc.

◆ event_context()

GSROEventContext GSROFactory::event_context ( GSROEventId event) const
inline

Definition at line 28 of file gSROFactory.h.

◆ finish_run()

void GSROFactory::finish_run ( bool all_events_processed)

Definition at line 46 of file gSROFactory.cc.

◆ from_options()

std::shared_ptr< GSROFactory > GSROFactory::from_options ( const std::shared_ptr< GOptions > & options)
static

Definition at line 6 of file gSROFactory.cc.

◆ interrupt_run()

void GSROFactory::interrupt_run ( )
inline

Definition at line 24 of file gSROFactory.h.

◆ rethrow_if_failed()

void GSROFactory::rethrow_if_failed ( ) const

Definition at line 51 of file gSROFactory.cc.


The documentation for this class was generated from the following files: