Changeset 934 in ntrip for trunk/BNC/RTCM3

Timestamp:

Jun 8, 2008, 4:33:04 PM (16 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC/RTCM3

Files:

• RTCM3coDecoder.cpp (modified) (6 diffs)
• RTCM3coDecoder.h (modified) (2 diffs)

trunk/BNC/RTCM3/RTCM3coDecoder.cpp

@@ -44 +44 @@
 #include "RTCM3coDecoder.h"
 #include "bncutils.h"
+#include "bncrinex.h"
 
 using namespace std;
@@ -49 +50 @@
 // Constructor
 ////////////////////////////////////////////////////////////////////////////
-RTCM3coDecoder::RTCM3coDecoder(const QString& fileName) 
-  : bncZeroDecoder(fileName) {
+RTCM3coDecoder::RTCM3coDecoder(const QString& fileName) {
+
+  // File Output
+  // -----------
+  QSettings settings;
+  QString path = settings.value("corrPath").toString();
+  if (!path.isEmpty()) {
+    expandEnvVar(path);
+    if ( path.length() > 0 && path[path.length()-1] != QDir::separator() ) {
+      path += QDir::separator();
+    }
+    _fileNameSkl = path + fileName;
+  }
+  _out = 0;
+
+  // Socket Server
+  // -------------
+  int port = settings.value("corrPort").toInt();
+  if (port != 0) {
+    _server = new QTcpServer;
+    _server->listen(QHostAddress::Any, port);
+    connect(_server, SIGNAL(newConnection()), this, SLOT(slotNewConnection()));
+    _sockets = new QList<QTcpSocket*>;
+  }
+  else {
+    delete _sockets;
+    delete _server;
+  }
 }
 
@@ -56 +83 @@
 ////////////////////////////////////////////////////////////////////////////
 RTCM3coDecoder::~RTCM3coDecoder() {
+}
+
+// Reopen Output File
+//////////////////////////////////////////////////////////////////////// 
+void RTCM3coDecoder::reopen() {
+
+  if (!_fileNameSkl.isEmpty()) {
+
+    QSettings settings;
+
+    QDateTime datTim = QDateTime::currentDateTime().toUTC();
+
+    QString hlpStr = bncRinex::nextEpochStr(datTim,
+                                      settings.value("corrIntr").toString());
+
+    QString fileName = _fileNameSkl 
+      + QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0'))
+      + datTim.toString(".yyC");
+
+    if (_fileName == fileName) {
+      return;
+    }
+    else {
+      _fileName = fileName;
+    }
+
+    delete _out;
+    _out = new ofstream( _fileName.toAscii().data() );
+  }
+}
+
+// New Connection
+////////////////////////////////////////////////////////////////////////////
+void RTCM3coDecoder::slotNewConnection() {
+  _sockets->push_back( _server->nextPendingConnection() );
 }
 
@@ -126 +188 @@
                _co.Sat[ii].Orbit.DeltaAlongTrack,
                _co.Sat[ii].Orbit.DeltaCrossTrack);
-        *_out << line.toAscii().data();
+        printLine(line);
       }
       for(int ii = CLOCKORBIT_NUMGPS; 
@@ -137 +199 @@
                _co.Sat[ii].Orbit.DeltaAlongTrack,
                _co.Sat[ii].Orbit.DeltaCrossTrack);
-        *_out << line.toAscii().data();
-      }
-      _out->flush();
+        printLine(line);
+      }
       _buffer = _buffer.substr(bytesused);
       return success;
@@ -151 +212 @@
   }
 }
+
+// 
+////////////////////////////////////////////////////////////////////////////
+void RTCM3coDecoder::printLine(const QString& line) {
+
+  if (_out) {
+    *_out << line.toAscii().data();
+    _out->flush();
+  }
+
+  if (_sockets) {
+    QMutableListIterator<QTcpSocket*> is(*_sockets);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+        if (sock->write(line.toAscii()) == -1) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
+}

trunk/BNC/RTCM3/RTCM3coDecoder.h

@@ -26 +26 @@
 #define RTCM3CODECODER_H
 
-#include "bnczerodecoder.h"
+#include <fstream>
+
+#include <QtCore>
+#include <QtNetwork>
+
+#include "RTCM/GPSDecoder.h"
 
 extern "C" {
@@ -32 +37 @@
 }
 
-class RTCM3coDecoder : public bncZeroDecoder {
-public:
+class RTCM3coDecoder : public QObject, public GPSDecoder {
+Q_OBJECT
+ public:
   RTCM3coDecoder(const QString& fileName);
   virtual ~RTCM3coDecoder();
   virtual t_irc Decode(char* buffer = 0, int bufLen = 0);
-private:
-  std::string _buffer;
-  ClockOrbit  _co;
-  Bias        _bias;
-} ;
+
+ private slots:
+  void slotNewConnection();
+
+ private:
+  void reopen();
+  void printLine(const QString& line);
+
+  std::ofstream*      _out;
+  QString             _fileNameSkl;
+  QString             _fileName;
+  std::string         _buffer;
+  ClockOrbit          _co;
+  Bias                _bias;
+  QTcpServer*         _server;
+  QList<QTcpSocket*>* _sockets;
+};
 
 #endif