qseinputfile.cpp

Go to the documentation of this file.

#include "qseinputfile.h"

QseInputFile::QseInputFile(const QString& name, QObject *parent)
  : QseDataSet(name, parent),
    m_Buffer(NULL),
    m_Length(0),
    m_BufferSize(0),    
    m_PathName(""),
    m_File(),

    m_NLines(0),
    m_MaxLength(0),
    m_Scan(NULL),
    m_NPoints(0)
{
  m_Buffer = (char*) malloc(250001);
  m_Length = 0;
  m_BufferSize = 250000;
}

QseInputFile::~QseInputFile()
{
  QMutexLocker lock(&m_Mutex);

  if (m_Buffer) {
    free(m_Buffer);
  }
}

QString QseInputFile::filePath()
{
  QMutexLocker lock(&m_Mutex);

  return m_PathName;
}

void QseInputFile::emitDataChanged()
{
  printf("emitDataChanged()\n");

  emit dataChanged();
}

void QseInputFile::updateProgress()
{
  QMutexLocker lock(&m_Mutex);

  qint64 sz = m_File.size();
  qint64 pz = m_File.pos();

  double pct = ((double) pz)/((double) sz)*100.0;

  emit madeProgress((int) pct);

  //  QApplication::processEvents();
}

void QseInputFile::nextDataFile(QString nm)
{
  QMutexLocker lock(&m_Mutex);

  if (m_File.isOpen()) {
    m_File.close();
  }
  
  m_PathName = nm;
  m_File.setFileName(m_PathName);
  m_File.open(QIODevice::ReadOnly);
  m_NLines = 0;
  m_MaxLength = 0;
  m_Length = 0;
  m_Scan = NULL;
  m_NPoints = 0;

  setFileName(nm);
}

bool QseInputFile::atEnd()
{
  QMutexLocker lock(&m_Mutex);

  if (m_File.isOpen()) {
    qint64 sz = m_File.size();
    qint64 pz = m_File.pos();
    
    return pz>=sz;
  } else{
//     printf("atEnd on closed file\n");
    return true;
  }
}

void QseInputFile::nextInputLine()
{
  QMutexLocker lock(&m_Mutex);

  int lnth = m_File.readLine(m_Buffer+m_Length, m_BufferSize-m_Length);
  bool lineended = false;

  while (lnth > 0 && (m_Buffer[lnth-1]=='\n' || m_Buffer[lnth-1]=='\r')) {
    m_Buffer[lnth-1]=0;
    lnth--;
    lineended = true;
  }

  m_Length += lnth;

  if (lineended) {
    m_NLines++;

    if (m_Length > m_MaxLength) {
      m_MaxLength = m_Length;
    }

    if (strncasecmp(m_Buffer, "#S", 2) == 0) {
      int ns = scanCount();
      // printf("Scan Added %d\n", ns);
      
      m_Scan = appendScan();
      m_Scan -> setName(m_Buffer);
      
      int sn;
      if (sscanf(m_Buffer, "#S%d", &sn)==1) {
  m_Scan -> setScanNumber(sn);
      }

      m_NPoints = 0;
      updateProgress();
      
//       printf("Scan Added %d\n", ns);

      emit scanAdded(ns);
      emit message(QString("Loading scan %1 of file %2").arg(scanCount()).arg(m_PathName));
    } else if (strncasecmp(m_Buffer, "#N", 2) == 0) {
      int nc;
    
      if (m_Scan && (sscanf(m_Buffer, "#N%d", &nc) == 1)) {
  m_Scan -> setColumnCount(nc);
      }
    } else if (strncasecmp(m_Buffer, "#L", 2) == 0) {
      if (m_Scan) {
  m_Scan -> setColumnNames(m_Buffer);
//  emit scanAdded(scanCount()-1);
      }
    } else if (strncasecmp(m_Buffer, "#D", 2) == 0) {
      QDateTime dt = QDateTime::fromString(m_Buffer+2);

      if (dt.isValid()) {
//  printf("Valid date %s\n", m_Buffer+2);
//  printf(" == %s\n", qPrintable(dt.toString("yyyyMMdd_hhmmss")));

  if (m_Scan) {
    m_Scan -> setScanDateTime(dt);
  }
      }
    }
  
    if (strncasecmp(m_Buffer, "#", 1) == 0) {
      if (m_Scan) {
  m_Scan -> appendHeader(m_Buffer);
      } else {
  appendHeader(m_Buffer);
      }
    } else {
      if (m_Scan) {
  //      printf("Append: <%s>\n", l);
  m_Scan -> appendData(m_Buffer);
  m_NPoints++;
      } else {
  appendHeader(m_Buffer);
      }
    }
    
    if (atEnd()) {
      emit madeProgress(110);
      emit message(QString("File %1 scanned, %2 lines, longest %3")
       .arg(m_PathName).arg(m_NLines).arg(m_MaxLength));
      emit message(QString("%1 scans found\n").arg(scanCount()));
      
      emit loadCompleted();
    }

    m_Length = 0;
  }
}

---