summaryrefslogtreecommitdiff
path: root/src/mongo/db/concurrency/lock_manager.cpp
diff options
context:
space:
mode:
authorAndrew Morrow <acm@mongodb.com>2015-06-18 15:02:54 -0400
committerAndrew Morrow <acm@mongodb.com>2015-06-19 22:51:28 -0400
commit1178eff1ddf60a7dac3a8cd71e2fdd278aa01b52 (patch)
treeee3096045eb4d2e4f69d57ef85c66b3be69e4302 /src/mongo/db/concurrency/lock_manager.cpp
parent4b5fa5fc711e4cf94291665575fd1c742ad3e7c3 (diff)
downloadmongo-1178eff1ddf60a7dac3a8cd71e2fdd278aa01b52.tar.gz
SERVER-19041 Simplify SimpleMutex
Diffstat (limited to 'src/mongo/db/concurrency/lock_manager.cpp')
-rw-r--r--src/mongo/db/concurrency/lock_manager.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/mongo/db/concurrency/lock_manager.cpp b/src/mongo/db/concurrency/lock_manager.cpp
index d082cc981ac..7a0e094ea30 100644
--- a/src/mongo/db/concurrency/lock_manager.cpp
+++ b/src/mongo/db/concurrency/lock_manager.cpp
@@ -399,7 +399,7 @@ namespace {
// Migration time: lock each partition in turn and transfer its requests, if any
while(partitioned()) {
LockManager::Partition* partition = partitions.back();
- SimpleMutex::scoped_lock scopedLock(partition->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(partition->mutex);
LockManager::Partition::Map::iterator it = partition->data.find(resourceId);
if (it != partition->data.end()) {
@@ -459,7 +459,7 @@ namespace {
// For intent modes, try the PartitionedLockHead
if (request->partitioned) {
Partition* partition = _getPartition(request);
- SimpleMutex::scoped_lock scopedLock(partition->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(partition->mutex);
// Fast path for intent locks
PartitionedLockHead* partitionedLock = partition->find(resId);
@@ -475,7 +475,7 @@ namespace {
// Use regular LockHead, maybe start partitioning
LockBucket* bucket = _getBucket(resId);
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
LockHead* lock = bucket->findOrInsert(resId);
@@ -483,7 +483,7 @@ namespace {
if (request->partitioned && !(lock->grantedModes & (~intentModes))
&& !lock->conflictModes) {
Partition* partition = _getPartition(request);
- SimpleMutex::scoped_lock scopedLock(partition->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(partition->mutex);
PartitionedLockHead* partitionedLock = partition->findOrInsert(resId);
invariant(partitionedLock);
lock->partitions.push_back(partition);
@@ -524,7 +524,7 @@ namespace {
LockConflictsTable[newMode]);
LockBucket* bucket = _getBucket(resId);
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
LockBucket::Map::iterator it = bucket->data.find(resId);
invariant(it != bucket->data.end());
@@ -595,7 +595,7 @@ namespace {
invariant(request->status == LockRequest::STATUS_GRANTED
|| request->status == LockRequest::STATUS_CONVERTING);
Partition* partition = _getPartition(request);
- SimpleMutex::scoped_lock scopedLock(partition->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(partition->mutex);
// Fast path: still partitioned.
if (request->partitionedLock) {
request->partitionedLock->grantedList.remove(request);
@@ -608,7 +608,7 @@ namespace {
LockHead* lock = request->lock;
LockBucket* bucket = _getBucket(lock->resourceId);
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
if (request->status == LockRequest::STATUS_GRANTED) {
// This releases a currently held lock and is the most common path, so it should be
@@ -668,7 +668,7 @@ namespace {
LockHead* lock = request->lock;
LockBucket* bucket = _getBucket(lock->resourceId);
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
lock->incGrantedModeCount(newMode);
lock->decGrantedModeCount(request->mode);
@@ -681,7 +681,7 @@ namespace {
size_t deletedLockHeads = 0;
for (unsigned i = 0; i < _numLockBuckets; i++) {
LockBucket* bucket = &_lockBuckets[i];
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
LockBucket::Map::iterator it = bucket->data.begin();
while (it != bucket->data.end()) {
@@ -821,7 +821,7 @@ namespace {
for (unsigned i = 0; i < _numLockBuckets; i++) {
LockBucket* bucket = &_lockBuckets[i];
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
if (!bucket->data.empty()) {
_dumpBucket(bucket);
@@ -971,7 +971,7 @@ namespace {
void DeadlockDetector::_processNextNode(const UnprocessedNode& node) {
// Locate the request
LockManager::LockBucket* bucket = _lockMgr._getBucket(node.resId);
- SimpleMutex::scoped_lock scopedLock(bucket->mutex);
+ stdx::lock_guard<SimpleMutex> scopedLock(bucket->mutex);
LockManager::LockBucket::Map::const_iterator iter = bucket->data.find(node.resId);
if (iter == bucket->data.end()) {