QseFileReader Class Reference

#include <qsefilereader.h>

Inheritance diagram for QseFileReader:

[legend]

Collaboration diagram for QseFileReader:

[legend]

List of all members.

Public Types
typedef QThread	inherited
Public Slots
void	openFile (QString fileName)
void	appendFile (QString fileName)
Public Member Functions
	QseFileReader (const QString &name, QObject *parent=0)
	~QseFileReader ()
QseInputFile *	inputFile ()
void	startWait ()
Protected Member Functions
void	run ()
Private Attributes
QString	m_Name
QseInputFile *	m_Data
QMutex	m_Mutex
QWaitCondition	m_Started
QWaitCondition	m_NewFile
bool	m_Abort
bool	m_Restart
QStringList	m_FileNames
int	m_Changed

---

Detailed Description

Definition at line 15 of file qsefilereader.h.

---

Member Typedef Documentation

typedef QThread QseFileReader::inherited

Definition at line 23 of file qsefilereader.h.

---

Constructor & Destructor Documentation

QseFileReader::QseFileReader	(	const QString &	name,
		QObject *	parent = 0
	)

Definition at line 8 of file qsefilereader.cpp.

References m_Mutex, and m_Started.

  : inherited(parent),
    m_Name(name),
    m_Data(NULL),
    m_Abort(false),
    m_Restart(false),
    m_Changed(false)
{
//   printf("file reader constructed\n");

  m_Mutex.lock();

  start();

  m_Started.wait(&m_Mutex);
  m_Mutex.unlock();
}

QseFileReader::~QseFileReader

(

)

Definition at line 26 of file qsefilereader.cpp.

References m_Abort, m_Mutex, and m_NewFile.

{
  quit();

  m_Mutex.lock();
  m_Abort = true;
  m_Mutex.unlock();

  m_NewFile.wakeOne();

  wait();
}

---

Member Function Documentation

QseInputFile * QseFileReader::inputFile

(

)

Definition at line 129 of file qsefilereader.cpp.

References m_Data, and m_Mutex.

Referenced by QseDataFlow::run().

{
  QMutexLocker lock(&m_Mutex);

  return m_Data;
}

void QseFileReader::startWait

(

)

Definition at line 39 of file qsefilereader.cpp.

References m_Mutex, and m_Started.

{
  m_Mutex.lock();
  start();

  m_Started.wait(&m_Mutex);
  m_Mutex.unlock();
}

void QseFileReader::openFile

(

QString

fileName

)

[slot]

Definition at line 48 of file qsefilereader.cpp.

References m_FileNames, m_Mutex, m_NewFile, and m_Restart.

{
  m_Mutex.lock();

  m_FileNames.clear();
  m_FileNames.append(fileName);
  m_Restart = true;

  m_Mutex.unlock();

  m_NewFile.wakeOne();
}

void QseFileReader::appendFile

(

QString

fileName

)

[slot]

Definition at line 61 of file qsefilereader.cpp.

References m_FileNames, m_Mutex, and m_NewFile.

{
  m_Mutex.lock();

  m_FileNames.append(fileName);

  m_Mutex.unlock();

  m_NewFile.wakeOne();
}

void QseFileReader::run

(

)

[protected]

Definition at line 72 of file qsefilereader.cpp.

References QseDataSet::emitLoadCompleted(), m_Abort, m_Changed, m_Data, m_FileNames, m_Mutex, m_Name, m_NewFile, m_Restart, and m_Started.

{
  m_Mutex.lock();
  m_Data = new QseInputFile(m_Name);
  m_Mutex.unlock();

  m_Started.wakeOne();

  m_Mutex.lock();
  m_NewFile.wait(&m_Mutex);
  m_Mutex.unlock();

//   printf("CurrentThread: %p ReaderThread: %p DataSetThread: %p\n",
//   QThread::currentThread(), this->thread(), m_Data->thread());

  forever {
    m_Mutex.lock();
    int atend = m_Data -> atEnd();
    int nfiles = m_FileNames.size();
    m_Mutex.unlock();

    if (m_Abort)   return;

    m_Mutex.lock();

    if (m_Restart || atend) {
      if (m_Restart) {
  m_Data -> clear();
  m_Restart = false;
  m_Changed = true;
      }

      if (nfiles) {
  QString nextFile = m_FileNames.takeFirst();
//  printf("next data file\n");

  m_Data -> nextDataFile(nextFile);
  m_Changed = true;
      } else {
  if (m_Changed) {
    m_Data->emitLoadCompleted();
    m_Changed = false;
  }

  m_NewFile.wait(&m_Mutex, 1000);
      }
    } else if (!atend) {
      m_Data -> nextInputLine();
      m_Changed = true;
    }

    m_Mutex.unlock();
  }

  delete m_Data;
}

Here is the call graph for this function:

---

Member Data Documentation

QString QseFileReader::m_Name [private]

Definition at line 36 of file qsefilereader.h.

Referenced by run().

QseInputFile* QseFileReader::m_Data [private]

Definition at line 37 of file qsefilereader.h.

Referenced by inputFile(), and run().

QMutex QseFileReader::m_Mutex [private]

Definition at line 38 of file qsefilereader.h.

Referenced by appendFile(), inputFile(), openFile(), QseFileReader(), run(), startWait(), and ~QseFileReader().

QWaitCondition QseFileReader::m_Started [private]

Definition at line 39 of file qsefilereader.h.

Referenced by QseFileReader(), run(), and startWait().

QWaitCondition QseFileReader::m_NewFile [private]

Definition at line 40 of file qsefilereader.h.

Referenced by appendFile(), openFile(), run(), and ~QseFileReader().

bool QseFileReader::m_Abort [private]

Definition at line 41 of file qsefilereader.h.

Referenced by run(), and ~QseFileReader().

bool QseFileReader::m_Restart [private]

Definition at line 42 of file qsefilereader.h.

Referenced by openFile(), and run().

QStringList QseFileReader::m_FileNames [private]

Definition at line 43 of file qsefilereader.h.

Referenced by appendFile(), openFile(), and run().

int QseFileReader::m_Changed [private]

Definition at line 44 of file qsefilereader.h.

Referenced by run().

---

The documentation for this class was generated from the following files:

• qsefilereader.h
• qsefilereader.cpp