Changeset 1222 in ntrip for trunk/BNC/bnccaster.cpp

Timestamp:

Nov 22, 2008, 2:09:45 PM (15 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bnccaster.cpp (modified) (6 diffs)

trunk/BNC/bnccaster.cpp

@@ -87 +87 @@
   }
 
+  int uPort = settings.value("outUPort").toInt();
+  if (uPort != 0) {
+    _uServer = new QTcpServer;
+    _uServer->listen(QHostAddress::Any, uPort);
+    connect(_uServer, SIGNAL(newConnection()), this, SLOT(slotNewUConnection()));
+    _uSockets = new QList<QTcpSocket*>;
+  }
+  else {
+    _uServer  = 0;
+    _uSockets = 0;
+  }
+
   _epochs = new QMultiMap<long, p_obs>;
 
@@ -111 +123 @@
   delete _server;
   delete _sockets;
+  delete _uServer;
+  delete _uSockets;
   if (_epochs) {
     QListIterator<p_obs> it(_epochs->values());
@@ -136 +150 @@
   obs->_o.StatID[sizeof(obs->_o.StatID)-1] = '\0';
         
+  const char begObs[] = "BEGOBS";
+  const int begObsNBytes = sizeof(begObs) - 1;
+
+  // Output into the socket
+  // ----------------------
+  if (_uSockets) {
+    QMutableListIterator<QTcpSocket*> is(*_uSockets);
+    while (is.hasNext()) {
+      QTcpSocket* sock = is.next();
+      if (sock->state() == QAbstractSocket::ConnectedState) {
+        bool ok = true;
+        if (myWrite(sock, begObs, begObsNBytes) != begObsNBytes) {
+          ok = false;
+        }
+        int numBytes = sizeof(obs->_o); 
+        if (myWrite(sock, (const char*)(&obs->_o), numBytes) != numBytes) {
+          ok = false;
+        }
+        if (!ok) {
+          delete sock;
+          is.remove();
+        }
+      }
+      else if (sock->state() != QAbstractSocket::ConnectingState) {
+        delete sock;
+        is.remove();
+      }
+    }
+  }
+
   // First time, set the _lastDumpSec immediately
   // --------------------------------------------
@@ -175 +219 @@
   emit( newMessage(QString("New Connection # %1")
                    .arg(_sockets->size()).toAscii()) );
+}
+
+void bncCaster::slotNewUConnection() {
+  _uSockets->push_back( _uServer->nextPendingConnection() );
+  emit( newMessage(QString("New Connection (usync) # %1")
+                   .arg(_uSockets->size()).toAscii()) );
 }
 
@@ -273 +323 @@
           while (is.hasNext()) {
             QTcpSocket* sock = is.next();
-            int myFlag = 0;
             if (sock->state() == QAbstractSocket::ConnectedState) {
               bool ok = true;
               if (first) {
                 if (myWrite(sock, begEpoch, begEpochNBytes) != begEpochNBytes) {
-                  myFlag = 1;
                   ok = false;
                 }
@@ -284 +332 @@
               int numBytes = sizeof(obs->_o); 
               if (myWrite(sock, (const char*)(&obs->_o), numBytes) != numBytes) {
-                myFlag = 2;
                 ok = false;
               }
               if (!it.hasNext()) {
                 if (myWrite(sock, endEpoch, endEpochNBytes) != endEpochNBytes) {
-                  myFlag = 3;
                   ok = false;
                 }