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

Timestamp:

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

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncgetthread.cpp (modified) (7 diffs)

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;
+}