Changeset 642 in ntrip

Timestamp:

Dec 18, 2007, 4:24:26 PM (16 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncapp.cpp (modified) (3 diffs)

trunk/BNC/bncapp.cpp

@@ -43 +43 @@
 #include <QMessageBox>
 #include <cmath>
+#include <unistd.h>
 
 #include "bncapp.h" 
@@ -524 +525 @@
   // ----------------------
   if (_sockets) {
-    QListIterator<QTcpSocket*> is(*_sockets);
+    QMutableListIterator<QTcpSocket*> is(*_sockets);
     while (is.hasNext()) {
       QTcpSocket* sock = is.next();
       if (sock->state() == QAbstractSocket::ConnectedState) {
-        sock->write(allLines);
+        int fd = sock->socketDescriptor();
+        if (::write(fd, allLines.data(), allLines.size()) != allLines.size()) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
       }
     }
@@ -590 +599 @@
   // ----------------------
   if (_sockets) {
-    QListIterator<QTcpSocket*> is(*_sockets);
+    QMutableListIterator<QTcpSocket*> is(*_sockets);
     while (is.hasNext()) {
       QTcpSocket* sock = is.next();
       if (sock->state() == QAbstractSocket::ConnectedState) {
-        sock->write(allLines);
+        int fd = sock->socketDescriptor();
+        if (::write(fd, allLines.data(), allLines.size()) != allLines.size()) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
       }
     }