OrderedQueue.h

// Copyright (c) Qualcomm Technologies, Inc. and/or its subsidiaries.
// SPDX-License-Identifier: BSD-3-Clause-Clear
 
#ifndef ORDERED_QUEUE_H
#define ORDERED_QUEUE_H
 
#include <iostream>
#include <queue>
#include <vector>
#include <mutex>
#include <condition_variable>
 
#include "Message.h"
#include "MemoryPool.h"
#include "Utils.h"
 
class OrderedQueue {
protected:
    int32_t mElementCount;
    std::mutex mOrderedQueueMutex;
    std::condition_variable mOrderedQueueCondition;
    int8_t lockStatus;
 
    struct QueueOrdering {
        int8_t operator() (Message* &a,  Message* &b) {
            return a->getPriority() > b->getPriority();
        }
    };
 
    std::priority_queue<Message*, std::vector<Message*>, QueueOrdering> mOrderedQueue;
 
public:
    OrderedQueue();
    ~OrderedQueue();
 
    int8_t addAndWakeup(Message* req);
 
    virtual void orderedQueueConsumerHook() = 0;
 
    Message* pop();
 
    void wait();
 
    int8_t hasPendingTasks();
 
    void forcefulAwake();
};
 
#endif