Index: trunk/BNS/bnscaster.cpp
===================================================================
--- trunk/BNS/bnscaster.cpp	(revision 1060)
+++ trunk/BNS/bnscaster.cpp	(revision 1060)
@@ -0,0 +1,101 @@
+/* -------------------------------------------------------------------------
+ * BKG NTRIP Server
+ * -------------------------------------------------------------------------
+ *
+ * Class:      bnscaster
+ *
+ * Purpose:    Connection to NTRIP Caster
+ *
+ * Author:     L. Mervart
+ *
+ * Created:    27-Aug-2008
+ *
+ * Changes:    
+ *
+ * -----------------------------------------------------------------------*/
+
+#include <math.h>
+#include "bnscaster.h" 
+
+using namespace std;
+
+// Constructor
+////////////////////////////////////////////////////////////////////////////
+t_bnscaster::t_bnscaster(const QString& mountpoint) {
+  _mountpoint         = mountpoint;
+  _outSocketOpenTrial = 0;
+}
+
+// Destructor
+////////////////////////////////////////////////////////////////////////////
+t_bnscaster::~t_bnscaster() {
+  delete _outSocket;
+}
+
+// Start the Communication with NTRIP Caster
+////////////////////////////////////////////////////////////////////////////
+void t_bnscaster::open() {
+
+  if (_outSocket != 0 && 
+      _outSocket->state() == QAbstractSocket::ConnectedState) {
+    return;
+  }
+
+  delete _outSocket; _outSocket = 0;
+
+  double minDt = exp2(_outSocketOpenTrial);
+  if (++_outSocketOpenTrial > 8) {
+    _outSocketOpenTrial = 8;
+  }
+  if (_outSocketOpenTime.isValid() &&
+      _outSocketOpenTime.secsTo(QDateTime::currentDateTime()) < minDt) {
+    return;
+  }
+  else {
+    _outSocketOpenTime = QDateTime::currentDateTime();
+  }
+
+  QSettings settings;
+  _outSocket = new QTcpSocket();
+  _outSocket->connectToHost(settings.value("outHost").toString(),
+                            settings.value("outPort").toInt());
+
+  const int timeOut = 100;  // 0.1 seconds
+  if (!_outSocket->waitForConnected(timeOut)) {
+    delete _outSocket;
+    _outSocket = 0;
+    emit(error("bns::openCaster Connect Timeout"));
+    return;
+  }
+
+  QString password   = settings.value("password").toString();
+
+  QByteArray msg = "SOURCE " + password.toAscii() + " /" + 
+                   _mountpoint.toAscii() + "\r\n" +
+                   "Source-Agent: NTRIP BNS/1.0\r\n\r\n";
+
+  _outSocket->write(msg);
+  _outSocket->waitForBytesWritten();
+
+  _outSocket->waitForReadyRead();
+  QByteArray ans = _outSocket->readLine();
+
+  if (ans.indexOf("OK") == -1) {
+    delete _outSocket;
+    _outSocket = 0;
+    emit(newMessage("bns::openCaster socket deleted"));
+  }
+  else {
+    emit(newMessage("bns::openCaster socket OK"));
+    _outSocketOpenTrial = 0;
+  }
+}
+
+// Write buffer
+////////////////////////////////////////////////////////////////////////////
+void t_bnscaster::write(char* buffer, unsigned len) {
+  if (_outSocket) {
+    _outSocket->write(buffer, len);
+    _outSocket->flush();
+  }
+}
Index: trunk/BNS/bnscaster.h
===================================================================
--- trunk/BNS/bnscaster.h	(revision 1060)
+++ trunk/BNS/bnscaster.h	(revision 1060)
@@ -0,0 +1,25 @@
+#ifndef BNSCASTER_H
+#define BNSCASTER_H
+
+#include <QtNetwork>
+
+class t_bnscaster {
+ Q_OBJECT
+ public:
+  t_bnscaster(const QString& mountpoint);
+  ~t_bnscaster();
+  void open();
+  void write(char* buffer, unsigned len);
+
+ signals:
+  void error(const QByteArray msg);
+  void newMessage(const QByteArray msg);
+
+ private:
+  QString     _mountpoint;
+  QTcpSocket* _outSocket;
+  int         _outSocketOpenTrial;
+  QDateTime   _outSocketOpenTime;
+};
+
+#endif