Changeset 11123 in ntrip for trunk/BNC/src/bncantex.cpp

Timestamp:

Oct 23, 2026, 4:52:02 PM (6 hours ago)

Author:

stuerze

Message:

A changed ANTEX file is read again while BNC is running and used from the GPS week given in it

File:

• trunk/BNC/src/bncantex.cpp (modified) (1 diff)

trunk/BNC/src/bncantex.cpp

@@ -1110 +1110 @@
 }
 
+// GPS week of the file from the SINEX code of the satellite entries
+// (e.g. IGS20_2437): the week occurring most often
+////////////////////////////////////////////////////////////////////////////
+int bncAntex::gpsWeek() const {
+  static const QRegularExpression re("_(\\d{4})$");
+  QMap<int, int> count;
+  QMapIterator<QString, QVector<t_antMap*> > it(_satMaps);
+  while (it.hasNext()) {
+    it.next();
+    for (const t_antMap* map : it.value()) {
+      QRegularExpressionMatch mm = re.match(map->snxCode.trimmed());
+      if (mm.hasMatch()) {
+        count[mm.captured(1).toInt()] += 1;
+      }
+    }
+  }
+  int week = 0, num = 0;
+  QMapIterator<int, int> itC(count);
+  while (itC.hasNext()) {
+    itC.next();
+    if (itC.value() > num) {
+      week = itC.key();
+      num  = itC.value();
+    }
+  }
+  return week;
+}
+
+// Take over the attitude model states and warnings of another instance
+////////////////////////////////////////////////////////////////////////////
+void bncAntex::takeStates(const bncAntex& other) {
+  _glonassYaw       = other._glonassYaw;
+  _gpsYaw           = other._gpsYaw;
+  _onYaw            = other._onYaw;
+  _noSatEntryWarned = other._noSatEntryWarned;
+}
+
+// Re-read the ANTEX file while running
+////////////////////////////////////////////////////////////////////////////
+bncAntexReloader::bncAntexReloader() {
+  _fileSize    = 0;
+  _init        = false;
+  _pending     = 0;
+  _pendingWeek = 0;
+}
+
+bncAntexReloader::~bncAntexReloader() {
+  delete _pending;
+}
+
+QString bncAntexReloader::update(bncAntex*& antex, const bncTime& epoch) {
+  if (!antex || antex->fileName().isEmpty()) {
+    return QString();
+  }
+  QString msg;
+  QDateTime now = QDateTime::currentDateTimeUtc();
+  if (!_init) {
+    QFileInfo fi(antex->fileName());
+    _fileTime = fi.lastModified();
+    _fileSize = fi.size();
+    _lastCheck = now;
+    _init = true;
+  }
+
+  // file changed?
+  if (_lastCheck.secsTo(now) >= 60) {
+    _lastCheck = now;
+    QFileInfo fi(antex->fileName());
+    // read only once the file has not changed for 30 s (copy finished)
+    if (fi.exists() && (fi.lastModified() != _fileTime || fi.size() != _fileSize) &&
+        fi.lastModified().secsTo(now) >= 30) {
+      _fileTime = fi.lastModified();
+      _fileSize = fi.size();
+      bncAntex* newAntex = new bncAntex();
+      if (newAntex->readFile(antex->fileName()) != success || newAntex->numSatPrns() == 0) {
+        delete newAntex;
+        msg = "ANTEX file " + antex->fileName() + " changed but could not be read - previous file kept";
+      }
+      else {
+        int week = newAntex->gpsWeek();
+        delete _pending;
+        _pending     = newAntex;
+        _pendingWeek = week;
+        if (epoch.valid() && week > int(epoch.gpsw())) {
+          msg = QString("ANTEX file %1 changed (GPS week %2) - used from GPS week %2 on")
+                .arg(antex->fileName()).arg(week);
+        }
+      }
+    }
+  }
+
+  // pending file due?
+  if (_pending && (!epoch.valid() || _pendingWeek <= int(epoch.gpsw()))) {
+    _pending->takeStates(*antex);
+    delete antex;
+    antex    = _pending;
+    _pending = 0;
+    if (!msg.isEmpty()) msg += "; ";
+    msg += QString("ANTEX file re-read, used from now on (GPS week %1): ").arg(_pendingWeek) + antex->info();
+  }
+  return msg;
+}
+
 // True if a missing satellite antenna entry has to be reported (at most once
 // per hour and PRN)