Index: trunk/BNC/combination/bnccomb.cpp
===================================================================
--- trunk/BNC/combination/bnccomb.cpp	(revision 3298)
+++ trunk/BNC/combination/bnccomb.cpp	(revision 3299)
@@ -225,7 +225,15 @@
   }
 
-  // Reject delayed corrections
-  // --------------------------
-  if (_processedBeforeTime.valid() && newCorr->tt < _processedBeforeTime) {
+  // Remember last correction time
+  // -----------------------------
+  if (!_lastCorrTime.valid() || _lastCorrTime < newCorr->tt) {
+    _lastCorrTime = newCorr->tt;
+  }
+
+  bncTime processTime = _lastCorrTime - 1.5 * moduloTime;
+
+  // Delete old corrections
+  // ----------------------
+  if (newCorr->tt < processTime) {
     delete newCorr;
     return;
@@ -255,18 +263,13 @@
   // Process all older Epochs (if there are any)
   // -------------------------------------------
-  const double waitTime = moduloTime;
-  _processedBeforeTime = newCorr->tt - waitTime;
-
   QList<cmbEpoch*> epochsToProcess;
-
   QMapIterator<QString, cmbAC*> itAC(_ACs);
   while (itAC.hasNext()) {
     itAC.next();
     cmbAC* AC = itAC.value();
-
     QMutableListIterator<cmbEpoch*> itEpo(AC->epochs);
     while (itEpo.hasNext()) {
       cmbEpoch* epoch = itEpo.next();
-      if (epoch->time < _processedBeforeTime) {
+      if (epoch->time <= processTime) {
         epochsToProcess.append(epoch);
         itEpo.remove();
Index: trunk/BNC/combination/bnccomb.h
===================================================================
--- trunk/BNC/combination/bnccomb.h	(revision 3298)
+++ trunk/BNC/combination/bnccomb.h	(revision 3299)
@@ -79,5 +79,5 @@
 
   QMap<QString, cmbAC*> _ACs;   // Analytical Centers (key is mountpoint)
-  bncTime               _processedBeforeTime;
+  bncTime               _lastCorrTime;
   QVector<cmbParam*>    _params;
   bncRtnetDecoder*      _rtnetDecoder;