diff options
Diffstat (limited to 'src/mongo/db/storage/in_memory/in_memory_engine.cpp')
-rw-r--r-- | src/mongo/db/storage/in_memory/in_memory_engine.cpp | 108 |
1 files changed, 52 insertions, 56 deletions
diff --git a/src/mongo/db/storage/in_memory/in_memory_engine.cpp b/src/mongo/db/storage/in_memory/in_memory_engine.cpp index 395d002b26a..46a12c28b4c 100644 --- a/src/mongo/db/storage/in_memory/in_memory_engine.cpp +++ b/src/mongo/db/storage/in_memory/in_memory_engine.cpp @@ -37,70 +37,66 @@ namespace mongo { - RecoveryUnit* InMemoryEngine::newRecoveryUnit() { - return new InMemoryRecoveryUnit(); - } +RecoveryUnit* InMemoryEngine::newRecoveryUnit() { + return new InMemoryRecoveryUnit(); +} - Status InMemoryEngine::createRecordStore(OperationContext* opCtx, - StringData ns, - StringData ident, - const CollectionOptions& options) { - // All work done in getRecordStore - return Status::OK(); - } +Status InMemoryEngine::createRecordStore(OperationContext* opCtx, + StringData ns, + StringData ident, + const CollectionOptions& options) { + // All work done in getRecordStore + return Status::OK(); +} - RecordStore* InMemoryEngine::getRecordStore(OperationContext* opCtx, - StringData ns, - StringData ident, - const CollectionOptions& options) { - stdx::lock_guard<stdx::mutex> lk(_mutex); - if (options.capped) { - return new InMemoryRecordStore(ns, - &_dataMap[ident], - true, - options.cappedSize ? options.cappedSize : 4096, - options.cappedMaxDocs ? options.cappedMaxDocs : -1); - } - else { - return new InMemoryRecordStore(ns, &_dataMap[ident]); - } +RecordStore* InMemoryEngine::getRecordStore(OperationContext* opCtx, + StringData ns, + StringData ident, + const CollectionOptions& options) { + stdx::lock_guard<stdx::mutex> lk(_mutex); + if (options.capped) { + return new InMemoryRecordStore(ns, + &_dataMap[ident], + true, + options.cappedSize ? options.cappedSize : 4096, + options.cappedMaxDocs ? options.cappedMaxDocs : -1); + } else { + return new InMemoryRecordStore(ns, &_dataMap[ident]); } +} - Status InMemoryEngine::createSortedDataInterface(OperationContext* opCtx, - StringData ident, - const IndexDescriptor* desc) { - - // All work done in getSortedDataInterface - return Status::OK(); - } +Status InMemoryEngine::createSortedDataInterface(OperationContext* opCtx, + StringData ident, + const IndexDescriptor* desc) { + // All work done in getSortedDataInterface + return Status::OK(); +} - SortedDataInterface* InMemoryEngine::getSortedDataInterface(OperationContext* opCtx, - StringData ident, - const IndexDescriptor* desc) { - stdx::lock_guard<stdx::mutex> lk(_mutex); - return getInMemoryBtreeImpl(Ordering::make(desc->keyPattern()), &_dataMap[ident]); - } +SortedDataInterface* InMemoryEngine::getSortedDataInterface(OperationContext* opCtx, + StringData ident, + const IndexDescriptor* desc) { + stdx::lock_guard<stdx::mutex> lk(_mutex); + return getInMemoryBtreeImpl(Ordering::make(desc->keyPattern()), &_dataMap[ident]); +} - Status InMemoryEngine::dropIdent(OperationContext* opCtx, - StringData ident) { - stdx::lock_guard<stdx::mutex> lk(_mutex); - _dataMap.erase(ident); - return Status::OK(); - } +Status InMemoryEngine::dropIdent(OperationContext* opCtx, StringData ident) { + stdx::lock_guard<stdx::mutex> lk(_mutex); + _dataMap.erase(ident); + return Status::OK(); +} - int64_t InMemoryEngine::getIdentSize( OperationContext* opCtx, - StringData ident ) { - return 1; - } +int64_t InMemoryEngine::getIdentSize(OperationContext* opCtx, StringData ident) { + return 1; +} - std::vector<std::string> InMemoryEngine::getAllIdents( OperationContext* opCtx ) const { - std::vector<std::string> all; - { - stdx::lock_guard<stdx::mutex> lk(_mutex); - for ( DataMap::const_iterator it = _dataMap.begin(); it != _dataMap.end(); ++it ) { - all.push_back( it->first ); - } +std::vector<std::string> InMemoryEngine::getAllIdents(OperationContext* opCtx) const { + std::vector<std::string> all; + { + stdx::lock_guard<stdx::mutex> lk(_mutex); + for (DataMap::const_iterator it = _dataMap.begin(); it != _dataMap.end(); ++it) { + all.push_back(it->first); } - return all; } + return all; +} } |