Changeset 2024 in ntrip for trunk/BNC/bncpppthread.cpp

Timestamp:

Nov 25, 2009, 6:38:01 PM (14 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncpppthread.cpp (modified) (5 diffs)

trunk/BNC/bncpppthread.cpp

@@ -54 +54 @@
   _staID         = staID;
   _isToBeDeleted = false;
+  _data          = 0;
 }
 
@@ -62 +63 @@
     wait();
   }
+  delete _data;
   QMapIterator<QString, t_eph*> it(_eph);
   while (it.hasNext()) {
@@ -93 +95 @@
         return;
       }
-
+      processEpoch();
     }
     catch (...) {
@@ -111 +113 @@
     t_obsInternal* obs = &(pp->_o);
     QByteArray staID = QByteArray(obs->StatID); 
-    cout << "DATA " << obs->GPSWeek << " " << obs->GPSWeeks << " " 
-         << staID.data() << " " 
-         << obs->satSys << obs->satNum << endl;
+    if (staID == _staID) {
+      if (!_data) {
+        _data = new t_data();
+        _data->GPSWeek  = obs->GPSWeek;
+        _data->GPSWeeks = obs->GPSWeeks;
+      }
+      ++_data->numSat;
+      _data->prn[_data->numSat] = 
+          QString("%1%2").arg(obs->satSys).arg(obs->satNum, 2, 10, QChar('0'));
+      _data->C1[_data->numSat] = obs->C1;
+      _data->C2[_data->numSat] = obs->C2;
+      _data->P1[_data->numSat] = obs->P1;
+      _data->P2[_data->numSat] = obs->P2;
+      _data->L1[_data->numSat] = obs->L1;
+      _data->L2[_data->numSat] = obs->L2;
+    }
   }
 }
@@ -161 +176 @@
   }
 }
+
+// 
+////////////////////////////////////////////////////////////////////////////
+void bncPPPthread::processEpoch() {
+  QMutexLocker locker(&_mutex);
+
+  if (!_data) {
+    return;
+  }
+
+  for (int is = 1; is <= _data->numSat; is++) {
+    cout << is << " " << _data->prn[is].toAscii().data() << " " 
+         << _data->C1[is] << " " << _data->P1[is] << endl;
+  }
+
+  cout << endl;
+  cout.flush();
+
+  delete _data;
+  _data = 0;
+}