Changeset 11113 in ntrip

Timestamp:

Oct 22, 2026, 4:00:17 PM (13 hours ago)

Author:

stuerze

Message:

timing in combination is improved

Location:

trunk/BNC/src

Files:

• bnchelp.html (modified) (1 diff)
• combination/bnccomb.cpp (modified) (2 diffs)
• combination/bnccomb.h (modified) (1 diff)

trunk/BNC/src/bnchelp.html

@@ -8524 +8524 @@
   <p>
     As the incoming corrections of the individual providers arrive with different latencies, BNC combines an epoch as
-    soon as each provider has delivered corrections for a later epoch, i.e. has completed the epoch. The combined
-    product is thus only delayed by the latency of the slowest provider. If a provider is late or missing, the epoch is
+    soon as each provider has delivered it. The corrections of a provider's epoch are passed on as soon as all its
+    messages have arrived (Multiple Message Indicator), with the clock corrections after the orbit corrections and
+    biases. The combined product is thus only delayed by the latency of the slowest provider. If a provider is late or missing, the epoch is
     combined without it at the latest when the newest incoming corrections are 10 seconds (or the sampling interval,
     if larger) younger than the epoch. Corrections arriving after an epoch was combined are ignored.</p>

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);

trunk/BNC/src/combination/bnccomb.h

@@ -277 +277 @@
   QMap<char, bncTime>                       _outlierStatStart; // start of the statistics interval
   void resetSatOffsets(char sys);
-  bool allACsBeyond(const bncTime& epoTime) const;
+  bool allACsDelivered(const bncTime& epoTime) const;
   bncTime                                    _resTime;
   cmbCorr*                                   _newCorr;