Changeset 3209 in ntrip for trunk/BNC/upload/bncuploadcaster.cpp

Timestamp:

Mar 30, 2011, 8:39:39 PM (13 years ago)

Author:

mervart

Message:

 

File:

• trunk/BNC/upload/bncuploadcaster.cpp (modified) (5 diffs)

trunk/BNC/upload/bncuploadcaster.cpp

@@ -182 +182 @@
     _t0  = settings.value("trafo_t0").toDouble();
   }
- 
-  // Deep copy of ephemerides
-  // ------------------------
-  _ephMap = 0;
+
+  // Member that receives the ephemeris
+  // ----------------------------------
+  _ephUser = new bncEphUser();
 }
 
@@ -204 +204 @@
     wait();
   }
-  if (_ephMap) {
-    QMapIterator<QString, t_eph*> it(*_ephMap);
-    while (it.hasNext()) {
-      it.next();
-      t_eph* eph = it.value();
-      delete eph;
-    }
-    delete _ephMap;
-  }
   delete _outFile;
   delete _rnx;
   delete _sp3;
+  delete _ephUser;
 }
 
@@ -306 +298 @@
 // 
 ////////////////////////////////////////////////////////////////////////////
-void bncUploadCaster::decodeRtnetStream(char* buffer, int bufLen,
-                      const QMap<QString, bncEphUser::t_ephPair*>& ephPairMap) {
+void bncUploadCaster::decodeRtnetStream(char* buffer, int bufLen) {
                                         
   QMutexLocker locker(&_mutex);
-
-  // Delete old ephemeris
-  // --------------------
-  if (_ephMap) {
-    QMapIterator<QString, t_eph*> it(*_ephMap);
-    while (it.hasNext()) {
-      it.next();
-      t_eph* eph = it.value();
-      delete eph;
-    }
-    delete _ephMap;
-  }
-  _ephMap = new QMap<QString, t_eph*>;
-
-  // Make a deep copy of ephemeris
-  // -----------------------------
-  QMapIterator<QString, bncEphUser::t_ephPair*> it(ephPairMap);
-  while (it.hasNext()) {
-    it.next();
-    bncEphUser::t_ephPair* pair = it.value();
-    t_eph* ep = pair->last;
-    if (pair->prev && ep && 
-        ep->receptDateTime().secsTo(QDateTime::currentDateTime()) < 60) {
-      ep = pair->prev;
-    }
-    QString prn(ep->prn().c_str());
-    if      (prn[0] == 'G') {
-      t_ephGPS* epGPS = static_cast<t_ephGPS*>(ep);
-      (*_ephMap)[prn] = new t_ephGPS(*epGPS);
-    }
-    else if (prn[0] == 'R') {
-      t_ephGlo* epGlo = static_cast<t_ephGlo*>(ep);
-      (*_ephMap)[prn] = new t_ephGlo(*epGlo);
-    }
-    else if (prn[0] == 'E') {
-      t_ephGal* epGal = static_cast<t_ephGal*>(ep);
-      (*_ephMap)[prn] = new t_ephGal(*epGal);
-    }
-  }
 
   // Append to buffer
@@ -418 +370 @@
     }
 
-    if ( _ephMap->contains(prn) ) {
-      t_eph* ep = (*_ephMap)[prn];
+    const bncEphUser::t_ephPair* ephPair = _ephUser->ephPair(prn);
+    if (ephPair) {
+      t_eph* eph = ephPair->last;
+      if (ephPair->prev && 
+           eph->receptDateTime().secsTo(QDateTime::currentDateTime()) < 60) {
+        eph = ephPair->prev;
+      }
 
       in >> xx(1) >> xx(2) >> xx(3) >> xx(4) >> xx(5) 
@@ -448 +405 @@
       if (sd) {
         QString outLine;
-        processSatellite(ep, _epoTime.gpsw(), _epoTime.gpssec(), prn, xx, sd, outLine);
+        processSatellite(eph, _epoTime.gpsw(), _epoTime.gpssec(), prn, 
+                         xx, sd, outLine);
         if (_outFile) {
           _outFile->write(_epoTime.gpsw(), _epoTime.gpssec(), outLine);