Changeset 10031 in ntrip

Timestamp:

Apr 14, 2023, 11:56:49 AM (12 months ago)

Author:

stuerze

Message:

minor changes

Location:

trunk/BNC/src/PPP

Files:

• pppClient.cpp (modified) (5 diffs)
• pppClient.h (modified) (2 diffs)
• pppFilter.cpp (modified) (6 diffs)
• pppParlist.cpp (modified) (7 diffs)

trunk/BNC/src/PPP/pppClient.cpp

@@ -474 +474 @@
     bool epochReProcessing = false;
     _numEpoProcessing = 0;
-    _historicalRefSats.clear();
+    if (!_historicalRefSats.isEmpty()) {
+      _historicalRefSats.clear();
+    }
 
     do {
-      _numEpoProcessing++;
+      if ((_numEpoProcessing++) > 30) {
+        LOG << "t_pppClient::processEpoch:  _numEpoProcessing > 30" << endl;
+        return finish(failure,12);
+      }
+
       if (_obsPool->refSatChanged()) {
         if(_filter->datumTransformation(_refSatMap) != success) {
@@ -488 +494 @@
         }
       }
+
       // Prepare Observations of the Rover
       // ---------------------------------
@@ -538 +545 @@
       LOG << "PUT EPOCH t_pppClient::processEpoch " << _epoTimeRover.timestr().c_str() << endl;
 #endif
-      
+
       // Process Epoch in Filter
       // -----------------------
@@ -552 +559 @@
         LOG << "pppClient: _obsPool->refSatChangeRequired() " << endl;
         epochReProcessing = true;
-#ifdef BNC_DEBUG_PPP        
+#ifdef BNC_DEBUG_PPP
         LOG <<  "DELETE EPOCH" << endl;
-#endif        
+#endif
         _obsPool->deleteLastEpoch();
         _filter->restoreState(0);
@@ -585 +592 @@
     return finish(failure,11);
   }
-  return finish(success,12);
+  return finish(success,0);
 }
 

trunk/BNC/src/PPP/pppClient.h

@@ -38 +38 @@
   const bncAntex*     antex() const {return _antex;}
   const t_pppStation* staRover() const {return _staRover;}
-  double              offGlo() const {return _offGlo;}
-  double              offGal() const {return _offGal;}
-  double              offBds() const {return _offBds;}
 
   std::ostringstream& log() {return *_log;}
@@ -77 +74 @@
   bncAntex*                 _antex;
   t_pppFilter*              _filter;
-  double                    _offGlo;
-  double                    _offGal;
-  double                    _offBds;
   std::vector<t_pppSatObs*> _obsRover;
   QMap<char, t_pppRefSat*>  _refSatMap;

trunk/BNC/src/PPP/pppFilter.cpp

@@ -95 +95 @@
   // Status Vector, Variance-Covariance Matrix
   // -----------------------------------------
-  ColumnVector xFltOld = _xFlt;
+  ColumnVector    xFltOld = _xFlt;
   SymmetricMatrix QFltOld = _QFlt;
   setStateVectorAndVarCovMatrix(xFltOld, QFltOld, setNeuNoiseToZero);
@@ -467 +467 @@
         // -----------------------
         else {
-          ColumnVector AA(nPar);
-          for (unsigned iPar = 0; iPar < nPar; iPar++) {
-            const t_pppParam *par = params[iPar];
-            AA[iPar] = par->partial(_epoTime, obs, tLC, refPrn);
-          }
-          double ll = obs->obsValue(tLC) - obs->cmpValue(tLC)
-                    - DotProduct(_x0, AA);
-          double vv = DotProduct(AA, _xFlt) - ll;
-          if (fabs(vv) > SLIP) {
-            LOG << epoTimeStr << " cycle slip detected " << t_lc::toString(tLC)
-                << ' ' << obs->prn().toString() << ' ' << setw(8)
-                << setprecision(4) << vv << endl;
-            if (preProcessing) {
-              _obsPool->setRefSatChangeRequired(sys, true);
-            } else {
+          if (!preProcessing) {
+            ColumnVector AA(nPar);
+            for (unsigned iPar = 0; iPar < nPar; iPar++) {
+              const t_pppParam *par = params[iPar];
+              AA[iPar] = par->partial(_epoTime, obs, tLC, refPrn);
+            }
+            double ll = obs->obsValue(tLC) - obs->cmpValue(tLC)
+                      - DotProduct(_x0, AA);
+            double vv = DotProduct(AA, _xFlt) - ll;
+            if (fabs(vv) > SLIP) {
+              LOG << epoTimeStr << " cycle slip detected " << t_lc::toString(tLC)
+                  << ' ' << obs->prn().toString() << ' ' << setw(8)
+                  << setprecision(4) << vv << endl;
               resetAmb(obs->prn(), obsVector, tLC);
             }
@@ -682 +680 @@
 #ifdef BNC_DEBUG_PPP
     LOG << "GET LAST EPOCH" << endl;
-#endif    
+#endif
   if (!epoch) {
     LOG << "t_pppFilter::datumTransformation: !lastEpoch" << endl;
@@ -688 +686 @@
   }
   _epoTime = epoch->epoTime();
- 
+
   LOG.setf(ios::fixed);
   LOG  << "DATUM TRANSFORMATION in Epoch  "<<  string(_epoTime) << endl;
@@ -785 +783 @@
   }
 
-  ColumnVector xFltOld = _xFlt;
+  ColumnVector    xFltOld = _xFlt;
   SymmetricMatrix QFltOld = _QFlt;
 
@@ -821 +819 @@
   // =================
   _datumTrafo->switchAA();
-  
+
   _obsPool->putEpoch(_epoTime, allObs, pseudoObsIono, refSatMap);
-#ifdef BNC_DEBUG_PPP  
+#ifdef BNC_DEBUG_PPP
   LOG << "PUT EPOCH t_pppFilter::datumTransformation " << _epoTime.timestr().c_str() << endl;
 #endif

trunk/BNC/src/PPP/pppParlist.cpp

@@ -506 +506 @@
           (!par->lastObsTime().valid() || (epoTime - par->lastObsTime() > 0.0))) {
 #ifdef BNC_DEBUG_PPP
-//        LOG << "remove1 " << par->toString() << std::endl;
+        //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         lostSats.append(par->prn());
@@ -519 +519 @@
                 par->type() == t_pppParam::pBiasG2) && !usedSystems().contains('G')) {
 #ifdef BNC_DEBUG_PPP
-        //LOG << "remove1 " << par->toString() << std::endl;
+       //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         delete par;
@@ -529 +529 @@
                 par->type() == t_pppParam::pBiasR2) && !usedSystems().contains('R')) {
 #ifdef BNC_DEBUG_PPP
-//        LOG << "remove1 " << par->toString() << std::endl;
+        //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         delete par;
@@ -539 +539 @@
                 par->type() == t_pppParam::pBiasE2) && !usedSystems().contains('E')) {
 #ifdef BNC_DEBUG_PPP
-//        LOG << "remove1 " << par->toString() << std::endl;
+        //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         delete par;
@@ -549 +549 @@
                 par->type() == t_pppParam::pBiasC2) && !usedSystems().contains('C')) {
 #ifdef BNC_DEBUG_PPP
-//        LOG << "remove1 " << par->toString() << std::endl;
+        //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         delete par;
@@ -566 +566 @@
           (lostSats.contains(par->prn()) || (epoTime - par->lastObsTime() > 0.0))) {
 #ifdef BNC_DEBUG_PPP
-        //LOG << "remove1 " << par->toString() << std::endl;
+       //LOG << "remove1 " << par->toString() << std::endl;
 #endif
         delete par;
@@ -741 +741 @@
     else {
 #ifdef BNC_DEBUG_PPP
-//      LOG << "push_back  parReq " << parReq->toString() << std::endl;
+      //LOG << "push_back  parReq " << parReq->toString() << std::endl;
 #endif
       _params.push_back(parReq);