Changeset 637 in ntrip

Timestamp:

Dec 17, 2007, 5:13:44 PM (16 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bnccaster.cpp (modified) (2 diffs)

trunk/BNC/bnccaster.cpp

@@ -39 +39 @@
  * -----------------------------------------------------------------------*/
 
+#include <iostream>
 #include <math.h>
 #include <unistd.h>
@@ -266 +267 @@
         if (_sockets) {
           int numBytes = sizeof(obs->_o); 
-          QListIterator<QTcpSocket*> is(*_sockets);
+          QMutableListIterator<QTcpSocket*> is(*_sockets);
           while (is.hasNext()) {
             QTcpSocket* sock = is.next();
             if (sock->state() == QAbstractSocket::ConnectedState) {
+              bool ok = true;
               int fd = sock->socketDescriptor();
               if (first) {
-                ::write(fd, &begEpoch, 1);
-              }
-              ::write(fd, &begObs, 1);
-              ::write(fd, &obs->_o, numBytes);
+                if (::write(fd, &begEpoch, 1) != 1) {
+                  ok = false;
+                }
+              }
+              if (::write(fd, &begObs, 1) != 1) {
+                ok = false;
+              }
+              if (::write(fd, &obs->_o, numBytes) != numBytes) {
+                ok = false;
+              }
               if (!it.hasNext()) {
-                ::write(fd, &endEpoch, 1);
-              }
+                if (::write(fd, &endEpoch, 1) != 1) {
+                  ok = false;
+                }
+              }
+              if (!ok) {
+                delete sock;
+                is.remove();
+              }
+            }
+            else if (sock->state() != QAbstractSocket::ConnectingState) {
+              delete sock;
+              is.remove();
             }
           }