Changeset 350 in ntrip for trunk/BNC/bnccaster.cpp

Timestamp:

Dec 13, 2006, 10:43:39 AM (17 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bnccaster.cpp (modified) (4 diffs)

trunk/BNC/bnccaster.cpp

@@ -114 +114 @@
 // New Observations
 ////////////////////////////////////////////////////////////////////////////
-int bncCaster::newObs(const QByteArray& staID,
-                       bool firstObs, Observation* obs) {
+void bncCaster::newObs(const QByteArray& staID, const QUrl& mountPoint,
+                       bool firstObs, Observation* obs,
+                       const QByteArray& format) {
 
   QMutexLocker locker(&_mutex);
@@ -127 +128 @@
   obs->StatID[sizeof(obs->StatID)-1] = '\0';
         
+  // Prepare RINEX Output
+  // --------------------
+  if (_rinexWriters.find(obs->StatID) == _rinexWriters.end()) {
+    _rinexWriters.insert(obs->StatID, new bncRinex(obs->StatID, 
+                                                   mountPoint, format));
+  }
+  bncRinex* rnx = _rinexWriters.find(obs->StatID).value();
+  if (_samplingRate == 0 || iSec % _samplingRate == 0) {
+    rnx->deepCopy(obs);
+  }
+  rnx->dumpEpoch(newTime);
+
   // First time, set the _lastDumpSec immediately
   // --------------------------------------------
@@ -145 +158 @@
     }
     delete obs;
-    return 1;
+    return;
   }
 
@@ -159 +172 @@
     _lastDumpSec = newTime - _waitTime;
   }
-
-  return 0;
 }