Changeset 350 in ntrip for trunk/BNC/bncgetthread.cpp

Timestamp:

Dec 13, 2006, 10:43:39 AM (17 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncgetthread.cpp (modified) (4 diffs)

trunk/BNC/bncgetthread.cpp

@@ -49 +49 @@
 #include "bnctabledlg.h"
 #include "bncapp.h"
-#include "bncutils.h"
 
 #include "RTCM/RTCM2Decoder.h"
@@ -61 +60 @@
 bncGetThread::bncGetThread(const QUrl& mountPoint, 
                            const QByteArray& format, int iMount) {
-  _decoder     = 0;
-  _mountPoint  = mountPoint;
-  _staID       = mountPoint.path().mid(1).toAscii();
-  _staID_orig  = _staID;
-  _format      = format;
-  _socket      = 0;
-  _timeOut     = 20*1000;  // 20 seconds
-  _nextSleep   =  1;       //  1 second
-  _iMount      = iMount;   // index in mountpoints array
-  _rinexWriter = 0;
+  _decoder    = 0;
+  _mountPoint = mountPoint;
+  _staID      = mountPoint.path().mid(1).toAscii();
+  _staID_orig = _staID;
+  _format     = format;
+  _socket     = 0;
+  _timeOut    = 20*1000;  // 20 seconds
+  _nextSleep  =  1;       //  1 second
+  _iMount     = iMount;   // index in mountpoints array
 
   // Check name conflict
@@ -89 +87 @@
     }
   }
-
-  _samplingRate = settings.value("rnxSampl").toInt();
 
   if (num > 0) {
@@ -292 +288 @@
         for (list<Observation*>::iterator it = _decoder->_obsList.begin(); 
              it != _decoder->_obsList.end(); it++) {
-
-          // Check observation epoch
-          // -----------------------
-          int    week;
-          double sec;
-          currentGPSWeeks(week, sec);
-          
-          const double secPerWeek = 7.0 * 24.0 * 3600.0;
-          const double maxDt      = 600.0;            
-
-          if (week < (*it)->GPSWeek) {
-            week += 1;
-            sec  -= secPerWeek;
-          }
-          if (week > (*it)->GPSWeek) {
-            week -= 1;
-            sec  += secPerWeek;
-          }
-          double dt = fabs(sec - (*it)->GPSWeeks);
-          if (week != (*it)->GPSWeek || dt > maxDt) {
-            emit( newMessage("Wrong observation epoch") );
-            delete (*it);
-            continue;
-          }
-
           emit newObs(_staID, *it);
           bool firstObs = (it == _decoder->_obsList.begin());
-          if ( _global_caster->newObs(_staID, firstObs, *it) == 0 ) {
-
-            if (_rinexWriter == 0) {
-              _rinexWriter = new bncRinex((*it)->StatID, _mountPoint, _format);
-            }
-
-            long iSec    = long(floor((*it)->GPSWeeks+0.5));
-            long newTime = (*it)->GPSWeek * 7*24*3600 + iSec;
-
-            if (_samplingRate == 0 || iSec % _samplingRate == 0) {
-              _rinexWriter->deepCopy(*it);
-            }
-            _rinexWriter->dumpEpoch(newTime);
-          }
-
-
+          _global_caster->newObs(_staID, _mountPoint, firstObs, *it, _format);
         }
         _decoder->_obsList.clear();