Changeset 249 in ntrip for trunk/BNC/bncgetthread.cpp

Timestamp:

Oct 14, 2006, 10:34:27 AM (18 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncgetthread.cpp (modified) (1 diff)

trunk/BNC/bncgetthread.cpp

@@ -218 +218 @@
   // ------------------
   while (true) {
-
-    if (_socket->state() != QAbstractSocket::ConnectedState) {
-      emit(newMessage(_staID + ": Socket not connected, reconnecting"));
-      tryReconnect();
-    }
-
-    _socket->waitForReadyRead(_timeOut);
-    qint64 nBytes = _socket->bytesAvailable();
-    if (nBytes > 0) {
-      char* data = new char[nBytes];
-      _socket->read(data, nBytes);
-      _decoder->Decode(data, nBytes);
-      delete data;
-      for (list<Observation*>::iterator it = _decoder->_obsList.begin(); 
-           it != _decoder->_obsList.end(); it++) {
-        emit newObs(_staID, *it);
-        _global_caster->newObs(_staID, *it);
-      }
-      _decoder->_obsList.clear();
-    }
-    else {
-      emit(newMessage(_staID + ": Data Timeout, reconnecting"));
+    try {
+      if (_socket->state() != QAbstractSocket::ConnectedState) {
+        emit(newMessage(_staID + ": Socket not connected, reconnecting"));
+        tryReconnect();
+      }
+      
+      
+      _socket->waitForReadyRead(_timeOut);
+      qint64 nBytes = _socket->bytesAvailable();
+      if (nBytes > 0) {
+        char* data = new char[nBytes];
+        _socket->read(data, nBytes);
+        _decoder->Decode(data, nBytes);
+        delete data;
+        for (list<Observation*>::iterator it = _decoder->_obsList.begin(); 
+             it != _decoder->_obsList.end(); it++) {
+          emit newObs(_staID, *it);
+          _global_caster->newObs(_staID, *it);
+        }
+        _decoder->_obsList.clear();
+      }
+      else {
+        emit(newMessage(_staID + ": Data Timeout, reconnecting"));
+        tryReconnect();
+      }
+    }
+    catch (const char* msg) {
+      emit(newMessage(_staID + msg));
       tryReconnect();
     }