Changeset 3226 in ntrip for trunk/BNC/upload/bncuploadcaster.cpp
- Timestamp:
- Mar 31, 2011, 6:10:51 PM (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/BNC/upload/bncuploadcaster.cpp
r3224 r3226 38 38 _sOpenTrial = 0; 39 39 _isToBeDeleted = false; 40 41 40 } 42 41 … … 55 54 if (isRunning()) { 56 55 wait(); 56 } 57 } 58 59 // Endless Loop 60 //////////////////////////////////////////////////////////////////////////// 61 void bncUploadCaster::run() { 62 while (true) { 63 if (_isToBeDeleted) { 64 QThread::quit(); 65 deleteLater(); 66 return; 67 } 68 open(); 69 if (_outSocket && _outSocket->state() == QAbstractSocket::ConnectedState) { 70 QMutexLocker locker(&_mutex); 71 _outSocket->write(_outBuffer); 72 _outSocket->flush(); 73 _outBuffer.clear(); 74 } 75 else { 76 QMutexLocker locker(&_mutex); 77 _outBuffer.clear(); 78 } 79 sleep(5); 57 80 } 58 81 } … … 117 140 } 118 141 119 // Write buffer120 ////////////////////////////////////////////////////////////////////////////121 void bncUploadCaster::write(char* buffer, unsigned len) {122 if (_outSocket && _outSocket->state() == QAbstractSocket::ConnectedState) {123 _outSocket->write(buffer, len);124 _outSocket->flush();125 }126 }127
Note:
See TracChangeset
for help on using the changeset viewer.