1 files changed, 84 insertions, 0 deletions
diff --git a/src/mongo/util/concurrency/rwlockimpl.cpp b/src/mongo/util/concurrency/rwlockimpl.cpp
new file mode 100644
index 00000000000..6d5943cffc2
--- /dev/null
+++ b/src/mongo/util/concurrency/rwlockimpl.cpp
@@ -0,0 +1,84 @@
+// @file rwlockimpl.cpp
+
+#if defined(_WIN32)
+#define WIN32_LEAN_AND_MEAN
+#define NOMINMAX
+#include <windows.h>
+#endif
+#include <map>
+#include <set>
+#include <boost/version.hpp>
+#include <boost/noncopyable.hpp>
+#include <boost/thread/mutex.hpp>
+#include <boost/thread/condition.hpp>
+
+using namespace std;
+
+#include "../assert_util.h"
+#include "../time_support.h"
+#include "rwlockimpl.h"
+#include "simplerwlock.h"
+#include "threadlocal.h"
+
+namespace mongo {
+
+#if defined(_WIN32) && defined(MONGO_USE_SRW_ON_WINDOWS)
+    SimpleRWLock::SimpleRWLock(const char *p) : name(p?p:"") { 
+        InitializeSRWLock(&_lock);
+    }
+# if defined(_DEBUG)
+    // the code below in _DEBUG build will check that we don't try to recursively lock, 
+    // which is not supported by this class.  also checks that you don't unlock without 
+    // having locked
+    void SimpleRWLock::lock() {
+        unsigned me = GetCurrentThreadId();
+        int& state = s.getRef();
+        dassert( state == 0 );
+        state--;
+        AcquireSRWLockExclusive(&_lock);
+        tid = me; // this is for use in the debugger to see who does have the lock
+    }
+    void SimpleRWLock::unlock() { 
+        int& state = s.getRef();
+        dassert( state == -1 );
+        state++;
+        tid = 0xffffffff;
+        ReleaseSRWLockExclusive(&_lock);
+    }
+    void SimpleRWLock::lock_shared() { 
+        int& state = s.getRef();
+        dassert( state == 0 );
+        state++;
+        AcquireSRWLockShared(&_lock);
+        shares++;
+    }
+    void SimpleRWLock::unlock_shared() { 
+        int& state = s.getRef();
+        dassert( state == 1 );
+        state--;
+        shares--;
+        ReleaseSRWLockShared(&_lock); 
+    }
+# else
+    void SimpleRWLock::lock() {
+        AcquireSRWLockExclusive(&_lock);
+    }
+    void SimpleRWLock::unlock() { 
+        ReleaseSRWLockExclusive(&_lock);
+    }
+    void SimpleRWLock::lock_shared() { 
+        AcquireSRWLockShared(&_lock);
+    }
+    void SimpleRWLock::unlock_shared() { 
+        ReleaseSRWLockShared(&_lock); 
+    }
+# endif
+#else
+    SimpleRWLock::SimpleRWLock(const char *p) : name(p?p:"") { }
+    void SimpleRWLock::lock() { m.lock(); }
+    void SimpleRWLock::unlock() { m.unlock(); }
+    void SimpleRWLock::lock_shared() { m.lock_shared(); }
+    void SimpleRWLock::unlock_shared() { m.unlock_shared(); }
+#endif
+
+}