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

Timestamp:

Aug 19, 2008, 11:36:54 AM (16 years ago)

Author:

zdenek

Message:

Zdenek Lukes: a) added logic for RTCM 2.3 messages 20/21 decoding

b) added logic for cycle slip flags (slip counters or lock time indicators) handling

File:

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

trunk/BNC/bncgetthread.cpp

@@ -40 +40 @@
 
 #include <stdlib.h>
+#include <iomanip>
 
 #include <QFile>
@@ -144 +145 @@
     _rnx = new bncRinex(_staID, mountPoint, format, latitude, longitude, nmea);
   }
+  _rnx_set_position = false;
 
   msleep(100); //sleep 0.1 sec
@@ -160 +162 @@
   }
   delete _decoder;
-  delete _rnx;    
+  delete _rnx;
 }
 
@@ -369 +371 @@
     if      (_format.indexOf("RTCM_2") != -1) {
       emit(newMessage("Get Data: " + _staID + " in RTCM 2.x format"));
-      _decoder = new RTCM2Decoder();
+      _decoder = new RTCM2Decoder(_staID.data());
     }
     else if (_format.indexOf("RTCM_3") != -1) {
@@ -560 +562 @@
 
         delete [] data;
-        
+
         QListIterator<p_obs> it(_decoder->_obsList);
         while (it.hasNext()) {
@@ -648 +650 @@
           // ------------
           if (_rnx) {
-             long iSec    = long(floor(obs->_o.GPSWeeks+0.5));
-             long newTime = obs->_o.GPSWeek * 7*24*3600 + iSec;
-            if (_samplingRate == 0 || iSec % _samplingRate == 0) {
-              _rnx->deepCopy(obs);
+            bool dump = true;
+
+            ////RTCM2Decoder* decoder2 = dynamic_cast<RTCM2Decoder*>(_decoder);
+            ////if ( decoder2 && !_rnx_set_position ) {
+            ////  double stax, stay, staz;
+            ////  if ( decoder2->getStaCrd(stax, stay, staz) == success ) {
+            ////        _rnx->setApproxPos(stax, stay, staz);
+            ////        _rnx_set_position = true;
+            ////  }
+            ////  else {
+            ////        dump = false;
+            ////  }
+            ////}
+              
+            if ( dump ) {
+              long iSec    = long(floor(obs->_o.GPSWeeks+0.5));
+              long newTime = obs->_o.GPSWeek * 7*24*3600 + iSec;
+              if (_samplingRate == 0 || iSec % _samplingRate == 0) {
+                _rnx->deepCopy(obs);
+              }
+              _rnx->dumpEpoch(newTime);
             }
-            _rnx->dumpEpoch(newTime);
-          }
-
+          }
+
+          // Emit new observation signal
+          // ---------------------------
           bool firstObs = (obs == _decoder->_obsList.first());
           obs->_status = t_obs::posted;
@@ -757 +777 @@
   }
 }
+
+//
+//////////////////////////////////////////////////////////////////////////////
+void bncGetThread::slotNewEphGPS(gpsephemeris gpseph) {
+  RTCM2Decoder* decoder = dynamic_cast<RTCM2Decoder*>(_decoder);
+
+  if ( decoder ) {
+    QMutexLocker locker(&_mutex);
+  
+    decoder->storeEph(gpseph);
+  }
+}
+