Inheritance diagram for sbn::parallel_pipeline< T >:

Collaboration diagram for sbn::parallel_pipeline< T >:

Public Types
typedef basic_pipeline< T >	base_pipeline

Public Types inherited from sbn::basic_pipeline< T >
typedef T	kernel_type

typedef std::queue< T * >	kernel_pool

typedef std::vector< std::thread >	thread_pool

typedef sys::spin_mutex	mutex_type

typedef sys::simple_lock< sys::spin_mutex >	lock_type

typedef sys::thread_semaphore	sem_type

typedef queue_traits< std::queue< T * > >	traits_type

Public Types inherited from sbn::pipeline_base
typedef std::chrono::system_clock	clock_type

typedef clock_type::time_point	time_point

typedef clock_type::duration	duration

Public Member Functions
	parallel_pipeline (parallel_pipeline &&rhs) noexcept

	parallel_pipeline (unsigned concurrency) noexcept

	parallel_pipeline (const parallel_pipeline &)=delete

parallel_pipeline &	operator= (const parallel_pipeline &)=delete

Public Member Functions inherited from sbn::basic_pipeline< T >
	basic_pipeline (unsigned concurrency) noexcept

	basic_pipeline (basic_pipeline &&rhs) noexcept

	basic_pipeline (const basic_pipeline &)=delete

basic_pipeline &	operator= (const basic_pipeline &)=delete

void	send (kernel_type *k)

void	send (kernel_type **kernels, size_t n)

void	start ()

void	stop ()

void	wait ()

unsigned	concurrency () const noexcept

Public Member Functions inherited from sbn::pipeline_base
	pipeline_base (pipeline_base &&)=default

	pipeline_base (const pipeline_base &)=delete

pipeline_base &	operator= (pipeline_base &)=delete

void	setstate (pipeline_state rhs) noexcept

pipeline_state	state () const noexcept

bool	is_starting () const noexcept

bool	has_started () const noexcept

bool	is_running () const noexcept

bool	is_stopping () const noexcept

bool	has_stopped () const noexcept

time_point	start_time_point () const noexcept

bool	has_start_time_point () const noexcept

const char *	name () const noexcept

void	set_name (const char *rhs) noexcept

void	set_number (unsigned rhs) noexcept

template<class ... Args>
void	log (const Args &... args) const

void	log_error (const std::exception &err) const

Protected Member Functions
void	do_run () override

Protected Member Functions inherited from sbn::basic_pipeline< T >
void	xstop ()

virtual void	run (Thread_context *context)

Additional Inherited Members
Protected Types inherited from sbn::basic_pipeline< T >
typedef std::vector< std::unique_ptr< kernel_type > >	kernel_sack

typedef queue_pop_iterator< kernel_pool, traits_type >	queue_popper

Protected Attributes inherited from sbn::basic_pipeline< T >
kernel_pool	_kernels

thread_pool	_threads

mutex_type	_mutex

sem_type	_semaphore

Protected Attributes inherited from sbn::pipeline_base
volatile pipeline_state	_state = pipeline_state::initial

time_point	_start = time_point(duration::zero())

const char *	_name = "ppl"

unsigned	_number = 0

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

/home/slurm-ci/jobs/subordination-subordination-17/src/subordination/ppl/parallel_pipeline.hh
/home/slurm-ci/jobs/subordination-subordination-17/src/subordination/ppl/parallel_pipeline.cc

Public Types

Public Member Functions