qsedataflow.cpp

Go to the documentation of this file.

#include "qsedataflow.h"

#include "qsefilereader.h"
#include "qseaveragerrole.h"
#include "qseaverager.h"
#include "qsedataset.h"
#include "qseinputfile.h"
#include "qsedatadeglitcher.h"
#include "qsenormalizer.h"
#include "qseedgealigner.h"
#include "qsescanaverager.h"

QseDataFlow::QseDataFlow(QObject *parent)
  : QThread(parent),
    m_InputReader(NULL),
    m_InputData(NULL),
    m_Deglitcher(NULL),
    m_DeglitchedData(NULL),
    m_Normalizer(NULL),
    m_NormalizedData(NULL),
    m_EdgeAligner(NULL),
    m_AlignedData(NULL),
    m_ScanAverager(NULL),
    m_AveragedData(NULL),

    m_TotalDataSet(NULL),
    m_Averager(NULL),
    m_AveragerRole(NULL),
    m_NormalizedDataSet(NULL),
    m_AveragedDataSet(NULL)
{
  m_Mutex.lock();

//   printf("Starting...\n");

  start();

//   printf("Waiting...\n");

  m_Wait.wait(&m_Mutex);

//   printf("Woken...\n");

  m_Mutex.unlock();
}

QseDataFlow::~QseDataFlow()
{
  delete m_InputReader;
  delete m_TotalDataSet;
  delete m_NormalizedDataSet;
  delete m_AveragedDataSet;
  delete m_AveragerRole;
  delete m_Averager;
}

// QseInputFile* QseDataFlow::inputDataSet()
// {
//   return m_InputDataSet;
// }

// QseDataSet*      QseDataFlow::totalDataSet()
// {
//   return m_TotalDataSet;
// }

// QseDataSet*      QseDataFlow::normalizedDataSet()
// {
//   return m_NormalizedDataSet;
// }

// QseDataSet*      QseDataFlow::averagedDataSet()
// {
//   return m_AveragedDataSet;
// }

// QseAveragerRole* QseDataFlow::averagerRole()
// {
//   return m_Role;
// }

// QseAverager*     QseDataFlow::averager()
// {
//   return m_Averager;
// }

// QseFileReader*   QseDataFlow::inputFileReader()
// {
//   return m_InputReader;
// }

void QseDataFlow::run()
{
  m_Mutex.lock();

  m_InputReader       = new QseFileReader("input", NULL);
  m_InputData         = m_InputReader->inputFile();

  m_DeglitchedData    = new QseDataSet("deglitched", NULL);
  m_NormalizedData    = new QseDataSet("norm", NULL);
  m_AlignedData       = new QseDataSet("aligned", NULL);
  m_AveragedData      = new QseDataSet("avg", NULL);

  m_Deglitcher        = new QseDataDeglitcher(m_InputData,
                m_DeglitchedData,
                "deglitcher",
                NULL);

  m_Normalizer        = new QseNormalizer(m_DeglitchedData,
            m_NormalizedData,
            "normalizer",
            NULL);

  m_EdgeAligner       = new QseEdgeAligner(m_NormalizedData,
             m_AlignedData,
             "aligner",
             NULL);

  m_ScanAverager      = new QseScanAverager(m_AlignedData,
              m_AveragedData,
              "averager",
              NULL);

  m_AveragerRole      = new QseAveragerRole();
  m_Averager          = new QseAverager();

  m_TotalDataSet      = new QseDataSet("total");
  m_NormalizedDataSet = new QseDataSet("norm");
  m_AveragedDataSet   = new QseDataSet("avg");

  m_Mutex.unlock();

  m_Wait.wakeOne();

  exec();
}

---