Changeset 937 in ntrip

Timestamp:

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

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bncapp.cpp (modified) (4 diffs)
• bncapp.h (modified) (3 diffs)
• bncmain.cpp (modified) (1 diff)
• bncwindow.cpp (modified) (1 diff)

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();
+      }
+    }
+  }
+}

trunk/BNC/bncapp.h

@@ -39 +39 @@
     virtual ~bncApp();  
     QString bncVersion() const {return _bncVersion;}
-    void    setPort(int port);
+    void setPort(int port);
+    void setPortCorr(int port);
     void setCaster(bncCaster* caster) {_caster = caster;}
   public slots:
@@ -50 +51 @@
  private slots:
    void slotNewConnection();
+   void slotNewConnectionCorr();
   private:
     void printEphHeader();
@@ -74 +76 @@
     QTcpServer*         _server;
     QList<QTcpSocket*>* _sockets;
+    int                 _portCorr;
+    QTcpServer*         _serverCorr;
+    QList<QTcpSocket*>* _socketsCorr;
     bncCaster*          _caster;
 };

trunk/BNC/bncmain.cpp

@@ -126 +126 @@
 
     app.setPort(settings.value("outEphPort").toInt());
+    app.setPortCorr(settings.value("corrPort").toInt());
 
     app.connect(caster, SIGNAL(getThreadErrors()), &app, SLOT(quit()));

trunk/BNC/bncwindow.cpp

@@ -638 +638 @@
 
   ((bncApp*)qApp)->setPort(_outEphPortLineEdit->text().toInt());
+  ((bncApp*)qApp)->setPortCorr(_corrPortLineEdit->text().toInt());
 
   connect(_caster, SIGNAL(getThreadErrors()),