|
typedef bits::Timer_pipeline_base< T > | base_pipeline |
|
typedef T | kernel_type |
|
typedef Mutex | mutex_type |
|
typedef Lock | lock_type |
|
typedef Semaphore | sem_type |
|
typedef Traits | traits_type |
|
typedef T | kernel_type |
|
typedef Kernels | kernel_pool |
|
typedef Threads | thread_pool |
|
typedef Mutex | mutex_type |
|
typedef Lock | lock_type |
|
typedef Semaphore | sem_type |
|
typedef Traits | traits_type |
|
typedef std::chrono::system_clock | clock_type |
|
typedef clock_type::time_point | time_point |
|
typedef clock_type::duration | duration |
|
|
| timer_pipeline (timer_pipeline &&rhs) noexcept |
|
| timer_pipeline (const timer_pipeline &)=delete |
|
timer_pipeline & | operator= (const timer_pipeline &)=delete |
|
| 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 |
|
| 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 |
|
|
void | do_run () override |
|
void | xstop () |
|
virtual void | run (Thread_context *context) |
|
|
typedef std::vector< std::unique_ptr< kernel_type > > | kernel_sack |
|
typedef queue_pop_iterator< kernel_pool, traits_type > | queue_popper |
|
kernel_pool | _kernels |
|
thread_pool | _threads |
|
mutex_type | _mutex |
|
sem_type | _semaphore |
|
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 struct was generated from the following files:
- /home/slurm-ci/jobs/subordination-subordination-17/src/subordination/ppl/timer_pipeline.hh
- /home/slurm-ci/jobs/subordination-subordination-17/src/subordination/ppl/timer_pipeline.cc