gui/src/session/GraphDataEngine.h

   1 #ifndef AESALON_GUI_SESSION_GRAPH_DATA_ENGINE_H
   2 #define AESALON_GUI_SESSION_GRAPH_DATA_ENGINE_H
   3
   4 #include <QMutex>
   5 #include <QObject>
   6 #include <QQueue>
   7
   8 #include "DataRequest.h"
   9 #include "GraphData.h"
  10 #include "DataThread.h"
  11
  12 class RenderThread;
  13
  14 class GraphDataEngine : public QObject { Q_OBJECT
  15 private:
  16     QMutex queue_mutex;
  17     QQueue<DataRequest *> data_request_queue;
  18
  19     QList<GraphData *> graph_data;
  20     DataThread *data_thread;
  21 protected:
  22     virtual DataRequest *spawn_new_request(const Timestamp &timestamp) = 0;
  23 public:
  24     GraphDataEngine(QObject *parent, DataThread *data_thread);
  25     virtual ~GraphDataEngine();
  26
  27     /* NOTE: this function is called from outside the current thread. Hence the mutex. */
  28     void push_request(DataRequest *request) {
  29         QMutexLocker locker(&queue_mutex);
  30         data_request_queue.enqueue(request);
  31     }
  32     DataRequest *pop_request() {
  33         QMutexLocker locker(&queue_mutex);
  34         if(data_request_queue.isEmpty()) return NULL;
  35         return data_request_queue.dequeue();
  36     }
  37
  38     void add_data(GraphData *data) {
  39         graph_data.append(data);
  40     }
  41
  42     void request_data(RenderThread *thread, const Timestamp &timestamp);
  43
  44     void handle_requests();
  45 };
  46
  47 #endif