2023-05-11 23:24:01 +00:00
|
|
|
#ifndef CACHINGQUEUE_H
|
|
|
|
#define CACHINGQUEUE_H
|
|
|
|
#include <QCoreApplication>
|
|
|
|
#include <QObject>
|
|
|
|
#include <QThread>
|
|
|
|
#include <QMutex>
|
|
|
|
#include <QMutexLocker>
|
2023-05-15 09:53:52 +00:00
|
|
|
#include <QMap>
|
2023-05-11 23:24:01 +00:00
|
|
|
#include <QMultiMap>
|
|
|
|
#include <QVariant>
|
2023-05-15 09:53:52 +00:00
|
|
|
#include <QQueue>
|
2023-05-11 23:24:01 +00:00
|
|
|
#include <QRect>
|
|
|
|
#include <QWaitCondition>
|
2023-05-15 09:53:52 +00:00
|
|
|
#include <QDateTime>
|
2023-05-24 18:50:01 +00:00
|
|
|
#include <QRandomGenerator>
|
2023-05-11 23:24:01 +00:00
|
|
|
|
|
|
|
#include "wfviewtypes.h"
|
2023-05-15 09:53:52 +00:00
|
|
|
#include "rigidentities.h"
|
2023-05-11 23:24:01 +00:00
|
|
|
|
|
|
|
enum queuePriority {
|
|
|
|
// Use prime numbers for priority, so that each queue is processed
|
|
|
|
priorityNone=0, priorityImmediate=1, priorityHighest=2, priorityHigh=3, priorityMediumHigh=5, priorityMedium=7, priorityMediumLow=11, priorityLow=19, priorityLowest=23
|
|
|
|
};
|
|
|
|
|
2024-02-09 17:08:04 +00:00
|
|
|
inline QMap<QString,int> priorityMap = {{"None",0},{"Immediate",1},{"Highest",2},{"High",3},{"Medium High",5},{"Medium",7},{"Medium Low",11},{"Low",19},{"Lowest",23}};
|
2023-05-11 23:24:01 +00:00
|
|
|
|
|
|
|
// Command with no param is a get by default
|
|
|
|
struct queueItem {
|
2023-06-05 08:27:37 +00:00
|
|
|
queueItem () {}
|
2024-03-30 20:40:27 +00:00
|
|
|
queueItem (funcs command, QVariant param, bool recurring, uchar receiver) : command(command), param(param), receiver(receiver), recurring(recurring){};
|
|
|
|
queueItem (funcs command, QVariant param, bool recurring) : command(command), param(param), receiver(false), recurring(recurring){};
|
|
|
|
queueItem (funcs command, QVariant param) : command(command), param(param),receiver(0), recurring(false){};
|
|
|
|
queueItem (funcs command, bool recurring, uchar receiver) : command(command), param(QVariant()), receiver(receiver), recurring(recurring) {};
|
|
|
|
queueItem (funcs command, bool recurring) : command(command), param(QVariant()), receiver(0), recurring(recurring) {};
|
|
|
|
queueItem (funcs command) : command(command), param(QVariant()), receiver(0), recurring(false){};
|
2023-06-05 08:27:37 +00:00
|
|
|
funcs command;
|
|
|
|
QVariant param;
|
2024-03-30 20:40:27 +00:00
|
|
|
uchar receiver;
|
2023-06-05 08:27:37 +00:00
|
|
|
bool recurring;
|
2023-08-07 21:11:14 +00:00
|
|
|
qint64 id = QDateTime::currentMSecsSinceEpoch();
|
2023-05-11 23:24:01 +00:00
|
|
|
};
|
|
|
|
|
2023-05-15 09:53:52 +00:00
|
|
|
struct cacheItem {
|
|
|
|
cacheItem () {};
|
2024-03-30 20:40:27 +00:00
|
|
|
cacheItem (funcs command, QVariant value, uchar receiver=0) : command(command), req(QDateTime()), reply(QDateTime()), value(value), receiver(receiver){};
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-06-05 08:27:37 +00:00
|
|
|
funcs command;
|
|
|
|
QDateTime req;
|
|
|
|
QDateTime reply;
|
|
|
|
QVariant value;
|
2024-03-30 20:40:27 +00:00
|
|
|
uchar receiver;
|
2023-05-15 09:53:52 +00:00
|
|
|
};
|
|
|
|
|
2023-05-11 23:24:01 +00:00
|
|
|
class cachingQueue : public QThread
|
|
|
|
{
|
|
|
|
Q_OBJECT
|
|
|
|
|
|
|
|
signals:
|
2024-03-30 20:40:27 +00:00
|
|
|
void haveCommand(funcs func, QVariant param, uchar receiver);
|
2023-05-15 09:53:52 +00:00
|
|
|
void sendValue(cacheItem item);
|
2024-04-30 08:42:54 +00:00
|
|
|
void sendMessage(QString msg);
|
2023-07-06 09:36:11 +00:00
|
|
|
void cacheUpdated(cacheItem item);
|
2023-12-18 10:47:16 +00:00
|
|
|
void rigCapsUpdated(rigCapabilities* caps);
|
2023-05-15 09:53:52 +00:00
|
|
|
|
|
|
|
public slots:
|
|
|
|
// Can be called directly or via emit.
|
2024-03-30 20:40:27 +00:00
|
|
|
void receiveValue(funcs func, QVariant value, uchar receiver);
|
2023-05-11 23:24:01 +00:00
|
|
|
|
|
|
|
private:
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-05-11 23:24:01 +00:00
|
|
|
static cachingQueue *instance;
|
2023-05-15 11:34:24 +00:00
|
|
|
static QMutex instanceMutex;
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-05-15 10:15:35 +00:00
|
|
|
QMutex mutex;
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-05-11 23:24:01 +00:00
|
|
|
QMultiMap <queuePriority,queueItem> queue;
|
2023-06-05 08:27:37 +00:00
|
|
|
QMultiMap<funcs,cacheItem> cache;
|
2023-05-15 09:53:52 +00:00
|
|
|
QQueue<cacheItem> items;
|
2024-04-30 08:42:54 +00:00
|
|
|
QQueue<QString> messages;
|
2023-05-11 23:24:01 +00:00
|
|
|
|
|
|
|
// Command to set cache value
|
2024-03-30 20:40:27 +00:00
|
|
|
void setCache(funcs func, QVariant val, uchar receiver=0);
|
|
|
|
queuePriority isRecurring(funcs func, uchar receiver=0);
|
2023-07-06 09:36:11 +00:00
|
|
|
bool compare(QVariant a, QVariant b);
|
2023-05-15 09:53:52 +00:00
|
|
|
|
|
|
|
|
|
|
|
// Various other values
|
2023-05-15 10:15:35 +00:00
|
|
|
bool aborted=false;
|
2023-05-11 23:24:01 +00:00
|
|
|
QWaitCondition waiting;
|
2024-05-20 13:35:36 +00:00
|
|
|
qint64 queueInterval=-1; // Don't start the timer!
|
2023-12-18 10:47:16 +00:00
|
|
|
|
|
|
|
rigCapabilities* rigCaps = Q_NULLPTR; // Must be NULL until a radio is connected
|
|
|
|
|
2023-05-15 09:53:52 +00:00
|
|
|
// Functions
|
|
|
|
void run();
|
2024-03-30 20:40:27 +00:00
|
|
|
funcs checkCommandAvailable(funcs cmd, bool set=false);
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-05-11 23:24:01 +00:00
|
|
|
protected:
|
|
|
|
cachingQueue(QObject* parent = Q_NULLPTR) : QThread(parent) {};
|
|
|
|
~cachingQueue();
|
|
|
|
|
|
|
|
public:
|
|
|
|
cachingQueue(cachingQueue &other) = delete;
|
|
|
|
void operator=(const cachingQueue &) = delete;
|
|
|
|
|
|
|
|
static cachingQueue *getInstance(QObject* parent = Q_NULLPTR);
|
|
|
|
void message(QString msg);
|
2024-03-30 20:40:27 +00:00
|
|
|
void add(queuePriority prio ,funcs func, bool recurring=false, uchar receiver=0);
|
2023-05-15 09:53:52 +00:00
|
|
|
void add(queuePriority prio,queueItem item);
|
2024-03-30 20:40:27 +00:00
|
|
|
void addUnique(queuePriority prio ,funcs func, bool recurring=false, uchar receiver=0);
|
2023-05-15 09:53:52 +00:00
|
|
|
void addUnique(queuePriority prio,queueItem item);
|
2024-03-30 20:40:27 +00:00
|
|
|
void del(funcs func, uchar receiver=0);
|
2023-05-11 23:24:01 +00:00
|
|
|
void clear();
|
2024-05-20 13:35:36 +00:00
|
|
|
void interval(qint64 val);
|
|
|
|
qint64 interval() {return queueInterval;}
|
2023-06-05 08:27:37 +00:00
|
|
|
void updateCache(bool reply, queueItem item);
|
2024-03-30 20:40:27 +00:00
|
|
|
void updateCache(bool reply, funcs func, QVariant value=QVariant(), uchar receiver=0);
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2024-03-30 20:40:27 +00:00
|
|
|
cacheItem getCache(funcs func, uchar receiver=0);
|
2023-05-15 09:53:52 +00:00
|
|
|
|
2023-06-05 08:27:37 +00:00
|
|
|
QMultiMap<funcs,cacheItem> getCacheItems();
|
2023-05-15 09:53:52 +00:00
|
|
|
QMultiMap <queuePriority,queueItem> getQueueItems();
|
2023-07-06 09:36:11 +00:00
|
|
|
void lockMutex() {mutex.lock();}
|
|
|
|
void unlockMutex() {mutex.unlock();}
|
2024-03-25 12:42:08 +00:00
|
|
|
void setRigCaps(rigCapabilities* caps) { if (rigCaps != caps) { rigCaps = caps; emit rigCapsUpdated(rigCaps);} }
|
2023-12-18 10:47:16 +00:00
|
|
|
rigCapabilities* getRigCaps() { return rigCaps; }
|
2023-05-11 23:24:01 +00:00
|
|
|
};
|
|
|
|
|
2023-05-15 13:32:46 +00:00
|
|
|
Q_DECLARE_METATYPE(queueItem)
|
|
|
|
Q_DECLARE_METATYPE(cacheItem)
|
2023-05-11 23:24:01 +00:00
|
|
|
#endif // CACHINGQUEUE_H
|