Changeset 5646 in ntrip for trunk/BNC/src

Timestamp:

Feb 23, 2014, 10:29:42 AM (11 years ago)

Author:

weber

Message:

Ras stream output through TCP/IP port enabled

File:

• trunk/BNC/src/bncgetthread.cpp (modified) (6 diffs)

trunk/BNC/src/bncgetthread.cpp ¶

@@ -104 +104 @@
 
   bncSettings settings;
+
   if (!settings.value("rawOutFile").toString().isEmpty()) {
     _rawOutput = true;
@@ -131 +132 @@
   _miscMount     = settings.value("miscMount").toString();
   _decoder   = 0;
+
+  // Miscellaneous output port  // Georg
+  // -------------------------
+  _miscPort = settings.value("miscPort").toInt();
+  if (_miscPort != 0) {
+    _miscServer = new QTcpServer;
+    if ( !_miscServer->listen(QHostAddress::Any, _miscPort) ) {
+      emit newMessage("bncgetthread: Cannot listen on Miscellaneous Output Port", true);
+    }
+    connect(_miscServer, SIGNAL(newConnection()), this, SLOT(slotNewMiscConnection()));
+    _miscSockets = new QList<QTcpSocket*>;
+  }
+  else {
+    _miscServer  = 0;
+    _miscSockets = 0;
+  }
 
   // Serial Port
@@ -383 +400 @@
   delete _serialPort;
   delete _latencyChecker;
+  delete _miscServer;
+  delete _miscSockets;
   emit getThreadFinished(_staID);
 }
@@ -473 +492 @@
         _serialPort->write(data);
       }
-      
+
+      // Output into the Miscellaneous socket // Georg
+      // ------------------------------------
+      if (_miscSockets && _miscMount != "ALL") {
+        QMutableListIterator<QTcpSocket*> is(*_miscSockets);
+        while (is.hasNext()) {
+          QTcpSocket* sock = is.next();
+          if (sock->state() == QAbstractSocket::ConnectedState) {
+            if (myMiscWrite(sock, data, nBytes) != nBytes) {
+              delete sock;
+              is.remove();
+            }       
+          }       
+          else if (sock->state() != QAbstractSocket::ConnectingState) {
+            delete sock;
+            is.remove();
+          }       
+        }       
+      } 
+
       // Decode Data
       // -----------
@@ -671 +709 @@
 }
 
+// New Connection // Georg
+////////////////////////////////////////////////////////////////////////////
+void bncGetThread::slotNewMiscConnection() {
+  _miscSockets->push_back( _miscServer->nextPendingConnection() );
+  emit( newMessage(QString("New client connection on Miscellaneous Output Port: # %1")
+                   .arg(_miscSockets->size()).toAscii(), true) );
+}
+
+// Write buffer // Georg
+////////////////////////////////////////////////////////////////////////////
+int bncGetThread::myMiscWrite(QTcpSocket* sock, const char* buf, int bufLen) {
+  sock->write(buf, bufLen);
+  for (int ii = 1; ii <= 10; ii++) {
+    if (sock->waitForBytesWritten(10)) {  // wait 10 ms
+      return bufLen;
+    }
+  }
+  return -1;
+}
+
 // RTCM scan output
 //////////////////////////////////////////////////////////////////////////////
@@ -807 +865 @@
   }
 }
+