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