Changeset 1427 in ntrip for trunk/BNC/GPSS/gpssDecoder.cpp

Timestamp:

Jan 2, 2009, 6:16:47 PM (15 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/GPSS/gpssDecoder.cpp (modified) (5 diffs)

trunk/BNC/GPSS/gpssDecoder.cpp

@@ -57 +57 @@
   errmsg.clear();
 
+  if (_mode == MODE_SEARCH) {
+    _buffer.clear();
+  }
   _buffer.append(data, dataLen);
 
   for (;;) { 
 
+    if (_buffer.size() < 1) {
+      _mode = MODE_SEARCH;
+      return success;
+    }
+
     if      (_mode == MODE_SEARCH) {
-      if (_buffer.size() < 1) {
-        _mode = MODE_SEARCH;
-        return success;
-      }
       if (_buffer[0] == 0x02) {
         _mode = MODE_TYPE;
+      }
+      else {
+        _mode = MODE_SEARCH;
       }
       _buffer.erase(0,1);
@@ -73 +80 @@
 
     else if (_mode == MODE_TYPE) {
-      if (_buffer.size() < 1) {
-        _mode = MODE_SEARCH;
-        return success;
-      }
       if        (_buffer[0] == 0x00) {
         _mode = MODE_EPOCH;
@@ -82 +85 @@
         _mode = MODE_EPH;
       } else {
-        errmsg.push_back("Unknown record type");
         _mode = MODE_SEARCH;
       }
@@ -112 +114 @@
       memcpy(&epochHdr, _buffer.data(), sizeof(epochHdr));
       _buffer.erase(0,sizeof(epochHdr));
+      if (_buffer.size() < epochHdr.n_svs * sizeof(t_obsInternal)) {
+        _mode = MODE_SEARCH;
+        return success;
+      }
       for (int is = 1; is <= epochHdr.n_svs; is++) {
-        if (_buffer.size() < sizeof(t_obsInternal)) {
-          _mode = MODE_SEARCH;
-          return success;
-        }
         t_obs* obs = new t_obs();
         memcpy(&(obs->_o), _buffer.data(), sizeof(t_obsInternal));
@@ -138 +140 @@
 
     else {
-      if (_buffer.size() < 1) {
-        _mode = MODE_SEARCH;
-        return success;
-      }
       _buffer.erase(0,1);
       _mode = MODE_SEARCH;