Changeset 8418 in ntrip

Timestamp:

Jul 13, 2018, 1:14:56 PM (6 years ago)

Author:

stuerze

Message:

some changes to allow 10 Hz observation data real-time processing

Location:

branches/BNC_2.12/src

Files:

• bncgetthread.cpp (modified) (3 diffs)
• bncgetthread.h (modified) (1 diff)
• bncrinex.cpp (modified) (1 diff)
• bnctime.cpp (modified) (4 diffs)
• bncutils.cpp (modified) (2 diffs)

branches/BNC_2.12/src/bncgetthread.cpp

@@ -53 +53 @@
 #include "bnccore.h"
 #include "bncutils.h"
+#include "bnctime.h"
 #include "bnczerodecoder.h"
 #include "bncnetqueryv0.h"
@@ -620 +621 @@
         if (!_rawFile) {
           QString prn(obs._prn.toString().c_str());
-          long iSec = long(floor(obs._time.gpssec() + 0.5));
-          long obsTime = obs._time.gpsw() * 7 * 24 * 3600 + iSec;
-          QMap<QString, long>::const_iterator it = _prnLastEpo.find(prn);
+          bncTime obsTime = obs._time;
+          QMap<QString, bncTime>::const_iterator it = _prnLastEpo.find(prn);
           if (it != _prnLastEpo.end()) {
-            long oldTime = it.value();
+            bncTime oldTime = it.value();
             if (obsTime < oldTime) {
-              emit(newMessage(_staID + ": old observation " + prn.toAscii(),
-                  false));
+              emit(newMessage(_staID + ": old observation " + prn.toLatin1(), false));
               continue;
             } else if (obsTime == oldTime) {
-              emit(newMessage(
-                  _staID + ": observation coming more than once "
-                      + prn.toAscii(), false));
+              emit(newMessage(_staID + ": observation coming more than once "
+                              + prn.toLatin1(), false));
               continue;
             }
@@ -638 +636 @@
           _prnLastEpo[prn] = obsTime;
         }
+
 
         decoder()->dumpRinexEpoch(obs, _format);

branches/BNC_2.12/src/bncgetthread.h

@@ -138 +138 @@
    bool                       _rawOutput;
    bool                       _latencycheck;
-   QMap<QString, long>        _prnLastEpo;
+   QMap<QString, bncTime>     _prnLastEpo;
    QMap<char, QVector<QString> > _rnxTypes;
    QStringList                _gloSlots;

branches/BNC_2.12/src/bncrinex.cpp

@@ -496 +496 @@
   // -------------
   const t_satObs& fObs = obsList.first();
-  QDateTime datTimNom  = dateAndTimeFromGPSweek(fObs._time.gpsw(), floor(fObs._time.gpssec()+0.5));
+  QDateTime datTimNom  = dateAndTimeFromGPSweek(fObs._time.gpsw(), fObs._time.gpssec());
 
   // Close the file

branches/BNC_2.12/src/bnctime.cpp

@@ -6 +6 @@
 #include <sstream>
 #include <iomanip>
+#include <iostream>
 
 #include "bnctime.h"
@@ -82 +83 @@
   if(msec/1000.0 < sec - 86400.0)
     ++week;
-  return set(week, msec/1000.0);
+  return set(week, double(msec/1000.0));
 }
 
@@ -118 +119 @@
   intsec = sec;
   updatetime(&week, &intsec, msec, 0); /* Moscow -> GPS */
-  sec = intsec+(msec%1000)/1000.0;
+  sec = intsec+double((msec%1000)/1000.0);
   return set(week, sec);
 }
@@ -132 +133 @@
     msec -= 7*24*60*60*1000;
   currentGPSWeeks(week, sec);
-  if(msec/1000.0 < sec - 86400.0)
+  if((msec/1000.0) < (sec - 86400.0)) {
     ++week;
-  return set(week, msec/1000.0);
-}
-
+  }
+  return set(week, double(msec/1000.0));
+}
 // 
 //////////////////////////////////////////////////////////////////////////////

branches/BNC_2.12/src/bncutils.cpp

@@ -251 +251 @@
 bool checkForWrongObsEpoch(bncTime obsEpoch) {
   const double maxDt = 600.0;
-  long iSec    = long(floor(obsEpoch.gpssec()+0.5));
-  long obsTime = obsEpoch.gpsw()*7*24*3600 + iSec;
+  bncTime obsTime = obsEpoch;
   int    week;
   double sec;
   currentGPSWeeks(week, sec);
-  long currTime = week * 7*24*3600 + long(sec);
+  bncTime currTime(week, sec);
 
   if (fabs(currTime - obsTime) > maxDt) {
@@ -575 +574 @@
   const ColumnVector& yi, // vector of the initial y-values
   double dx,              // the step size for the integration
-  double* acc,            // aditional acceleration
+  double* acc,            // additional acceleration
   ColumnVector (*der)(double x, const ColumnVector& y, double* acc)
                           // A pointer to a function that computes the