Changeset 8418 in ntrip for branches/BNC_2.12/src/bncgetthread.cpp

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

File:

• branches/BNC_2.12/src/bncgetthread.cpp (modified) (3 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);