File indexing completed on 2024-12-22 04:17:22

 /***************************************************************************
                     stdinsource.cpp  -  data source for stdin
                              -------------------
     begin                : Fri Oct 31 2003
     copyright            : (C) 2003 The University of Toronto
     email                : netterfield@astro.utoronto.ca
  ***************************************************************************/
 
 /***************************************************************************
  *                                                                         *
  *   This program is free software; you can redistribute it and/or modify  *
  *   it under the terms of the GNU General Public License as published by  *
  *   the Free Software Foundation; either version 2 of the License, or     *
  *   (at your option) any later version.                                   *
  *                                                                         *
  ***************************************************************************/
 
 #include "kst_i18n.h"
 #include "config.h"
 #include "stdinsource.h"
 
 #include <QTemporaryFile>
 #include <QXmlStreamWriter>
 
 #include <stdlib.h>
 #include <unistd.h>
 
 #ifdef TIME_WITH_SYS_TIME
 # include <sys/time.h>
 # include <time.h>
 #else
 # ifdef HAVE_SYS_TIME_H
 #  include <sys/time.h>
 # else
 #  include <time.h>
 # endif
 #endif
 
 namespace Kst {
 
 const QString StdinSource::staticTypeString = I18N_NOOP("Stdin Data Source");
 
 StdinSource::StdinSource(ObjectStore *store, QSettings *cfg)
 : DataSource(store, cfg, "stdin", "stdin") {
   _file = new QTemporaryFile;
   _filename = _file->fileName();
   // Unfortunately we have to update here.  stdin is a special case.
   update();
   _src = DataSource::loadSource(this->store(), _filename, "ASCII");
   if (_src && _src->isValid()) {
     _valid = true;
   }
 }
 
 
 StdinSource::~StdinSource() {
   _file->close();
   delete _file;
   _file = 0L;
 }
 
 
 const QString& StdinSource::typeString() const {
   return staticTypeString;
 }
 
 
 Object::UpdateType StdinSource::internalDataSourceUpdate() {
   if (!_valid) {
     _src = DataSource::loadSource(store(), _filename, "ASCII");
     if (_src && _src->isValid()) {
       _valid = true;
     } else {
       return NoChange;
     }
   }
 
   fd_set rfds;
   struct timeval tv;
   int retval;
   char instr[4097];
   int i = 0;
   bool new_data = false;
   bool got_some = false;
 
   int handle = _file->handle();
   FILE *fp = fdopen(handle, "w+");
 
   if (!fp) {
     return Object::NO_CHANGE;
   }
 
   do {
     /* Watch stdin (fd 0) to see when it has input. */
     FD_ZERO(&rfds);
     FD_SET(0, &rfds);
     /* Wait up to 0 seconds. */
     tv.tv_sec = 0;
     tv.tv_usec = 0;
 
     retval = select(1, &rfds, NULL, NULL, &tv);
 
     new_data = false;
     if (retval > 0) {
       char *fgs = fgets(instr, 4096, stdin);
       if (fgs && fp) {
         got_some = true;
         fputs(instr, fp);
         new_data = true;
       }
     }
   } while (++i < 100000 && new_data);
 
   fclose(fp);
 
   if (got_some && _src) {
     return _src->update();
   }
   return NoChange;
 }
 
 
 int StdinSource::readField(double *v, const QString& field, int s, int n) {
   if (isValid()) {
     return _src->readField(v, field, s, n);
   }
   return -1;
 }
 
 
 bool StdinSource::isValidField(const QString& field) const {
   if (isValid()) {
     return _src->isValidField(field);
   }
   return false;
 }
 
 
 int StdinSource::samplesPerFrame(const QString& field) {
   if (isValid()) {
     return _src->samplesPerFrame(field);
   }
   return 0;
 }
 
 
 int StdinSource::frameCount(const QString& field) const {
   if (isValid()) {
     return _src->frameCount(field);
   }
   return 0;
 }
 
 
 QString StdinSource::fileType() const {
   if (isValid()) {
     return _src->fileType();
   }
   return QString::null;
 }
 
 
 void StdinSource::save(QXmlStreamWriter &s) {
   if (isValid()) {
     return _src->save(s);
   }
   DataSource::save(s);
 }
 
 
 bool StdinSource::isValid() const {
   return _valid && _src && _src->isValid();
 }
 
 
 bool StdinSource::isEmpty() const {
   return !isValid() || _src->isEmpty();
 }
 
 }
 // vim: ts=2 sw=2 et