socg/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     m_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     m_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     qDebug("WorkerThread::run()");
  40
  41     // Loop
  42     while (!m_abort) {
  43         m_mutex.lock();
  44         if (m_data.size() >= 2007) {
  45             qDebug("BLOCKED");
  46             condition.wait(&m_mutex);
  47             m_mutex.unlock();
  48         }
  49         else {
  50             qDebug("Reading from file");
  51             in >> r;
  52             if (in.status() == QDataStream::ReadPastEnd) {
  53                 qDebug("Datastream has read past end");
  54                 m_abort = true;
  55                 m_mutex.unlock();
  56                 return;
  57             }
  58             m_data.enqueue(r);
  59             m_mutex.unlock();
  60         }
  61     }
  62 }
  63
  64 void WorkerThread::setFileName(QString fileName)
  65 {
  66     qDebug("WorkerThread::setFileName()");
  67
  68     // Close old file
  69     m_file.close();
  70
  71     // Caution: discard all old data in QQueue
  72     // Worst case scenario if you don't: frame read corruption
  73     m_data.clear();
  74
  75     // Open new file
  76     // XXX: toLatin1() segfaults
  77     m_file.setFileName(fileName);
  78     if (!m_file.open(QIODevice::ReadOnly)) {
  79         qDebug("Cannot open file name: %s", fileName.toLatin1());
  80         return;
  81     }
  82
  83     in.setDevice(&m_file);
  84     extractFileHeader();
  85 }
  86
  87 quint32 WorkerThread::getMagicVersion(void) const
  88 {
  89     qDebug("WorkerThread::getMagicVersion()");
  90
  91     return m_magicVersion;
  92 }
  93
  94 quint32 WorkerThread::getProtocolVersion(void) const
  95 {
  96     qDebug("WorkerThread::getProtocolVersion()");
  97
  98     return m_protocolVersion;
  99 }
 100
 101 float WorkerThread::getDurationInSec(void) const
 102 {
 103     qDebug("WorkerThread::getDurationInSec()");
 104
 105     return m_durationInSec;
 106 }
 107
 108 quint32 WorkerThread::getNumOfRecords(void) const
 109 {
 110     qDebug("WorkerThread::getNumOfRecords()");
 111
 112     return m_numOfRecords;
 113 }
 114
 115 void WorkerThread::extractFileHeader(void)
 116 {
 117     qDebug("WorkerThread::extractFileHeader()");
 118
 119     in >> m_magicVersion;
 120     //Q_ASSERT(m_magicVersion == 0xA0B0C0D0);
 121
 122     in >> m_protocolVersion;
 123     //Q_ASSERT(m_protocolVersion == 0x1);
 124
 125     in >> m_durationInSec;
 126     in >> m_numOfRecords;
 127
 128     // qDebug() adds an extra space between items,
 129     // plus a new line in the last one.
 130     qDebug() << "Magic version =" << hex << m_magicVersion;
 131     qDebug() << "Protocol version =" << m_protocolVersion;
 132     qDebug() << "Duration in sec = " << m_durationInSec;
 133     qDebug() << "Number of records ="  << m_numOfRecords;
 134 }