Changeset 1414 in ntrip

Timestamp:

Dec 31, 2008, 1:07:51 PM (15 years ago)

Author:

mervart

Message:

* empty log message *

File:

• trunk/BNC/bncnetqueryrtp.cpp (modified) (5 diffs)

trunk/BNC/bncnetqueryrtp.cpp

@@ -29 +29 @@
   _socket    = 0;
   _udpSocket = 0;
+  _eventLoop = new QEventLoop(this);
 }
 
@@ -34 +35 @@
 ////////////////////////////////////////////////////////////////////////////
 bncNetQueryRtp::~bncNetQueryRtp() {
+  delete _eventLoop;
   delete _socket;
   delete _udpSocket;
@@ -41 +43 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncNetQueryRtp::stop() {
-#ifndef sparc
-  if (_socket) {
-    _socket->abort();
-  }
-#endif
+  _eventLoop->quit();
   _status = finished;
 }
@@ -57 +55 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncNetQueryRtp::waitForReadyRead(QByteArray& outData) {
+
+  // Wait Loop
+  // ---------
+  if (!_udpSocket->hasPendingDatagrams()) {
+    _eventLoop->exec();
+  }
+
+  // Append Data
+  // -----------
+  QByteArray datagram;
+  datagram.resize(_udpSocket->pendingDatagramSize());
+  _udpSocket->readDatagram(datagram.data(), datagram.size());
+  outData.append(datagram);
 }
 
@@ -104 +115 @@
     _udpSocket = new QUdpSocket();
     _udpSocket->bind(clientPort.toInt());
+    connect(_udpSocket, SIGNAL(readyRead()), _eventLoop, SLOT(quit()));
     
     QByteArray reqStr;