Changeset 759 in ntrip for trunk

Timestamp:

Mar 30, 2008, 6:08:45 PM (17 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNS

Files:

• bnseph.cpp (modified) (3 diffs)
• bnseph.h (modified) (2 diffs)

trunk/BNS/bnseph.cpp

@@ -22 +22 @@
 ////////////////////////////////////////////////////////////////////////////
 t_bnseph::t_bnseph(QObject* parent) : QThread(parent) {
+  _socket = 0;
 }
 
@@ -27 +28 @@
 ////////////////////////////////////////////////////////////////////////////
 t_bnseph::~t_bnseph() {
+  delete _socket;
 }
 
@@ -32 +34 @@
 ////////////////////////////////////////////////////////////////////////////
 void t_bnseph::run() {
-  emit(newMessage("============ Start bnseph ============"));
+
+  emit(newMessage("bnseph::run Start"));
+
+  // Connect the Socket
+  // ------------------
+  QSettings settings;
+  QString host = settings.value("ephHost").toString();
+  int     port = settings.value("ephPort").toInt();
+
+  _socket = new QTcpSocket();
+  _socket->connectToHost(host, port);
+
+  const int timeOut = 10*1000;  // 10 seconds
+  if (!_socket->waitForConnected(timeOut)) {
+    emit(newMessage("bnseph::run Connect Timeout"));
+    delete _socket; _socket = 0;
+    return;
+  }
+
+  while (true) {
+    if (_socket->canReadLine()) {
+      QByteArray line = _socket->readLine();
+      emit(newMessage(line));
+    }
+    else {
+      _socket->waitForReadyRead(10);
+    }
+  }
 }
 

trunk/BNS/bnseph.h

@@ -3 +3 @@
 
 #include <QThread>
-#include <QMutex>
+#include <QtNetwork>
 
 class t_bnseph : public QThread {
@@ -16 +16 @@
  
  private:
-  QMutex _mutex;
+  QTcpSocket* _socket;
 };
 #endif