prioqueue.hpp

#ifndef QOS_CPP_PRIO_QUEUE
#define QOS_CPP_PRIO_QUEUE
 
#include "include/types.hpp"
#include "include/task.hpp"
 
namespace qOS {
 
    namespace pq {
        struct queueStack_t {
            task *pTask{ nullptr };
            void *qData{ nullptr };
        };
    }
 
    class prioQueue {
        private:
            volatile base_t index{ -1 };
            void *data{ nullptr };
            pq::queueStack_t *stack{ nullptr };
            size_t size{ 0U };
            void clearIndex( const index_t indexToClear ) noexcept;
            prioQueue( prioQueue const& ) = delete;
            void operator=( prioQueue const& ) = delete;
        protected:
            prioQueue() = delete;
            virtual ~prioQueue() {}
            prioQueue( pq::queueStack_t *area, const size_t pq_size ) noexcept;
            size_t count( void ) const noexcept;
            task* get( void ) noexcept;
            bool isTaskInside( const task &Task ) const noexcept;
            bool insert( task &Task, void *pData ) noexcept;
            void cleanUp( const task &Task ) noexcept;
            inline bool hasElements( void ) const noexcept
            {
                return ( index >= 0 );
            }
        friend class core; /*only core can use this class*/
    };
 
}
 
#endif /*QOS_CPP_PRIO_QUEUE*/