SourceXtractor::MultithreadedMeasurement Member List

This is the complete list of members for SourceXtractor::MultithreadedMeasurement, including all inherited members.

addObserver(std::shared_ptr< Observer< T > > observer)	SourceXtractor::Observable< T >	inlinevirtual
m_abort_raised	SourceXtractor::MultithreadedMeasurement	private
m_group_counter	SourceXtractor::MultithreadedMeasurement	private
m_input_done	SourceXtractor::MultithreadedMeasurement	private
m_new_output	SourceXtractor::MultithreadedMeasurement	private
m_next_stage	SourceXtractor::PipelineEmitter< SourceGroupInterface >	private
m_observers	SourceXtractor::Observable< T >	private
m_output_queue	SourceXtractor::MultithreadedMeasurement	private
m_output_queue_mutex	SourceXtractor::MultithreadedMeasurement	private
m_output_thread	SourceXtractor::MultithreadedMeasurement	private
m_semaphore	SourceXtractor::MultithreadedMeasurement	private
m_source_to_row	SourceXtractor::MultithreadedMeasurement	private
m_thread_pool	SourceXtractor::MultithreadedMeasurement	private
MultithreadedMeasurement(SourceToRowConverter source_to_row, const std::shared_ptr< Euclid::ThreadPool > &thread_pool, unsigned max_queue_size)	SourceXtractor::MultithreadedMeasurement	inline
notifyObservers(const T &message) const	SourceXtractor::Observable< T >	inlineprotected
outputThreadLoop()	SourceXtractor::MultithreadedMeasurement	private
outputThreadStatic(MultithreadedMeasurement *measurement)	SourceXtractor::MultithreadedMeasurement	privatestatic
receiveProcessSignal(const ProcessSourcesEvent &event) override	SourceXtractor::MultithreadedMeasurement	virtual
receiveSource(std::unique_ptr< SourceGroupInterface > source_group) override	SourceXtractor::MultithreadedMeasurement	virtual
removeObserver(std::shared_ptr< Observer< T > > observer)	SourceXtractor::Observable< T >	inlinevirtual
sendProcessSignal(const ProcessSourcesEvent &event) const	SourceXtractor::PipelineEmitter< SourceGroupInterface >	inlineprotected
sendSource(std::unique_ptr< SourceGroupInterface > source) const	SourceXtractor::PipelineEmitter< SourceGroupInterface >	inlineprotected
setNextStage(std::shared_ptr< PipelineReceiver< SourceGroupInterface > > next)	SourceXtractor::PipelineEmitter< SourceGroupInterface >	inline
SourceToRowConverter typedef	SourceXtractor::MultithreadedMeasurement
startThreads() override	SourceXtractor::MultithreadedMeasurement	virtual
stopThreads() override	SourceXtractor::MultithreadedMeasurement	virtual
synchronizeThreads() override	SourceXtractor::MultithreadedMeasurement	virtual
~Measurement() override=default	SourceXtractor::Measurement
~MultithreadedMeasurement() override	SourceXtractor::MultithreadedMeasurement
~Observable()=default	SourceXtractor::Observable< T >	virtual
~PipelineEmitter() override=default	SourceXtractor::PipelineEmitter< SourceGroupInterface >
~PipelineReceiver()=default	SourceXtractor::PipelineReceiver< SourceGroupInterface >	virtual