Changeset 6485 in ntrip for trunk/BNC

Timestamp:

Dec 28, 2014, 5:03:17 PM (10 years ago)

Author:

mervart

Message:

 

File:

• trunk/BNC/src/bnccore.cpp (modified) (3 diffs)

trunk/BNC/src/bnccore.cpp

@@ -582 +582 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_bncCore::slotNewCodeBiases(QList<t_satCodeBias> codeBiases) {
-
+  QMutexLocker locker(&_mutex);
+  emit newCodeBiases(codeBiases);
+  if (_socketsCorr) {
+    ostringstream out;
+    t_satCodeBias::writeEpoch(&out, codeBiases);   
+    QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+        if (sock->write(out.str().c_str()) == -1) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
 }
 
@@ -588 +607 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_bncCore::slotNewPhaseBiases(QList<t_satPhaseBias> phaseBiases) {
-
+  QMutexLocker locker(&_mutex);
+  emit newPhaseBiases(phaseBiases);
+  if (_socketsCorr) {
+    ostringstream out;
+    t_satPhaseBias::writeEpoch(&out, phaseBiases);   
+    QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+        if (sock->write(out.str().c_str()) == -1) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
 }
 
@@ -594 +632 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_bncCore::slotNewTec(t_vTec vTec) {
-
+  QMutexLocker locker(&_mutex);
+  emit newTec(vTec);
+  if (_socketsCorr) {
+    ostringstream out;
+    t_vTec::write(&out, vTec);   
+    QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+        if (sock->write(out.str().c_str()) == -1) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
 }