Changeset 349 in ntrip

Timestamp:

Dec 12, 2006, 4:59:42 PM (18 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bnccaster.cpp (modified) (4 diffs)
• bnccaster.h (modified) (3 diffs)
• bncgetthread.cpp (modified) (4 diffs)
• bncgetthread.h (modified) (2 diffs)

trunk/BNC/bnccaster.cpp

@@ -114 +114 @@
 // New Observations
 ////////////////////////////////////////////////////////////////////////////
-void bncCaster::newObs(const QByteArray& staID, const QUrl& mountPoint,
-                       bool firstObs, Observation* obs,
-                       const QByteArray& format) {
+int bncCaster::newObs(const QByteArray& staID,
+                       bool firstObs, Observation* obs) {
 
   QMutexLocker locker(&_mutex);
@@ -128 +127 @@
   obs->StatID[sizeof(obs->StatID)-1] = '\0';
         
-  // Prepare RINEX Output
-  // --------------------
-  if (_rinexWriters.find(obs->StatID) == _rinexWriters.end()) {
-    _rinexWriters.insert(obs->StatID, new bncRinex(obs->StatID, 
-                                                   mountPoint, format));
-  }
-  bncRinex* rnx = _rinexWriters.find(obs->StatID).value();
-  if (_samplingRate == 0 || iSec % _samplingRate == 0) {
-    rnx->deepCopy(obs);
-  }
-  rnx->dumpEpoch(newTime);
-
   // First time, set the _lastDumpSec immediately
   // --------------------------------------------
@@ -158 +145 @@
     }
     delete obs;
-    return;
+    return 1;
   }
 
@@ -172 +159 @@
     _lastDumpSec = newTime - _waitTime;
   }
+
+  return 0;
 }
 

trunk/BNC/bnccaster.h

@@ -32 +32 @@
 
 #include "RTCM/GPSDecoder.h"
-#include "bncrinex.h"
 
 class bncGetThread;
@@ -44 +43 @@
    void addGetThread(bncGetThread* getThread);
    int  numStations() const {return _staIDs.size();}
-   void newObs(const QByteArray& staID, const QUrl& mountPoint,
-               bool firstObs, Observation* obs, const QByteArray& format);
+   int  newObs(const QByteArray& staID, bool firstObs, Observation* obs);
 
  signals:
@@ -66 +64 @@
    QList<QTcpSocket*>*            _sockets;
    QList<QByteArray>              _staIDs;
-   QMap<QString, bncRinex*>       _rinexWriters;
    QList<bncGetThread*>           _threads;
    int                            _samplingRate;

trunk/BNC/bncgetthread.cpp

@@ -49 +49 @@
 #include "bnctabledlg.h"
 #include "bncapp.h"
+#include "bncutils.h"
 
 #include "RTCM/RTCM2Decoder.h"
@@ -60 +61 @@
 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
+  _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;
 
   // Check name conflict
@@ -87 +89 @@
     }
   }
+
+  _samplingRate = settings.value("rnxSampl").toInt();
 
   if (num > 0) {
@@ -288 +292 @@
         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());
-          _global_caster->newObs(_staID, _mountPoint, firstObs, *it, _format);
+          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);
+          }
+
+
         }
         _decoder->_obsList.clear();

trunk/BNC/bncgetthread.h

@@ -32 +32 @@
 #include "RTCM/GPSDecoder.h"
 #include "bncconst.h"
+#include "bncrinex.h"
 
 class bncGetThread : public QThread {
@@ -68 +69 @@
    int         _nextSleep;
    int         _iMount;
+   int         _samplingRate;
+   bncRinex*   _rinexWriter;
 };