Changeset 6455 in ntrip for trunk/BNC/src/bnccore.cpp

Timestamp:

Dec 27, 2014, 3:58:55 PM (9 years ago)

Author:

mervart

Message:

 

File:

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

trunk/BNC/src/bnccore.cpp

@@ -534 +534 @@
   emit newOrbCorrections(orbCorrections);
   if (_socketsCorr) {
-    QListIterator<t_orbCorr> it(orbCorrections);
-    while (it.hasNext()) {
-      const t_orbCorr& corr = it.next();
-      QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
-      while (is.hasNext()) {
-        QTcpSocket* sock = is.next();
-        if (sock->state() == QAbstractSocket::ConnectedState) {
-          if (sock->write(corr.toLine().c_str()) == -1) {
-            delete sock;
-            is.remove();
-          }
-        }
-        else if (sock->state() != QAbstractSocket::ConnectingState) {
+    ostringstream out;
+    t_orbCorr::writeEpoch(&out, orbCorrections);   
+    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();
       }
     }
@@ -561 +559 @@
   emit newClkCorrections(clkCorrections);
   if (_socketsCorr) {
-    QListIterator<t_clkCorr> it(clkCorrections);
-    while (it.hasNext()) {
-      const t_clkCorr& corr = it.next();
-      QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
-      while (is.hasNext()) {
-        QTcpSocket* sock = is.next();
-        if (sock->state() == QAbstractSocket::ConnectedState) {
-          if (sock->write(corr.toLine().c_str()) == -1) {
-            delete sock;
-            is.remove();
-          }
-        }
-        else if (sock->state() != QAbstractSocket::ConnectingState) {
+    ostringstream out;
+    t_clkCorr::writeEpoch(&out, clkCorrections);   
+    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();
       }
     }