Changeset 9843 in ntrip

Timestamp:

Oct 4, 2022, 11:30:02 AM (2 years ago)

Author:

stuerze

Message:

restore RTNET buffer reading code

File:

• trunk/BNC/src/upload/bncrtnetuploadcaster.cpp (modified) (4 diffs)

trunk/BNC/src/upload/bncrtnetuploadcaster.cpp

@@ -264 +264 @@
   QMutexLocker locker(&_mutex);
 
-
   // Append to internal buffer
   // -------------------------
@@ -275 +274 @@
   if (iEpoBeg == -1) {
     _rtnetStreamBuffer.clear();
+    emit(newMessage(
+          "bncRtnetUploadCaster: no Epoch line found " + _casterID.toLatin1(), false));
     return;
   }
+  _rtnetStreamBuffer = _rtnetStreamBuffer.mid(iEpoBeg);
+
+  int iEpoEnd = _rtnetStreamBuffer.lastIndexOf("EOE"); // end   of last epoch
+  if (iEpoEnd == -1) {
+    emit(newMessage(
+          "bncRtnetUploadCaster: no EOE found " + _casterID.toLatin1(), false));
+    return;
+  }
+  else {
+    lines = _rtnetStreamBuffer.left(iEpoEnd).split('\n', QString::SkipEmptyParts);
+    _rtnetStreamBuffer = _rtnetStreamBuffer.mid(iEpoEnd+3);
+  }
+
+  if (lines.size() < 2) {
+      emit(newMessage(
+            "bncRtnetUploadCaster: less than 2 lines to decode " + _casterID.toLatin1(), false));
+    return;
+  }
+
+  // Keep the last unfinished line in buffer
+  // ---------------------------------------
+  int iLastEOL = _rtnetStreamBuffer.lastIndexOf('\n');
+  if (iLastEOL != -1) {
+    _rtnetStreamBuffer = _rtnetStreamBuffer.mid(iLastEOL+1);
+    emit(newMessage(
+          "bncRtnetUploadCaster: keep the last unfinished line in buffer " + _casterID.toLatin1(), false));
+  }
+
+
+  /* Append to internal buffer
+  // -------------------------
+  _rtnetStreamBuffer.append(QByteArray(buffer, bufLen));
+
+  // Select buffer part that contains last epoch
+  // -------------------------------------------
+  QStringList lines;
+  int iEpoBeg = _rtnetStreamBuffer.lastIndexOf('*');   // begin of last epoch
+  if (iEpoBeg == -1) {
+    _rtnetStreamBuffer.clear();
+    emit(newMessage(
+          "bncRtnetUploadCaster: no Epoch line found " + _casterID.toLatin1(), false));
+    return;
+  }
+
   int iEpoBegEarlier = _rtnetStreamBuffer.indexOf('*');
   if (iEpoBegEarlier != -1 && iEpoBegEarlier < iEpoBeg) { // are there two epoch lines in buffer?
@@ -284 +329 @@
     _rtnetStreamBuffer = _rtnetStreamBuffer.mid(iEpoBeg);
   }
+
   int iEpoEnd = _rtnetStreamBuffer.lastIndexOf("EOE"); // end of last epoch
   if (iEpoEnd == -1) {
+    _rtnetStreamBuffer.clear();
+    emit(newMessage(
+          "bncRtnetUploadCaster: no EOE found " + _casterID.toLatin1(), false));
     return;
   }
@@ -309 +358 @@
     return;
   }
-
+*/
   // Read first line (with epoch time)
   // ---------------------------------