Changeset 385 in ntrip for trunk/BNC

Timestamp:

Feb 1, 2007, 8:12:51 AM (18 years ago)

Author:

mervart

Message:

* empty log message *

File:

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

trunk/BNC/bnccaster.cpp

@@ -120 +120 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncCaster::reconnecting(const QByteArray& staID) {
+  QMutexLocker locker(&_mutex);
   if (_rinexWriters.find(staID) != _rinexWriters.end()) {
     bncRinex* rnx = _rinexWriters.find(staID).value();
@@ -186 +187 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncCaster::dumpEpochSlot() {
+  QMutexLocker locker(&_mutex);
   if (_newTime != 0 && _epochs->size() > 0) {
     dumpEpochs(_lastDumpSec + 1, _newTime - _waitTime);
@@ -199 +201 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncCaster::slotNewConnection() {
+  QMutexLocker locker(&_mutex);
   _sockets->push_back( _server->nextPendingConnection() );
 }
@@ -205 +208 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncCaster::addGetThread(bncGetThread* getThread) {
+  QMutexLocker locker(&_mutex);
   connect(getThread, SIGNAL(error(const QByteArray&)), 
           this, SLOT(slotGetThreadError(const QByteArray&)));
@@ -228 +232 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncCaster::dumpEpochs(long minTime, long maxTime) {
+  QMutexLocker locker(&_mutex);
 
   const char begEpoch = 'A';