Changeset 10038 in ntrip for trunk/BNC/src/combination/bnccomb.h

Timestamp:

May 10, 2023, 11:19:40 AM (12 months ago)

Author:

stuerze

Message:

minor changes

File:

• trunk/BNC/src/combination/bnccomb.h (modified) (9 diffs)

trunk/BNC/src/combination/bnccomb.h

@@ -4 +4 @@
 
 #include <fstream>
+#include <iostream>
 #include <map>
 #include <newmat.h>
+#include <deque>
 #include "bncephuser.h"
 #include "satObs.h"
@@ -20 +22 @@
  Q_OBJECT
  public:
-  bncComb();
   virtual ~bncComb();
   static bncComb* instance();
@@ -42 +43 @@
 
  private:
+  static bncComb* _instPtr;   // The one, single instance
+  bncComb();                  // private constructor
+  bncComb(const bncComb&);
+  bncComb& operator=(const bncComb&);
+
   enum e_method{singleEpoch, filter};
 
@@ -85 +91 @@
     cmbCorr() {
       _eph                        = 0;
+      _orbCorr                    = 0;
+      _clkCorr                    = 0;
+      _satCodeBias                = 0;
       _iod                        = 0;
       _dClkResult                 = 0.0;
       _satCodeBiasIF              = 0.0;
+      _weightFactor               = 1.0;
     }
     ~cmbCorr() {}
@@ -94 +104 @@
     unsigned long  _iod;
     t_eph*         _eph;
-    t_orbCorr      _orbCorr;
-    t_clkCorr      _clkCorr;
-    t_satCodeBias  _satCodeBias;
+    t_orbCorr*      _orbCorr;
+    t_clkCorr*      _clkCorr;
+    t_satCodeBias* _satCodeBias;
     QString        _acName;
     double         _satCodeBiasIF;
@@ -109 +119 @@
     cmbEpoch() {}
     ~cmbEpoch() {
+      clear();
+    }
+    void clear() {
       QVectorIterator<cmbCorr*> it(corrs);
       while (it.hasNext()) {
@@ -115 +128 @@
     }
     QVector<cmbCorr*> corrs;
+  };
+
+  class epoClkData {
+   public:
+    epoClkData() {}
+    ~epoClkData() {
+      for (unsigned ii = 0; ii < _clkCorr.size(); ii++) {
+        delete _clkCorr[ii];
+      }
+    }
+    bncTime                 _time;
+    std::vector<t_clkCorr*> _clkCorr;
   };
 
@@ -196 +221 @@
   };
 
-
-  void  processEpoch(char sys);
-  t_irc processEpoch_filter(char sys, QTextStream& out, QMap<QString, cmbCorr*>& resCorr,
-                            ColumnVector& dx);
-  t_irc processEpoch_singleEpoch(char sys, QTextStream& out, QMap<QString, cmbCorr*>& resCorr,
-                                 ColumnVector& dx);
+  void  processEpoch(bncTime epoTime, const std::vector<t_clkCorr*>& clkCorrVec);
+  void  processSystem(bncTime epoTime, char sys, QTextStream& out);
+  t_irc processEpoch_filter(bncTime epoTime, char sys, QTextStream& out, QMap<QString, cmbCorr*>& resCorr, ColumnVector& dx);
+  t_irc processEpoch_singleEpoch(bncTime epoTime, char sys, QTextStream& out, QMap<QString, cmbCorr*>& resCorr, ColumnVector& dx);
   t_irc createAmat(char sys, Matrix& AA, ColumnVector& ll, DiagonalMatrix& PP,
                    const ColumnVector& x0, QMap<QString, cmbCorr*>& resCorr);
-  void  dumpResults(const QMap<QString, cmbCorr*>& resCorr);
-  void  printResults(QTextStream& out, const QMap<QString, cmbCorr*>& resCorr);
+  void  dumpResults(bncTime epoTime, const QMap<QString, cmbCorr*>& resCorr);
+  void  printResults(bncTime epoTime, QTextStream& out, const QMap<QString, cmbCorr*>& resCorr);
   void  switchToLastEph(t_eph* lastEph, cmbCorr* corr);
-  t_irc checkOrbits(char sys, QTextStream& out);
-  QVector<cmbCorr*>& corrs(char sys) {return _buffer[sys][_resTime].corrs;}
+  t_irc checkOrbits(bncTime epoTime, char sys, QTextStream& out);
+  QVector<cmbCorr*>& corrs(char sys) {return _buffer[sys].corrs;}
 
   QMutex                                     _mutex;
   QList<cmbAC*>                              _ACs;
-  bncTime                                    _resTime;
+  std::deque<epoClkData*>                    _epoClkData;
+  bncTime                                    _lastClkCorrTime;
   QMap<char, QVector<cmbParam*>>             _params;
-  QMap<char, QMap<bncTime, cmbEpoch>>        _buffer;
+  QMap<char, cmbEpoch>                       _buffer;
   bncRtnetDecoder*                           _rtnetDecoder;
   QMap<char, SymmetricMatrix>                _QQ;
@@ -227 +251 @@
   int                                        _ms;
   QString                                    _cmbRefAttributes;
-  QMap<QString, QMap<t_prn, t_orbCorr> >     _orbCorrections;
-  QMap<QString, QMap<t_prn, t_satCodeBias> > _satCodeBiases;
+  QMap<QString, QMap<t_prn, t_orbCorr*> >     _orbCorrections;
+  QMap<QString, QMap<t_prn, t_satCodeBias*> > _satCodeBiases;
   bncEphUser                                 _ephUser;
   SsrCorr*                                   _ssrCorr;