Inheritance diagram for sbn::io_pipeline< T >:
Collaboration diagram for sbn::io_pipeline< T >:
Public Types | |
| typedef parallel_pipeline< T > | base_pipeline |
 Public Types inherited from sbn::parallel_pipeline< T > | |
| 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 | |
| io_pipeline (io_pipeline &&rhs) noexcept | |
| io_pipeline () noexcept | |
| use only one thread to read/write data | |
| io_pipeline (unsigned concurrency) noexcept | |
| io_pipeline (const io_pipeline &)=delete | |
| io_pipeline & | operator= (const io_pipeline &)=delete |
| Public Member Functions inherited from sbn::parallel_pipeline< T > | |
| 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 |
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 Member Functions inherited from sbn::parallel_pipeline< T > | |
| void | do_run () override |
| Protected Member Functions inherited from sbn::basic_pipeline< T > | |
| void | xstop () |
| virtual void | run (Thread_context *context) |
| 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 struct was generated from the following file:
- /home/slurm-ci/jobs/subordination-subordination-17/src/subordination/ppl/io_pipeline.hh
