Changeset 838 in ntrip for trunk

Timestamp:

Apr 16, 2008, 1:28:38 PM (17 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNS

Files:

• bnseph.cpp (modified) (3 diffs)
• bnseph.h (modified) (1 diff)

trunk/BNS/bnseph.cpp

@@ -35 +35 @@
 }
 
-// Start 
+// Connect the Socket
 ////////////////////////////////////////////////////////////////////////////
-void t_bnseph::run() {
+void t_bnseph::reconnect() {
 
-  emit(newMessage("bnseph::run Start"));
+  delete _socket;
 
-  // Connect the Socket
-  // ------------------
   QSettings settings;
   QString host = "localhost";
@@ -50 +48 @@
   _socket->connectToHost(host, port);
 
-  const int timeOut = 3*1000;  // 3 seconds
+  const int timeOut = 10*1000;  // 10 seconds
   if (!_socket->waitForConnected(timeOut)) {
-    emit(error("bnseph::run Connect Timeout"));
+    emit(newMessage("bnseph::run Connect Timeout"));
   }
-  else {
-    while (true) {
-      if (_socket->state() != QAbstractSocket::ConnectedState) {
-        emit(error("bnseph::not connected"));
-        break;
-      }
+}
+
+// Start 
+////////////////////////////////////////////////////////////////////////////
+void t_bnseph::run() {
+
+  emit(newMessage("bnseph::run Start"));
+
+  while (true) {
+    if (_socket == 0 || _socket->state() != QAbstractSocket::ConnectedState) {
+      reconnect();
+    }
+    if (_socket && _socket->state() == QAbstractSocket::ConnectedState) {
       if (_socket->canReadLine()) {
         readEph();
@@ -66 +71 @@
         _socket->waitForReadyRead(10);
       }
+    }
+    else {
+      msleep(10);
     }
   }

trunk/BNS/bnseph.h

@@ -51 +51 @@
  
  private:
+  void reconnect();
   void readEph();
   QTcpSocket* _socket;