Changeset 2178 in ntrip for trunk

Timestamp:

Jan 4, 2010, 1:48:00 PM (15 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bncmodel.cpp (modified) (5 diffs)
• bncmodel.h (modified) (3 diffs)

trunk/BNC/bncmodel.cpp

@@ -187 +187 @@
     writeNMEAstr(nmStr);
   }
+
+  int port = 7777;
+
+  if (port != 0) {
+    _server = new QTcpServer;
+    if ( !_server->listen(QHostAddress::Any, port) ) {
+      emit newMessage("bncModel: Cannot listen on sync port", true);
+    }
+    connect(_server, SIGNAL(newConnection()), this, SLOT(slotNewConnection()));
+    _sockets = new QList<QTcpSocket*>;
+  }
+  else {
+    _server  = 0;
+    _sockets = 0;
+  }
+
+
 }
 
@@ -194 +211 @@
   delete _nmeaStream;
   delete _nmeaFile;
+  delete _server;
+  delete _sockets;
+}
+
+// New Connection
+////////////////////////////////////////////////////////////////////////////
+void bncModel::slotNewConnection() {
+  _sockets->push_back( _server->nextPendingConnection() );
+  emit( newMessage(QString("PPP: new connection on port: # %1")
+                   .arg(_sockets->size()).toAscii(), true) );
 }
 
@@ -562 +589 @@
   // NMEA Output
   // -----------
-  if (_nmeaStream) {
+  if (_nmeaStream || _sockets) {
     double xyz[3]; 
     xyz[0] = x();
@@ -668 +695 @@
 void bncModel::writeNMEAstr(const QString& nmStr) {
 
-  if (!_nmeaStream) {
-    return;
-  }
-
   unsigned char XOR = 0;
   for (int ii = 0; ii < nmStr.length(); ii++) {
@@ -677 +700 @@
   }
   
-  *_nmeaStream << '$' << nmStr << '*' << hex << (int) XOR << endl;
-
-  _nmeaStream->flush();
-}
+  if (_nmeaStream) {
+    *_nmeaStream << '$' << nmStr << '*' << hex << (int) XOR << endl;
+    _nmeaStream->flush();
+  }
+
+  if (_sockets) {
+    QMutableListIterator<QTcpSocket*> is(*_sockets);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+//        *sock << '$' << nmStr << '*' << hex << (int) XOR << endl;
+//        sock->flush();
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
+}

trunk/BNC/bncmodel.h

@@ -27 +27 @@
 
 #include <QtCore>
+#include <QtNetwork>
 #include <newmat.h>
 
@@ -68 +69 @@
   void newMessage(QByteArray msg, bool showOnScreen);
 
+ private slots:
+  void slotNewConnection();
+
  private:
   double cmpValue(t_satData* satData);
@@ -89 +93 @@
   QFile*             _nmeaFile;
   QTextStream*       _nmeaStream;
+  QTcpServer*         _server;
+  QList<QTcpSocket*>* _sockets;
 };