Changeset 2030 in ntrip

Timestamp:

Nov 26, 2009, 11:40:38 AM (15 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bnccaster.cpp (modified) (2 diffs)
• bnccaster.h (modified) (1 diff)
• bncgetthread.cpp (modified) (2 diffs)
• bncgetthread.h (modified) (1 diff)
• bncpppthread.cpp (modified) (1 diff)
• bncpppthread.h (modified) (2 diffs)

trunk/BNC/bnccaster.cpp

@@ -252 +252 @@
   _threads.push_back(getThread);
 
-  bncPPPthread* PPPthread = getThread->PPPthread();
-  if (PPPthread) {
-    connect(this, SIGNAL(newEpochData(QList<p_obs>)),
-            PPPthread, SLOT(slotNewEpochData(QList<p_obs>)));
-    connect(((bncApp*)qApp), SIGNAL(newEphGPS(gpsephemeris)),
-            PPPthread, SLOT(slotNewEphGPS(gpsephemeris)));
-    connect(((bncApp*)qApp), SIGNAL(newCorrections(QList<QString>)),
-            PPPthread, SLOT(slotNewCorrections(QList<QString>)));
-    PPPthread->start();
-  }
-
   getThread->start();
 }
@@ -302 +291 @@
     bool first = true;
     QList<p_obs> allObs = _epochs->values(sec);
-
-    emit newEpochData(allObs);
 
     QListIterator<p_obs> it(allObs);

trunk/BNC/bnccaster.h

@@ -51 +51 @@
    void getThreadsFinished();   
    void newMessage(QByteArray msg, bool showOnScreen);
-   void newEpochData(QList<p_obs>);
 
  private slots:

trunk/BNC/bncgetthread.cpp

@@ -332 +332 @@
 
   _latencyChecker = new latencyChecker(_staID);
+
+  if (_PPPthread) {
+    connect(((bncApp*)qApp), SIGNAL(newEphGPS(gpsephemeris)),
+            _PPPthread, SLOT(slotNewEphGPS(gpsephemeris)));
+    connect(((bncApp*)qApp), SIGNAL(newCorrections(QList<QString>)),
+            _PPPthread, SLOT(slotNewCorrections(QList<QString>)));
+    _PPPthread->start();
+  }
 
   msleep(100); //sleep 0.1 sec
@@ -491 +499 @@
         }
       
+        // PPP Client
+        // ----------
+        if (_PPPthread) {
+          _PPPthread->putNewObs(obs);
+        }
+
         // Emit new observation signal
         // ---------------------------

trunk/BNC/bncgetthread.h

@@ -73 +73 @@
    QByteArray longitude() const {return _longitude;}
    QByteArray ntripVersion() const {return _ntripVersion;}
-   bncPPPthread* PPPthread() {return _PPPthread;}
 
  signals:

trunk/BNC/bncpppthread.cpp

@@ -107 +107 @@
 // 
 ////////////////////////////////////////////////////////////////////////////
-void bncPPPthread::slotNewEpochData(QList<p_obs> obsList) {
-  QMutexLocker locker(&_mutex);
-  QListIterator<p_obs> it(obsList);
-
-  delete _data;
-  _data = new t_data();
-
-  while (it.hasNext()) {
-    p_obs          pp  = it.next();
-    t_obsInternal* obs = &(pp->_o);
-    QByteArray staID = QByteArray(obs->StatID); 
-    if (staID == _staID) {
-      if (_data->tt.undef()) {
-        _data->tt.set(obs->GPSWeek, 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;
-    }
-  }
+void bncPPPthread::putNewObs(p_obs pp) {
+
+  QMutexLocker locker(&_mutex);
+
+  t_obsInternal* obs = &(pp->_o);
+
+  t_time tt(obs->GPSWeek, obs->GPSWeeks);
+
+  QString prn = 
+        QString("%1%2").arg(obs->satSys).arg(obs->satNum, 2, 10, QChar('0'));
+
+  cout << tt.timestr(1) << " " << prn.toAscii().data() << endl;
+  cout.flush();
+
+///  delete _data;
+///  _data = new t_data();
+///
+///    QByteArray staID = QByteArray(obs->StatID); 
+///    if (staID == _staID) {
+///      if (_data->tt.undef()) {
+///      }
+///      ++_data->numSat;
+///      _data->prn[_data->numSat] = 
+///          
+///      _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;
+///    }
+///  }
 }
 

trunk/BNC/bncpppthread.h

@@ -73 +73 @@
  public:
   void terminate();
+  void putNewObs(p_obs pp);
 
  signals:
@@ -82 +83 @@
 
  public slots:
-  void slotNewEpochData(QList<p_obs> obsList);
   void slotNewEphGPS(gpsephemeris gpseph);
   void slotNewCorrections(QList<QString> corrList);