summaryrefslogtreecommitdiff
path: root/dbtests
diff options
context:
space:
mode:
authorDwight <dwight@10gen.com>2011-01-05 12:21:31 -0500
committerDwight <dwight@10gen.com>2011-01-05 12:21:31 -0500
commitf52ce911460f1e33a3dbe10e14ad7a43671fabbc (patch)
tree7ecb2d3a0e19ef3b7e0ea6d67dd7c50618da37fd /dbtests
parent23c7da463fcd2364e8782f9e2d9d380413dcdba2 (diff)
parentf5e2323933025844cd76e9f31025f8dc1747e55d (diff)
downloadmongo-f52ce911460f1e33a3dbe10e14ad7a43671fabbc.tar.gz
Merge branch 'master' of github.com:mongodb/mongo
Conflicts: dbtests/threadedtests.cpp
Diffstat (limited to 'dbtests')
-rw-r--r--dbtests/threadedtests.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/dbtests/threadedtests.cpp b/dbtests/threadedtests.cpp
index 585b5ce31c4..cee41284a67 100644
--- a/dbtests/threadedtests.cpp
+++ b/dbtests/threadedtests.cpp
@@ -57,13 +57,13 @@ namespace ThreadedTests {
}
};
- class MongoMutexTest : public ThreadedTest<> {
- enum { N = 100000 };
+ class MongoMutexTest : public ThreadedTest<135> {
+ enum { N = 80000 };
MongoMutex *mm;
- virtual void setup() {
+ virtual void setup() {
mm = new MongoMutex("MongoMutexTest");
}
- virtual void subthread() {
+ virtual void subthread() {
Client::initThread("mongomutextest");
sleepmillis(0);
for( int i = 0; i < N; i++ ) {
@@ -73,46 +73,46 @@ namespace ThreadedTests {
mm->unlock_shared();
mm->unlock_shared();
}
- else if( i % 7 == 1 ) {
+ else if( i % 7 == 1 ) {
mm->lock_shared();
ASSERT( mm->atLeastReadLocked() );
mm->unlock_shared();
}
- else if( i % 7 == 2 ) {
+ else if( i % 7 == 2 ) {
mm->lock();
ASSERT( mm->isWriteLocked() );
mm->unlock();
}
- else if( i % 7 == 3 ) {
+ else if( i % 7 == 3 ) {
mm->lock();
mm->lock_shared();
ASSERT( mm->isWriteLocked() );
mm->unlock_shared();
mm->unlock();
}
- else if( i % 7 == 4 ) {
+ else if( i % 7 == 4 ) {
mm->lock();
mm->releaseEarly();
mm->unlock();
}
- else if( i % 7 == 5 ) {
- if( mm->lock_try(1) ) {
+ else if( i % 7 == 5 ) {
+ if( mm->lock_try(1) ) {
mm->unlock();
}
}
- else if( i % 7 == 6 ) {
- if( mm->lock_shared_try(0) ) {
+ else if( i % 7 == 6 ) {
+ if( mm->lock_shared_try(0) ) {
mm->unlock_shared();
}
}
- else {
+ else {
mm->lock_shared();
mm->unlock_shared();
}
}
cc().shutdown();
}
- virtual void validate() {
+ virtual void validate() {
ASSERT( !mm->atLeastReadLocked() );
mm->lock();
mm->unlock();