Changeset 6099 in ntrip for trunk/BNC/src/PPP_free/pppClient.cpp

Timestamp:

Sep 8, 2014, 8:36:22 AM (10 years ago)

Author:

mervart

Message:

 

File:

• trunk/BNC/src/PPP_free/pppClient.cpp (modified) (10 diffs)

trunk/BNC/src/PPP_free/pppClient.cpp

@@ -45 +45 @@
 #include "pppClient.h"
 #include "pppFilter.h"
-#include "pppOptions.h"
+#include "bncephuser.h"
 #include "bncutils.h"
-#include "bncconst.h"
 
 using namespace BNC_PPP;
@@ -64 +63 @@
 // Constructor
 ////////////////////////////////////////////////////////////////////////////
-t_pppClient::t_pppClient(const t_pppOptions* opt) : bncEphUser(false) {
+t_pppClient::t_pppClient(const t_pppOptions* opt) {
 
   _opt     = new t_pppOptions(*opt);
@@ -70 +69 @@
   _epoData = new t_epoData();
   _log     = new ostringstream();
+  _ephUser = new bncEphUser(false);
   _staID   = QByteArray(_opt->_roverName.c_str());
 
@@ -81 +81 @@
   delete _epoData;
   delete _opt;
+  delete _ephUser;
   delete _log;
 }
@@ -87 +88 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_pppClient::processEpoch(const vector<t_satObs*>& satObs, t_output* output) {
-  QMutexLocker locker(&_mutex);
   
   // Convert and store observations
@@ -176 +176 @@
       int channel = 0;
       if (satData->system() == 'R') {
-        if (_eph.contains(satData->prn)) {
-          t_eph* eLast =_eph.value(satData->prn)->last;
-          channel = eLast->slotNum();
+        const bncEphUser::t_ephPair* ephPair = _ephUser->ephPair(satData->prn);
+        if (ephPair) {
+          channel = ephPair->last->slotNum();
         }
         else {
@@ -229 +229 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_pppClient::putOrbCorrections(const std::vector<t_orbCorr*>& corr) {
-  QMutexLocker locker(&_mutex);
   for (unsigned ii = 0; ii < corr.size(); ii++) {
     QString prn = QString(corr[ii]->_prn.toString().c_str());
-    if (_eph.contains(prn)) {
-      t_eph* eLast = _eph.value(prn)->last;
-      t_eph* ePrev = _eph.value(prn)->prev;
+    const bncEphUser::t_ephPair* ephPair = _ephUser->ephPair(prn);
+    if (ephPair) {
+      t_eph* eLast = ephPair->last;
+      t_eph* ePrev = ephPair->prev;
       if      (eLast && eLast->IOD() == corr[ii]->_iod) {
         eLast->setOrbCorr(corr[ii]);
@@ -248 +248 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_pppClient::putClkCorrections(const std::vector<t_clkCorr*>& corr) {
-  QMutexLocker locker(&_mutex);
   for (unsigned ii = 0; ii < corr.size(); ii++) {
     QString prn = QString(corr[ii]->_prn.toString().c_str());
-    if (_eph.contains(prn)) {
-      t_eph* eLast = _eph.value(prn)->last;
-      t_eph* ePrev = _eph.value(prn)->prev;
+    const bncEphUser::t_ephPair* ephPair = _ephUser->ephPair(prn);
+    if (ephPair) {
+      t_eph* eLast = ephPair->last;
+      t_eph* ePrev = ephPair->prev;
       if      (eLast && eLast->IOD() == corr[ii]->_iod) {
         eLast->setClkCorr(corr[ii]);
@@ -276 +276 @@
   const t_ephGal* ephGal = dynamic_cast<const t_ephGal*>(eph);
   if      (ephGPS) {
-    putNewEph(new t_ephGPS(*ephGPS));
+    _ephUser->putNewEph(new t_ephGPS(*ephGPS));
   }
   else if (ephGlo) {
-    putNewEph(new t_ephGlo(*ephGlo));
+    _ephUser->putNewEph(new t_ephGlo(*ephGlo));
   }
   else if (ephGal) {
-    putNewEph(new t_ephGal(*ephGal));
+    _ephUser->putNewEph(new t_ephGal(*ephGal));
   }
 }
@@ -290 +290 @@
 t_irc t_pppClient::getSatPos(const bncTime& tt, const QString& prn, 
                               ColumnVector& xc, ColumnVector& vv) {
-  if (_eph.contains(prn)) {
-    t_eph* eLast = _eph.value(prn)->last;
-    t_eph* ePrev = _eph.value(prn)->prev;
+
+  const bncEphUser::t_ephPair* ephPair = _ephUser->ephPair(prn);
+  if (ephPair) {
+    t_eph* eLast = ephPair->last;
+    t_eph* ePrev = ephPair->prev;
     if      (eLast && eLast->getCrd(tt, xc, vv, _opt->useOrbClkCorr()) == success) {
       return success;