diff options
author | Dwight <dwight@10gen.com> | 2011-01-05 12:21:31 -0500 |
---|---|---|
committer | Dwight <dwight@10gen.com> | 2011-01-05 12:21:31 -0500 |
commit | f52ce911460f1e33a3dbe10e14ad7a43671fabbc (patch) | |
tree | 7ecb2d3a0e19ef3b7e0ea6d67dd7c50618da37fd /dbtests | |
parent | 23c7da463fcd2364e8782f9e2d9d380413dcdba2 (diff) | |
parent | f5e2323933025844cd76e9f31025f8dc1747e55d (diff) | |
download | mongo-f52ce911460f1e33a3dbe10e14ad7a43671fabbc.tar.gz |
Merge branch 'master' of github.com:mongodb/mongo
Conflicts:
dbtests/threadedtests.cpp
Diffstat (limited to 'dbtests')
-rw-r--r-- | dbtests/threadedtests.cpp | 28 |
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(); |