Changeset 138 in ntrip for trunk/BNC

Timestamp:

Sep 8, 2006, 10:09:25 AM (18 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bncconst.h (modified) (1 diff)
• bncgetthread.cpp (modified) (7 diffs)
• bncgetthread.h (modified) (3 diffs)

trunk/BNC/bncconst.h

@@ -1 +1 @@
 #ifndef BNCCONST_H
 #define BNCCONST_H
+
+enum t_irc {failure = -1, success}; // return code
 
 class t_CST {

trunk/BNC/bncgetthread.cpp

@@ -37 +37 @@
   _socket     = 0;
   _timeOut    = 10*1000;  // 10 seconds
+  _nextSleep  =  1;       //  1 second
 }
 
@@ -102 +103 @@
 // Init Run
 ////////////////////////////////////////////////////////////////////////////
-void bncGetThread::initRun() {
+t_irc bncGetThread::initRun() {
 
   // Send the Request
@@ -113 +114 @@
 
   if (!_socket) {
-    return exit(1);
+    return failure;
   }
 
@@ -123 +124 @@
     if (line.indexOf("ICY 200 OK") != 0) {
       emit(newMessage(("Wrong Caster Response:\n" + line).toAscii()));
-      return exit(1);
+      exit(1);
     }
   }
   else {
     emit(newMessage("Response Timeout"));
-    return exit(1);
+    return failure;
   }
 
@@ -148 +149 @@
     else {
       emit(newMessage(_staID + " Unknown data format " + _format));
-      return exit(1);
-    }
-  }
+      exit(1);
+    }
+  }
+  return success;
 }
 
@@ -157 +159 @@
 void bncGetThread::run() {
 
-  initRun();
+  if ( initRun() != success ) {
+    emit(newMessage("initRun failed, reconnecting"));
+    tryReconnect();
+  }
 
   // Read Incoming Data
@@ -194 +199 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncGetThread::tryReconnect() {
-
-}
+  while (1) {
+    delete _socket; _socket = 0;
+    sleep(_nextSleep);
+    if ( initRun() == success ) {
+      break;
+    }
+    else {
+      _nextSleep *= 2;
+    }
+  }
+  _nextSleep = 1;
+}

trunk/BNC/bncgetthread.h

@@ -7 +7 @@
 
 #include "RTCM/GPSDecoder.h"
+#include "bncconst.h"
 
 class bncGetThread : public QThread {
@@ -27 +28 @@
  protected:
    virtual void run();
+
  private:
-   void initRun();
-   void tryReconnect();
-   void message(const QString&);
-   void exit(int exitCode = 0);
+   t_irc initRun();
+   void  message(const QString&);
+   void  exit(int exitCode = 0);
+   void  tryReconnect();
    GPSDecoder* _decoder;
    QTcpSocket* _socket;
@@ -38 +40 @@
    QByteArray  _format;
    int         _timeOut;
+   int         _nextSleep;
 };