class sbn::parallel_pipeline
Base classes
Classes
  • class sbn::parallel_pipeline::sentry
Structs
  • struct sbn::parallel_pipeline::properties
Methods
  • write(std::ostream & out) const -> void
  • num_upstream_threads(size_t n) -> void
  • num_downstream_threads(size_t n) -> void
  • guard() const -> sentry
  • guard() -> sentry
  • thread_init(thread_init_type rhs) -> void
  • error_pipeline() const -> pipeline *
  • error_pipeline(pipeline * rhs) -> void
  • clear(kernel_sack & sack) -> void
  • wait() -> void
  • stop() -> void
  • start() -> void
  • send_thread(kernel_ptr && k) -> void
  • send_timer(kernel_ptr && k) -> void
  • send_downstream(kernel_ptr && k) -> void
  • send_upstream(kernel_ptr && k) -> void
  • send(kernel_ptr_array && kernels) -> void
  • send(kernel_ptr && k) -> voidvirtual
  • operator=(const parallel_pipeline &) -> parallel_pipeline &
  • parallel_pipeline(const parallel_pipeline &)
  • operator=(parallel_pipeline &&) -> parallel_pipeline &
  • parallel_pipeline(parallel_pipeline &&)
  • ~parallel_pipeline()
  • parallel_pipeline(const properties & p)explicit
  • parallel_pipeline(unsigned num_upstream_threads)explicit
  • parallel_pipeline()
operator<<(std::ostream & out, const parallel_pipeline & rhs) -> std::ostream &