Changeset 937 in ntrip for trunk/BNC/bncapp.cpp

Timestamp:

Jun 8, 2008, 5:48:54 PM (16 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncapp.cpp (modified) (4 diffs)

trunk/BNC/bncapp.cpp

@@ -98 +98 @@
   _sockets = 0;
 
+  _portCorr    = 0;
+  _serverCorr  = 0;
+  _socketsCorr = 0;
+
   _pgmName  = _bncVersion.leftJustified(20, ' ', true);
 #ifdef WIN32
@@ -117 +121 @@
   delete _server;
   delete _sockets;
+  delete _serverCorr;
+  delete _socketsCorr;
   if (_rinexVers == 2) {
     delete _ephStreamGlonass;
@@ -555 +561 @@
 }
 
+// Set Port Number
+////////////////////////////////////////////////////////////////////////////
+void bncApp::setPortCorr(int port) {
+  _portCorr = port;
+  if (_portCorr != 0) {
+    _serverCorr = new QTcpServer;
+    _serverCorr->listen(QHostAddress::Any, _portCorr);
+    connect(_serverCorr, SIGNAL(newConnection()), this, SLOT(slotNewConnectionCorr()));
+    _socketsCorr = new QList<QTcpSocket*>;
+  }
+}
+
 // New Connection
 ////////////////////////////////////////////////////////////////////////////
 void bncApp::slotNewConnection() {
   _sockets->push_back( _server->nextPendingConnection() );
+}
+
+// New Connection
+////////////////////////////////////////////////////////////////////////////
+void bncApp::slotNewConnectionCorr() {
+  _socketsCorr->push_back( _serverCorr->nextPendingConnection() );
 }
 
@@ -569 +593 @@
 }
 
-
 // 
 ////////////////////////////////////////////////////////////////////////////
 void bncApp::slotNewCorrLine(QString line) {
-  cout << line.toAscii().data() << endl;
-}
+  if (_socketsCorr) {
+    QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
+    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();
+      }
+    }
+  }
+}