caProvider threads: Lock the mutex while reading isStop state

src/ca/channelConnectThread.cpp

@@ -105,7 +105,7 @@ void ChannelConnectThread::run()
                  if(channel) channel->notifyClient();
              }
          }
-         if(isStop) {
+         if(stopping()) {
              waitForStop.signal();
              break;
          }

src/ca/channelConnectThread.h

@@ -56,6 +56,10 @@ public:
     void channelConnected(NotifyChannelRequesterPtr const &notifyChannelRequester);
 private:
     ChannelConnectThread();
+    bool stopping() {
+        pvData::Lock the(mutex);
+        return isStop;
+    }
 
     bool isStop;
     std::tr1::shared_ptr<epicsThread> thread;

src/ca/getDoneThread.cpp

@@ -104,7 +104,7 @@ void GetDoneThread::run()
                  if(channelGet) channelGet->notifyClient();
              }
          }
-         if(isStop) {
+         if(stopping()) {
              waitForStop.signal();
              break;
          }

src/ca/getDoneThread.h

@@ -56,6 +56,10 @@ public:
     void getDone(NotifyGetRequesterPtr const &notifyGetRequester);
 private:
     GetDoneThread();
+    bool stopping() {
+        pvData::Lock the(mutex);
+        return isStop;
+    }
 
     bool isStop;
     std::tr1::shared_ptr<epicsThread> thread;

src/ca/monitorEventThread.cpp

@@ -103,7 +103,7 @@ void MonitorEventThread::run()
                  if(channelMonitor) channelMonitor->notifyClient();
              }
          }
-         if(isStop) {
+         if(stopping()) {
              waitForStop.signal();
              break;
          }

src/ca/monitorEventThread.h

@@ -56,6 +56,10 @@ public:
     void event(NotifyMonitorRequesterPtr const &notifyMonitorRequester);
 private:
     MonitorEventThread();
+    bool stopping() {
+        pvData::Lock the(mutex);
+        return isStop;
+    }
 
     bool isStop;
     std::tr1::shared_ptr<epicsThread> thread;

src/ca/putDoneThread.cpp

@@ -104,7 +104,7 @@ void PutDoneThread::run()
                  if(channelPut) channelPut->notifyClient();
              }
          }
-         if(isStop) {
+         if(stopping()) {
              waitForStop.signal();
              break;
          }

src/ca/putDoneThread.h

@@ -56,6 +56,11 @@ public:
     void putDone(NotifyPutRequesterPtr const &notifyPutRequester);
 private:
     PutDoneThread();
+    bool stopping() {
+        pvData::Lock the(mutex);
+        return isStop;
+    }
+
     bool isStop;
     std::tr1::shared_ptr<epicsThread> thread;
     epics::pvData::Mutex mutex;