Changeset 3226 in ntrip for trunk/BNC/upload/bncuploadcaster.cpp

Timestamp:

Mar 31, 2011, 6:10:51 PM (13 years ago)

Author:

mervart

Message:

 

File:

• trunk/BNC/upload/bncuploadcaster.cpp (modified) (3 diffs)

trunk/BNC/upload/bncuploadcaster.cpp

@@ -38 +38 @@
   _sOpenTrial    = 0;
   _isToBeDeleted = false;
-
 }
 
@@ -55 +54 @@
   if (isRunning()) {
     wait();
+  }
+}
+
+// Endless Loop
+////////////////////////////////////////////////////////////////////////////
+void bncUploadCaster::run() {
+  while (true) {
+    if (_isToBeDeleted) {
+      QThread::quit();
+      deleteLater();
+      return;
+    }
+    open();
+    if (_outSocket && _outSocket->state() == QAbstractSocket::ConnectedState) {
+      QMutexLocker locker(&_mutex);
+      _outSocket->write(_outBuffer);
+      _outSocket->flush();
+      _outBuffer.clear();
+    }
+    else {
+      QMutexLocker locker(&_mutex);
+      _outBuffer.clear();
+    }
+    sleep(5);
   }
 }
@@ -117 +140 @@
 }
 
-// Write buffer
-////////////////////////////////////////////////////////////////////////////
-void bncUploadCaster::write(char* buffer, unsigned len) {
-  if (_outSocket && _outSocket->state() == QAbstractSocket::ConnectedState) {
-    _outSocket->write(buffer, len);
-    _outSocket->flush();
-  }
-}
-