Changeset 11137 in ntrip for trunk/BNC/src/bncephuser.cpp

Timestamp:

Oct 28, 2026, 9:48:01 PM (10 hours ago)

Author:

stuerze

Message:

eph handling improved

File:

• trunk/BNC/src/bncephuser.cpp (modified) (3 diffs)

trunk/BNC/src/bncephuser.cpp

@@ -48 +48 @@
 // Constructor
 ////////////////////////////////////////////////////////////////////////////
-bncEphUser::bncEphUser(bool connectSlots) {
+bncEphUser::bncEphUser(bool connectSlots, unsigned maxQueueSize) : _maxQueueSize(maxQueueSize) {
   if (connectSlots) {
     connect(BNC_CORE, SIGNAL(newGPSEph(t_ephGPS)),
@@ -148 +148 @@
 
   QString prn(newEph->prn().toInternalString().c_str());
+
+  // data set received before, e.g. from a slower stream after a newer one
+  if (_eph.contains(prn)) {
+    const deque<t_eph*>& qq = _eph[prn];
+    for (unsigned ii = 0; ii < qq.size(); ii++) {
+      if (qq[ii]->sameDataSet(eph)) {
+        delete newEph;
+        return failure;
+      }
+    }
+  }
 
   const t_eph* ephOld = ephLast(prn);
@@ -224 +235 @@
   if (eph->isUnhealthy()) {
     eph->setCheckState(t_eph::unhealthy);
+    return;
+  }
+
+  // GPS/QZSS: IODE and IODC of the same upload
+  // -------------------------------------------
+  const t_ephGPS* ephGPS = dynamic_cast<const t_ephGPS*>(eph);
+  if (ephGPS && !ephGPS->iodeIodcConsistent()) {
+    eph->setCheckState(t_eph::bad);
     return;
   }