Changeset 160 in ntrip for trunk/BNC

Timestamp:

Sep 12, 2006, 8:39:13 PM (18 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bnccaster.cpp (modified) (4 diffs)
• bncrinex.cpp (modified) (4 diffs)
• bncrinex.h (modified) (1 diff)

trunk/BNC/bnccaster.cpp

@@ -83 +83 @@
   long newTime = obs->GPSWeek * 7*24*3600 + obs->GPSWeeks;
 
+  // Rename the Station
+  // ------------------
+  strncpy(obs->StatID, staID.constData(),sizeof(obs->StatID));
+        
+  // Prepare RINEX Output
+  // --------------------
+  if (_rinexWriters.find(obs->StatID) == _rinexWriters.end()) {
+    _rinexWriters.insert(obs->StatID, new bncRinex(obs->StatID));
+  }
+  bncRinex* rnx = _rinexWriters.find(obs->StatID).value();
+  rnx->deepCopy(obs);
+  rnx->dumpEpoch(newTime);
+
   // First time, set the _lastDumpSec immediately
   // --------------------------------------------
@@ -98 +111 @@
   }
 
-  // Rename the station and save the observation
-  // -------------------------------------------
-  strncpy(obs->StatID, staID.constData(),sizeof(obs->StatID));
+  // Save the observation
+  // --------------------
   _epochs->insert(newTime, obs);
 
@@ -196 +208 @@
           }
         }
-        
-        // Prepare RINEX Output
-        // --------------------
-        if (_rinexWriters.find(obs->StatID) == _rinexWriters.end()) {
-          _rinexWriters.insert(obs->StatID, new bncRinex(obs->StatID));
-        }
-        bncRinex* rnx = _rinexWriters.find(obs->StatID).value();
-        rnx->deepCopy(obs);
       }
 
@@ -210 +214 @@
       first = false;
     }
-
-    // Write RINEX Files
-    // -----------------
-    QMapIterator<QString, bncRinex*> ir(_rinexWriters);
-    while (ir.hasNext()) {
-      bncRinex* rnx = ir.next().value();
-      rnx->dumpEpoch();
-    }
-  }
-}
+  }
+}

trunk/BNC/bncrinex.cpp

@@ -260 +260 @@
 // Write One Epoch into the RINEX File
 ////////////////////////////////////////////////////////////////////////////
-void bncRinex::dumpEpoch() {
+void bncRinex::dumpEpoch(long maxTime) {
+
+  // Select observations older than maxTime
+  // --------------------------------------
+  QList<Observation*> dumpList;
+  QMutableListIterator<Observation*> mIt(_obs);
+  while (mIt.hasNext()) {
+    Observation* ob = mIt.next();
+    if (ob->GPSWeek * 7*24*3600 + ob->GPSWeeks < maxTime) {
+      dumpList.push_back(ob);
+      mIt.remove();
+    }
+  }
 
   // Easy Return
   // -----------
-  if (_obs.isEmpty()) {
+  if (dumpList.isEmpty()) {
     return;
   }
@@ -270 +282 @@
   // Time of Epoch
   // -------------
-  Observation* firstObs = *_obs.begin();
+  Observation* firstObs = *dumpList.begin();
 
   QDateTime datTim = dateAndTimeFromGPSweek( firstObs->GPSWeek,
@@ -290 +302 @@
 
   _out << datTim.toString(" yy MM dd hh mm ss.zzz0000").toAscii().data()
-       << "  " << 0 << setw(3)  << _obs.size();
-
-  QListIterator<Observation*> it(_obs); int iSat = 0;
+       << "  " << 0 << setw(3)  << dumpList.size();
+
+  QListIterator<Observation*> it(dumpList); int iSat = 0;
   while (it.hasNext()) {
     iSat++;
@@ -320 +332 @@
 
   _out.flush();
-  _obs.clear();
 }
 

trunk/BNC/bncrinex.h

@@ -17 +17 @@
    ~bncRinex();
    void deepCopy(const Observation* obs);
-   void dumpEpoch();
+   void dumpEpoch(long maxTime);
 
  private: