dunedaq::oks::OksPipeline::Worker Struct Reference

Collaboration diagram for dunedaq::oks::OksPipeline::Worker:

Public Member Functions
	Worker (OksPipeline &pipeline)
void	run ()
bool	setJob (OksJob *job)
void	shutdown ()
void	stop ()

Private Attributes
OksPipeline &	m_pipeline
boost::mutex	m_mutex
boost::condition	m_condition
bool	m_idle
bool	m_shutdown
bool	m_stop
bool	m_running
OksJob *	m_job

Detailed Description

Definition at line 41 of file pipeline.hpp.

Constructor & Destructor Documentation

Worker()

dunedaq::oks::OksPipeline::Worker::Worker ( OksPipeline & pipeline )

inline

Definition at line 43 of file pipeline.hpp.

          : m_pipeline( pipeline ),
            m_idle( true ),
            m_shutdown( false ),
            m_stop( false ),
            m_running( false )
        { ; }

Member Function Documentation

run()

void dunedaq::oks::OksPipeline::Worker::run

(

)

Definition at line 28 of file pipeline.cpp.

{
    {
    boost::mutex::scoped_lock lock( m_mutex );
    m_pipeline.m_barrier.wait();
    }
    while ( true )
    {
    {
        boost::mutex::scoped_lock lock( m_mutex );
            m_running = true;
        }
    while ( !m_idle ) {
        m_job->run();
        delete m_job;
            m_idle = !m_pipeline.getJob( m_job );
    }
    {
        boost::mutex::scoped_lock lock( m_mutex );
            m_running = false;
            if ( m_shutdown ) 
        break;
        if ( m_stop ) {
        m_pipeline.m_barrier.wait();
                m_stop = false;
            }
        if ( m_idle )
                m_condition.wait( lock ); 
        }
    }
}

setJob()

bool dunedaq::oks::OksPipeline::Worker::setJob

(

OksJob *

job

)

Definition at line 14 of file pipeline.cpp.

{
    boost::mutex::scoped_lock lock( m_mutex );
    if ( !m_running && m_idle )
    {
        m_job = job;
        m_idle = false;
        m_condition.notify_one();
        return true;
    }
    return false;
}

shutdown()

void dunedaq::oks::OksPipeline::Worker::shutdown

(

)

Definition at line 61 of file pipeline.cpp.

{
    boost::mutex::scoped_lock lock( m_mutex );
    m_shutdown = true;
    m_condition.notify_one( );
}

stop()

void dunedaq::oks::OksPipeline::Worker::stop

(

)

Definition at line 69 of file pipeline.cpp.

{
    boost::mutex::scoped_lock lock( m_mutex );
    m_stop = true;
    m_condition.notify_one( );
}

Member Data Documentation

m_condition

boost::condition dunedaq::oks::OksPipeline::Worker::m_condition

private

Definition at line 62 of file pipeline.hpp.

m_idle

bool dunedaq::oks::OksPipeline::Worker::m_idle

private

Definition at line 63 of file pipeline.hpp.

m_job

OksJob* dunedaq::oks::OksPipeline::Worker::m_job

private

Definition at line 67 of file pipeline.hpp.

m_mutex

boost::mutex dunedaq::oks::OksPipeline::Worker::m_mutex

private

Definition at line 61 of file pipeline.hpp.

m_pipeline

OksPipeline& dunedaq::oks::OksPipeline::Worker::m_pipeline

private

Definition at line 60 of file pipeline.hpp.

m_running

bool dunedaq::oks::OksPipeline::Worker::m_running

private

Definition at line 66 of file pipeline.hpp.

m_shutdown

bool dunedaq::oks::OksPipeline::Worker::m_shutdown

private

Definition at line 64 of file pipeline.hpp.

m_stop

bool dunedaq::oks::OksPipeline::Worker::m_stop

private

Definition at line 65 of file pipeline.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/oks/include/oks/pipeline.hpp
• /github/workspace/dunedaq/sourcecode/oks/src/pipeline.cpp