Changeset 10960 in ntrip for trunk

Timestamp:

Jul 27, 2026, 1:43:45 PM (9 days ago)

Author:

stuerze

Message:

A timeout is added to allow a reonnect after an outage of Ntrip Version 2/2s streams

Location:

trunk/BNC

Files:

• CHANGELOG.md (modified) (1 diff)
• src/bncnetqueryv2.cpp (modified) (3 diffs)

trunk/BNC/CHANGELOG.md

@@ -10 +10 @@
 - FIXED: Handling of ionospheric constraints [(#220)](https://software.rtcm-ntrip.org/ticket/220)
 - FIXED: SP3/Clock RINEX clock values produced by the Upload Corrections feature no longer depend on whether 'Center of Mass' is ticked, since that setting should only affect the uploaded SSR Broadcast Correction stream [(#210)](https://software.rtcm-ntrip.org/ticket/210)
+- FIXED: A timeout is added to allow a reonnect after an outage of Ntrip Version 2/2s streams
 - CHANGED: prevention to extrapolate a orb/clk SSR correction far beyond its own declared update interval 
 - CHANGED: GLONASS postion integration fresh from the pristine, decoded TOC state rather than rolling _tt/_xv forward across repeated calls

trunk/BNC/src/bncnetqueryv2.cpp

@@ -16 +16 @@
 
 #include <iostream>
+
+#include <QTimer>
 
 #include "bncnetqueryv2.h"
@@ -34 +36 @@
   _firstData = true;
   _status    = init;
+  _timeOut   = 20000;
 
   bncSettings settings;
@@ -215 +218 @@
   // Wait Loop
   // ---------
+  bool timedOut = false;
   if (!_reply->bytesAvailable()) {
+    QTimer timer;
+    timer.setSingleShot(true);
+    connect(&timer, SIGNAL(timeout()), _eventLoop, SLOT(quit()));
+    timer.start(_timeOut);
     _eventLoop->exec();
+    timedOut = !timer.isActive();
   }
   if (!_reply) {
+    return;
+  }
+
+  // Timeout: neither new data arrived nor did the request finish
+  // (e.g. connection silently dropped by a NAT/firewall)
+  // --------------------------------------------------------------
+  if (timedOut) {
+    _status = error;
+    emit newMessage(_url.path().toLatin1().replace(0,1,"")
+                    + ": Read timeout", true);
+    disconnect(_reply, SIGNAL(finished()), this, SLOT(slotFinished()));
+    _reply->abort();
     return;
   }