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 43 of file pipeline.hpp.

Constructor & Destructor Documentation

Worker()

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

inline

Definition at line 45 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 32 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 19 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 64 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 72 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 66 of file pipeline.hpp.

m_idle

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

private

Definition at line 67 of file pipeline.hpp.

m_job

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

private

Definition at line 71 of file pipeline.hpp.

m_mutex

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

private

Definition at line 65 of file pipeline.hpp.

m_pipeline

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

private

Definition at line 64 of file pipeline.hpp.

m_running

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

private

Definition at line 70 of file pipeline.hpp.

m_shutdown

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

private

Definition at line 68 of file pipeline.hpp.

m_stop

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

private

Definition at line 69 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