Horizon::System::RuntimeContext::WorkQueueManager Class Reference

#include <System.hpp>

Collaboration diagram for Horizon::System::RuntimeContext::WorkQueueManager:

Public Member Functions
	WorkQueueManager (WorkControlAgent &control_agent)
void	push (std::shared_ptr< WorkContext > seg)
std::shared_ptr< WorkContext >	pop ()
bool	process ()
bool	is_paused ()

Public Attributes
WorkControlAgent &	_control_agent
boost::lockfree::spsc_queue< std::shared_ptr< WorkContext >, boost::lockfree::capacity< 100 > >	_queue
std::atomic< bool >	_paused {false}

Constructor & Destructor Documentation

WorkQueueManager()

Horizon::System::RuntimeContext::WorkQueueManager::WorkQueueManager ( WorkControlAgent &  control_agent )

inline

: _control_agent(control_agent) { }

Member Function Documentation

is_paused()

bool Horizon::System::RuntimeContext::WorkQueueManager::is_paused ( )

inline

{ return _paused; }

References _paused.

pop()

std::shared_ptr< WorkContext > Horizon::System::RuntimeContext::WorkQueueManager::pop ( )

inline

        {
            if (_queue.empty())
                return nullptr;
 
            std::shared_ptr<WorkContext> ret;
            _queue.pop(ret);
            return ret;
        }

References _queue.

Referenced by Horizon::System::RuntimeContext::pop(), and process().

Here is the caller graph for this function:

process()

bool Horizon::System::RuntimeContext::WorkQueueManager::process ( )

inline

        {
            std::shared_ptr<WorkContext> context = nullptr;
            
            //_control_agent.start();
 
            bool failed = false;
 
            while((context = pop()) != nullptr) {
                while (_control_agent.get_status() == RUNTIME_WORK_QUEUE_PAUSED || _control_agent.get_status() == RUNTIME_WORK_QUEUE_STOPPED) {
                    if (!_paused)
                        _paused = true;
                }
 
                if (_paused == true)
                    _paused = false;
 
                if (_control_agent.get_status() == RUNTIME_WORK_QUEUE_CANCELLED) {
                    return false;
                }
 
                // break on execution failure.
                if (context->execute() == false) {
                    failed = true;
                    break;
                }
 
            }
            
            _queue.reset();
 
            if (failed == true) {
                _control_agent.failed();
                return false;
            }
 
            _control_agent.completed();
 
            return true;
        }

References _control_agent, _paused, _queue, Horizon::System::RuntimeContext::WorkControlAgent::completed(), Horizon::System::RuntimeContext::WorkControlAgent::failed(), Horizon::System::RuntimeContext::WorkControlAgent::get_status(), pop(), Horizon::System::RUNTIME_WORK_QUEUE_CANCELLED, Horizon::System::RUNTIME_WORK_QUEUE_PAUSED, and Horizon::System::RUNTIME_WORK_QUEUE_STOPPED.

Referenced by Horizon::System::RuntimeContext::run().

Here is the call graph for this function:

Here is the caller graph for this function:

push()

void Horizon::System::RuntimeContext::WorkQueueManager::push ( std::shared_ptr< WorkContext >  seg )

inline

{ _queue.push(std::move(seg)); }

References _queue.

Referenced by Horizon::System::RuntimeContext::push().

Here is the caller graph for this function:

Member Data Documentation

_control_agent

WorkControlAgent& Horizon::System::RuntimeContext::WorkQueueManager::_control_agent

Referenced by process().

_paused

std::atomic<bool> Horizon::System::RuntimeContext::WorkQueueManager::_paused {false}

Referenced by is_paused(), and process().

_queue

boost::lockfree::spsc_queue<std::shared_ptr<WorkContext>, boost::lockfree::capacity<100> > Horizon::System::RuntimeContext::WorkQueueManager::_queue

Referenced by pop(), process(), and push().

---

The documentation for this class was generated from the following file:

• src/Server/Common/System.hpp