qt/sphere-orbit-camera-gui/workerthread.cpp

   1 #include <cstdlib>
   2 #include <iostream>
   3 #include <QDebug>
   4
   5 #include "workerthread.h"
   6
   7 WorkerThread::WorkerThread(QObject *parent)
   8     : QThread(parent)
   9 {
  10     qDebug("WorkerThread::WorkerThread()");
  11
  12     // Initialize random generator here
  13     srand(time(NULL));
  14
  15     // Make thread work forever by default
  16     abort = false;
  17
  18     // At this point the class hasn't been fully initialized.
  19     // The user must call setFileName(), before run()'ing.
  20 }
  21
  22 WorkerThread::~WorkerThread()
  23 {
  24     qDebug("WorkerThread::~WorkerThread()");
  25
  26     m_mutex.lock();
  27     abort = true;
  28     condition.wakeOne();
  29     m_mutex.unlock();
  30
  31     m_file.close();
  32
  33     wait();
  34 }
  35
  36 void WorkerThread::run(void)
  37 {
  38     float r;
  39
  40     qDebug("WorkerThread::run()");
  41
  42     // Loop
  43     while (!abort) {
  44         m_mutex.lock();
  45         if (m_data.size() >= 6667) {
  46             qDebug("BLOCKED");
  47             condition.wait(&m_mutex);
  48             m_mutex.unlock();
  49         }
  50         else {
  51             qDebug("Reading from file");
  52             in >> r;
  53             m_data.enqueue(r);
  54             m_mutex.unlock();
  55         }
  56     }
  57 }
  58
  59 void WorkerThread::setFileName(QString fileName)
  60 {
  61     qDebug("WorkerThread::setFileName()");
  62
  63     // Close old file
  64     m_file.close();
  65
  66     // Caution: discard all old data in QQueue
  67     // Worst case scenario if you don't: frame read corruption
  68     m_data.clear();
  69
  70     // Open new one
  71     m_file.setFileName(fileName);
  72     m_file.open(QIODevice::ReadOnly);
  73     in.setDevice(&m_file);
  74     extractFileHeader();
  75 }
  76
  77 quint32 WorkerThread::getMagicVersion(void) const
  78 {
  79     qDebug("WorkerThread::getMagicVersion()");
  80
  81     return m_magicVersion;
  82 }
  83
  84 quint32 WorkerThread::getProtocolVersion(void) const
  85 {
  86     qDebug("WorkerThread::getProtocolVersion()");
  87
  88     return m_protocolVersion;
  89 }
  90
  91 float WorkerThread::getDuration(void) const
  92 {
  93     qDebug("WorkerThread::getDuration()");
  94
  95     return m_duration;
  96 }
  97
  98 quint32 WorkerThread::getNumOfRecords(void) const
  99 {
 100     qDebug("WorkerThread::getNumOfRecords()");
 101
 102     return m_numOfRecords;
 103 }
 104
 105 void WorkerThread::extractFileHeader(void)
 106 {
 107     qDebug("WorkerThread::extractFileHeader()");
 108
 109     in >> m_magicVersion;
 110     //Q_ASSERT(m_magicVersion == 0xA0B0C0D0);
 111
 112     in >> m_protocolVersion;
 113     //Q_ASSERT(m_protocolVersion == 0x1);
 114
 115     in >> m_duration;
 116     in >> m_numOfRecords;
 117
 118     // qDebug() adds an extra space between items,
 119     // plus a new line in the last one.
 120     qDebug() << "Magic version =" << hex << m_magicVersion;
 121     qDebug() << "Protocol version =" << m_protocolVersion;
 122     qDebug() << "Duration in msec = " << m_duration;
 123     qDebug() << "Number of records ="  << m_numOfRecords;
 124 }