gui/src/session/DataThread.h

   1 #ifndef AESALON_GUI_SESSION_DATA_THREAD_H
   2 #define AESALON_GUI_SESSION_DATA_THREAD_H
   3
   4 #include <QThread>
   5 #include <QTimer>
   6 #include <QQueue>
   7
   8 #include "storage/SnapshotList.h"
   9 #include "data/DataSource.h"
  10 #include "DataRequest.h"
  11
  12 class DataThread : public QThread { Q_OBJECT
  13 private:
  14     DataSource *data_source;
  15     DataReceiver *data_receiver;
  16
  17     SnapshotList snapshot_list;
  18     Snapshot *current_snapshot;
  19     QTimer *snapshot_timer;
  20     QQueue<DataRequest *> request_list;
  21 public:
  22     DataThread(QObject *parent, DataSource *data_source);
  23     virtual ~DataThread();
  24 private slots:
  25     void event_received(Event *event);
  26     void create_new_snapshot();
  27     void no_more_data();
  28 protected:
  29     virtual void run();
  30 };
  31
  32 #endif