Add missing barriers for Object::m_LockOwner

refs #7648

lib/base/object.cpp

@@ -31,7 +31,7 @@ REGISTER_PRIMITIVE_TYPE(Object);
 Object::Object(void)
 	: m_References(0)
 #ifdef _DEBUG
-	, m_Locked(false)
+	, m_LockOwner(0)
 #endif /* _DEBUG */
 { }
 
@@ -49,8 +49,15 @@ Object::~Object(void)
  */
 bool Object::OwnsLock(void) const
 {
-	// TODO: barrier before reading m_Locked
+#ifdef _WIN32
-	return (m_Locked && m_LockOwner == boost::this_thread::get_id());
+	DWORD tid = InterlockedExchangeAdd(&m_LockOwner, 0);
+
+	return (tid == GetCurrentThreadId());
+#else /* _WIN32 */
+	pthread_t tid = __sync_fetch_and_add(&m_LockOwner, 0);
+
+	return (tid == pthread_self());
+#endif /* _WIN32 */
 }
 #endif /* _DEBUG */
 

lib/base/object.hpp

@@ -109,8 +109,11 @@ private:
 	mutable ThinMutex m_Mutex;
 
 #ifdef _DEBUG
-	mutable bool m_Locked;
+#	ifndef _WIN32
-	mutable boost::thread::id m_LockOwner;
+	mutable pthread_t m_LockOwner;
+#	else /* _WIN32 */
+	mutable DWORD m_LockOwner;
+#	endif /* _WIN32 */
 #endif /* _DEBUG */
 
 	friend struct ObjectLock;

lib/base/objectlock.hpp

@@ -62,18 +62,25 @@ public:
 		m_Locked = true;
 
 #ifdef _DEBUG
-		m_Object->m_Locked = true;
+#	ifdef _WIN32
-		// TODO: barrier after writing m_Locked
+		InterlockedExchange(&m_Object->m_LockOwner, GetCurrentThreadId());
-		m_Object->m_LockOwner = boost::this_thread::get_id();
+#	else /* _WIN32 */
+		__sync_lock_test_and_set(&m_Object->m_LockOwner, pthread_self());
+#	endif /* _WIN32 */
 #endif /* _DEBUG */
 	}
 
 	inline void Unlock(void)
 	{
-	#ifdef _DEBUG
+#ifdef _DEBUG
-		if (m_Locked)
+		if (m_Locked) {
-			m_Object->m_Locked = false;
+#	ifdef _WIN32
-	#endif /* _DEBUG */
+			InterlockedExchange(&m_Object->m_Locked, 0);
+#	else /* _WIN32 */
+			__sync_lock_test_and_set(&m_Object->m_LockOwner, 0);
+#	endif /* _WIN32 */
+		}
+#endif /* _DEBUG */
 
 		if (m_Locked) {
 			m_Object->m_Mutex.Unlock();

lib/base/unix.hpp

@@ -36,7 +36,6 @@
 #include <sys/wait.h>
 #include <glob.h>
 #include <dlfcn.h>
-#include <sys/types.h>
 #include <sys/stat.h>
 #include <dirent.h>
 #include <sys/time.h>