Changeset 11113 in ntrip for trunk/BNC/src/combination/bnccomb.cpp

Timestamp:

Oct 22, 2026, 4:00:17 PM (2 days ago)

Author:

stuerze

Message:

timing in combination is improved

File:

• trunk/BNC/src/combination/bnccomb.cpp (modified) (2 diffs)

trunk/BNC/src/combination/bnccomb.cpp

@@ -555 +555 @@
 
 
-// True if every AC has delivered clock corrections for an epoch after epoTime
-////////////////////////////////////////////////////////////////////////////
-bool bncComb::allACsBeyond(const bncTime& epoTime) const {
+// True if every AC has delivered clock corrections for epoTime or a later
+// epoch: the decoder passes an epoch on when it is complete (Multiple
+// Message Indicator) and emits its clocks after its orbits and biases
+////////////////////////////////////////////////////////////////////////////
+bool bncComb::allACsDelivered(const bncTime& epoTime) const {
   QListIterator<cmbAC*> itAC(_ACs);
   while (itAC.hasNext()) {
     const cmbAC* AC = itAC.next();
     bncTime acLast = _acLastClkTime.value(AC->name);
-    if (!acLast.valid() || !(acLast > epoTime)) {
+    if (!acLast.valid() || acLast < epoTime) {
       return false;
     }
@@ -723 +725 @@
       }
     }
-    // Process the front epoch as soon as all ACs have delivered corrections
-    // for a later epoch (i.e. have finished this one), at the latest when
-    // the newest correction is maxWait newer (an AC may be late or missing).
+    // Process the front epoch as soon as all ACs have delivered it (complete
+    // epochs), at the latest when the newest correction is maxWait newer
+    // (an AC may be late or missing).
     // Waiting only outWait after the newest correction lost the corrections
     // of ACs with a few seconds more latency ("old correction").
     // -----------------------------------------------------------------------
     const double maxWait = max(10.0, outWait);
-    if (allACsBeyond(epoTime) || epoTime < (_lastClkCorrTime - maxWait)) {
+    if (allACsDelivered(epoTime) || epoTime < (_lastClkCorrTime - maxWait)) {
       _resTime = epoTime;
       processEpoch(_resTime, clkCorrVec);