Horizon::System::RuntimeContext::WorkControlAgent Class Reference

#include <System.hpp>

Public Member Functions
bool	start ()
bool	stop ()
bool	pause ()
bool	cancel ()
bool	completed ()
bool	failed ()
runtime_work_queue_status	get_status ()

Public Attributes
std::atomic< enum runtime_work_queue_status >	_status {RUNTIME_WORK_QUEUE_NOT_STARTED}

Member Function Documentation

cancel()

bool Horizon::System::RuntimeContext::WorkControlAgent::cancel ( )

inline

        {
            runtime_work_queue_status status = get_status();
 
            if (status == RUNTIME_WORK_QUEUE_CANCELLED)
                return false;
 
            _status.store(RUNTIME_WORK_QUEUE_CANCELLED);
            return true;
        }

References _status, get_status(), and Horizon::System::RUNTIME_WORK_QUEUE_CANCELLED.

Here is the call graph for this function:

completed()

bool Horizon::System::RuntimeContext::WorkControlAgent::completed ( )

inline

        {
            runtime_work_queue_status status = get_status();
 
            if (status == RUNTIME_WORK_QUEUE_COMPLETED)
                return false;
            
            _status.store(RUNTIME_WORK_QUEUE_COMPLETED);
            return true;
        }

References _status, get_status(), and Horizon::System::RUNTIME_WORK_QUEUE_COMPLETED.

Referenced by Horizon::System::RuntimeContext::WorkQueueManager::process().

Here is the call graph for this function:

Here is the caller graph for this function:

failed()

bool Horizon::System::RuntimeContext::WorkControlAgent::failed ( )

inline

        {
            runtime_work_queue_status status = get_status();
 
            if (status == RUNTIME_WORK_QUEUE_FAILED)
                return false;
 
            _status.store(RUNTIME_WORK_QUEUE_FAILED);
            return true;
        }

References _status, get_status(), and Horizon::System::RUNTIME_WORK_QUEUE_FAILED.

Referenced by Horizon::System::RuntimeContext::WorkQueueManager::process().

Here is the call graph for this function:

Here is the caller graph for this function:

get_status()

runtime_work_queue_status Horizon::System::RuntimeContext::WorkControlAgent::get_status ( )

inline

{ return _status.load(); }

References _status.

Referenced by cancel(), completed(), failed(), pause(), Horizon::System::RuntimeContext::WorkQueueManager::process(), start(), and stop().

Here is the caller graph for this function:

pause()

bool Horizon::System::RuntimeContext::WorkControlAgent::pause ( )

inline

        {
            runtime_work_queue_status status = get_status();
 
            if (status == RUNTIME_WORK_QUEUE_FAILED || status == RUNTIME_WORK_QUEUE_COMPLETED)
                return false;
 
            _status.store(RUNTIME_WORK_QUEUE_PAUSED);
            return true;
        }

References _status, get_status(), Horizon::System::RUNTIME_WORK_QUEUE_COMPLETED, Horizon::System::RUNTIME_WORK_QUEUE_FAILED, and Horizon::System::RUNTIME_WORK_QUEUE_PAUSED.

Here is the call graph for this function:

start()

bool Horizon::System::RuntimeContext::WorkControlAgent::start ( )

inline

        {
            runtime_work_queue_status status = get_status();
 
            if (status > RUNTIME_WORK_QUEUE_NOT_STARTED)
                return false;
 
            _status.store(RUNTIME_WORK_QUEUE_STARTED);
            return true;
        }

References _status, get_status(), Horizon::System::RUNTIME_WORK_QUEUE_NOT_STARTED, and Horizon::System::RUNTIME_WORK_QUEUE_STARTED.

Here is the call graph for this function:

stop()

bool Horizon::System::RuntimeContext::WorkControlAgent::stop ( )

inline

        { 
            runtime_work_queue_status status = get_status();
            runtime_work_queue_status stop = RUNTIME_WORK_QUEUE_STOPPED; 
 
            if (status == RUNTIME_WORK_QUEUE_FAILED || status == RUNTIME_WORK_QUEUE_COMPLETED || status == stop)
                return false;
 
            _status.store(stop);
 
             return true;
        }

References _status, get_status(), Horizon::System::RUNTIME_WORK_QUEUE_COMPLETED, Horizon::System::RUNTIME_WORK_QUEUE_FAILED, Horizon::System::RUNTIME_WORK_QUEUE_STOPPED, and stop().

Referenced by stop().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

_status

std::atomic<enum runtime_work_queue_status> Horizon::System::RuntimeContext::WorkControlAgent::_status {RUNTIME_WORK_QUEUE_NOT_STARTED}

Referenced by cancel(), completed(), failed(), get_status(), pause(), start(), and stop().

---

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

• src/Server/Common/System.hpp