Changeset 2918 in ntrip for trunk/BNC/combination/bnccomb.cpp

Timestamp:

Jan 27, 2011, 5:39:44 PM (13 years ago)

Author:

mervart

Message:

 

File:

• trunk/BNC/combination/bnccomb.cpp (modified) (4 diffs)

trunk/BNC/combination/bnccomb.cpp

@@ -30 +30 @@
 
   QStringList combineStreams = settings.value("combineStreams").toStringList();
-  
-  _nStreams = combineStreams.size();
-  
-  if (_nStreams >= 2) {
+
+  if (combineStreams.size() >= 2) {
     QListIterator<QString> it(combineStreams);
     while (it.hasNext()) {
       QStringList hlp = it.next().split(" ");
-      cout << "combination: " << hlp[0].toAscii().data() << endl;
+      cmbAC* newAC = new cmbAC();
+      newAC->mountPoint = hlp[0];
+      newAC->name       = hlp[1];
+      newAC->weight     = hlp[2].toDouble();
+
+      _ACs[newAC->mountPoint] = newAC;
     }
   }
@@ -45 +48 @@
 ////////////////////////////////////////////////////////////////////////////
 bncComb::~bncComb() {
+  QMapIterator<QString, cmbAC*> it(_ACs);
+  while (it.hasNext()) {
+    it.next();
+    delete it.value();
+  }
 }
 
@@ -52 +60 @@
   QMutexLocker locker(&_mutex);
 
+  // Find the relevant instance of cmbAC class
+  // -----------------------------------------
+  if (_ACs.find(staID) == _ACs.end()) {
+    return;
+  }
+  cmbAC* AC = _ACs[staID];
+
+  // Read the Correction
+  // -------------------
   t_corr* newCorr = new t_corr();
   if (!newCorr->readLine(line) == success) {
@@ -58 +75 @@
   }
 
-  cout << staID.toAscii().data() << " " << newCorr->prn.toAscii().data() << " "
-       << newCorr->tt.datestr() << " " << newCorr->tt.timestr() << " "
-       << newCorr->iod << " " << newCorr->dClk << endl;
+  // Find/Create the instance of cmbEpoch class
+  // ------------------------------------------
+  cmbEpoch* newEpoch = 0;
+  QListIterator<cmbEpoch*> it(AC->epochs);
+  while (it.hasNext()) {
+    cmbEpoch* hlpEpoch = it.next();
+    if (hlpEpoch->time == newCorr->tt) {
+      newEpoch = hlpEpoch;
+      break;
+    }
+  }
+  if (newEpoch == 0) {
+    newEpoch = new cmbEpoch();
+    newEpoch->time = newCorr->tt;
+    AC->epochs.append(newEpoch);
+  }
 
-  delete newCorr;
+  if (newEpoch->corr.find(newCorr->prn) != newEpoch->corr.end()) {
+    delete newEpoch->corr[newCorr->prn];     
+  }
+  newEpoch->corr[newCorr->prn] = newCorr;
+
+  processEpochsBefore(newCorr->tt);
 }
 
+// 
+////////////////////////////////////////////////////////////////////////////
+void bncComb::processEpochsBefore(const bncTime& time) {
+
+  const double waitTime = 10.0; // wait 10 seconds
+
+  QMapIterator<QString, cmbAC*> itAC(_ACs);
+  while (itAC.hasNext()) {
+    itAC.next();
+    cmbAC* AC = itAC.value();
+
+
+    QMutableListIterator<cmbEpoch*> itEpo(AC->epochs);
+    while (itEpo.hasNext()) {
+      cmbEpoch* epoch = itEpo.next();
+      double dt = time - epoch->time;
+
+      if      (dt == waitTime) {
+        QMapIterator<QString, t_corr*> itCorr(epoch->corr);
+        while (itCorr.hasNext()) {
+          itCorr.next();
+          t_corr* corr = itCorr.value();
+          cout << AC->name.toAscii().data() << " " 
+               << AC->mountPoint.toAscii().data() << " "
+               << corr->prn.toAscii().data() << " "
+               << corr->tt.datestr() << " " << corr->tt.timestr() << " "
+               << corr->iod << " " << corr->dClk << endl;
+        }
+      }
+
+      if (dt >= waitTime) {
+        delete epoch;
+        itEpo.remove();
+      }
+    }
+  }
+}