Index: /trunk/BNS/bnscaster.cpp
===================================================================
--- /trunk/BNS/bnscaster.cpp	(revision 2644)
+++ /trunk/BNS/bnscaster.cpp	(revision 2645)
@@ -93,5 +93,5 @@
 // Start the Communication with NTRIP Caster
 ////////////////////////////////////////////////////////////////////////////
-void t_bnscaster::open(bool force) {
+void t_bnscaster::open() {
 
   if (_mountpoint.isEmpty()) {
@@ -99,10 +99,7 @@
   }
 
-  if (_outSocket != 0) {
-    if ( _outSocket->state() == QAbstractSocket::HostLookupState ||
-         _outSocket->state() == QAbstractSocket::ConnectingState ||
-         _outSocket->state() == QAbstractSocket::ConnectedState ) {
-      return;
-    }
+  if (_outSocket != 0 && 
+      _outSocket->state() == QAbstractSocket::ConnectedState) {
+    return;
   }
 
@@ -113,6 +110,5 @@
     _sOpenTrial = 4;
   }
-  if (!force &&
-      _outSocketOpenTime.isValid() &&
+  if (_outSocketOpenTime.isValid() &&
       _outSocketOpenTime.secsTo(QDateTime::currentDateTime()) < minDt) {
     return;
@@ -221,18 +217,7 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_bnscaster::write(char* buffer, unsigned len) {
-  for (int iTrial = 1; iTrial <= 2; ++iTrial) {
-    if (_outSocket) {
-      unsigned bytesWritten = _outSocket->write(buffer, len);
-      if (bytesWritten == len) {
-        _outSocket->flush();
-        break;
-      }
-      else {
-        emit(newMessage("Broadcaster: cannot write to socket, closing"));
-        delete _outSocket;
-        _outSocket = 0;
-        open(true);
-      }
-    }
+  if (_outSocket) {
+    _outSocket->write(buffer, len);
+    _outSocket->flush();
   }
 }
Index: /trunk/BNS/bnscaster.h
===================================================================
--- /trunk/BNS/bnscaster.h	(revision 2644)
+++ /trunk/BNS/bnscaster.h	(revision 2645)
@@ -10,5 +10,5 @@
   t_bnscaster(const QString& mountpoint);
   virtual ~t_bnscaster();
-  void open(bool force = false);
+  void open();
   void write(char* buffer, unsigned len);
   void printAscii(const QString& line);
Index: /trunk/BNS/bnseph.cpp
===================================================================
--- /trunk/BNS/bnseph.cpp	(revision 2644)
+++ /trunk/BNS/bnseph.cpp	(revision 2645)
@@ -90,5 +90,6 @@
   const int timeOut = 30*1000;  // 30 seconds
   if (!_socket->waitForConnected(timeOut)) {
-    emit(newMessage("bnseph::reconnect: Connect Timeout"));
+//  emit(newMessage("bnseph::run Connect Timeout"));
+    emit(newMessage("Ephemeris server: Connection timeout")); // weber
     msleep(1000);
   }
@@ -99,10 +100,10 @@
 void t_bnseph::run() {
 
-  emit(newMessage("bnseph::run: Start"));
+//emit(newMessage("bnseph::run Start"));
+  emit(newMessage("Ephemeris server: Connection opened")); // weber
 
   while (true) {
     if ( _socket == 0 ||
-         (_socket->state() != QAbstractSocket::HostLookupState &&
-          _socket->state() != QAbstractSocket::ConnectingState &&
+         (_socket->state() != QAbstractSocket::ConnectingState &&
           _socket->state() != QAbstractSocket::ConnectedState) ) {
       reconnect();