#include <pipeline.h>
Definition at line 16 of file pipeline.h.
◆ Pipeline()
| Pipeline::Pipeline |
( |
std::shared_ptr< Writer< PFPacket >> |
writer, |
|
|
std::shared_ptr< Reader< PFPacket >> |
reader, |
|
|
std::function< void()> |
func, |
|
|
std::shared_ptr< std::mutex > |
net_mtx, |
|
|
std::shared_ptr< std::condition_variable > |
net_cv, |
|
|
bool & |
net_fail |
|
) |
| |
◆ is_running()
| bool Pipeline::is_running |
( |
| ) |
|
◆ on_shutdown()
| void Pipeline::on_shutdown |
( |
| ) |
|
◆ run_reader()
| void Pipeline::run_reader |
( |
| ) |
|
|
private |
◆ run_writer()
| void Pipeline::run_writer |
( |
| ) |
|
|
private |
◆ start()
◆ terminate()
| void Pipeline::terminate |
( |
| ) |
|
◆ mutex_
| std::mutex Pipeline::mutex_ |
|
private |
◆ net_cv_
| std::shared_ptr<std::condition_variable> Pipeline::net_cv_ |
|
private |
◆ net_fail_
| bool& Pipeline::net_fail_ |
|
private |
◆ net_mtx_
| std::shared_ptr<std::mutex> Pipeline::net_mtx_ |
|
private |
◆ queue_
◆ reader_
◆ reader_thread_
| std::thread Pipeline::reader_thread_ |
|
private |
◆ running_
| std::atomic<bool> Pipeline::running_ |
|
private |
◆ shutdown
| std::function<void()> Pipeline::shutdown |
|
private |
◆ shutdown_
| std::atomic<bool> Pipeline::shutdown_ |
|
private |
◆ writer_
◆ writer_thread_
| std::thread Pipeline::writer_thread_ |
|
private |
The documentation for this class was generated from the following files: