/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/dbtests/ |
H A D | storage_timestamp_tests.cpp | 373 insertDocument(autoColl.getCollection(), in run() 435 insertDocument(autoColl.getCollection(), in run() 438 ASSERT_EQ(1, itCount(autoColl.getCollection())); in run() 488 auto doc = findOne(autoColl.getCollection()); in run() 527 << autoColl.getCollection()->uuid().get() in run() 554 auto doc = findOne(autoColl.getCollection()); in run() 563 doc = findOne(autoColl.getCollection()); in run() 613 ASSERT_EQ(0, itCount(autoColl.getCollection())) in run() 621 ASSERT_EQ(2, itCount(autoColl.getCollection())) in run() 676 ASSERT_EQ(0, itCount(autoColl.getCollection())) in run() [all …]
|
H A D | multikey_paths_test.cpp | 142 AutoGetCollection autoColl(_opCtx.get(), _nss, MODE_X); in TEST_F() local 143 Collection* collection = autoColl.getCollection(); in TEST_F() 174 AutoGetCollection autoColl(_opCtx.get(), _nss, MODE_X); in TEST_F() local 175 Collection* collection = autoColl.getCollection(); in TEST_F() 211 AutoGetCollection autoColl(_opCtx.get(), _nss, MODE_X); in TEST_F() local 212 Collection* collection = autoColl.getCollection(); in TEST_F() 257 AutoGetCollection autoColl(_opCtx.get(), _nss, MODE_X); in TEST_F() local 258 Collection* collection = autoColl.getCollection(); in TEST_F() 315 AutoGetCollection autoColl(_opCtx.get(), _nss, MODE_X); in TEST_F() local 316 Collection* collection = autoColl.getCollection(); in TEST_F() [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
H A D | storage_interface_impl.cpp | 214 std::unique_ptr<AutoGetCollection> autoColl; in createCollectionForBulkLoading() local 316 AutoGetCollection autoColl(opCtx, nss, MODE_IX); in insertDocumentsSingleBatch() local 384 AutoGetCollectionForReadCommand autoColl(opCtx, nss); in getOplogMaxSize() local 442 AutoGetCollection autoColl(opCtx, nss, MODE_X); in truncateCollection() local 773 AutoGetCollection autoColl(opCtx, nss, MODE_IX); in _updateWithQuery() local 775 autoColl, in _updateWithQuery() 826 AutoGetCollection autoColl(opCtx, nss, MODE_IX); in upsertById() local 899 autoColl, in deleteByFilter() 921 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionSize() local 935 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionCount() local [all …]
|
H A D | storage_interface_impl_test.cpp | 470 ASSERT_TRUE(autoColl.getCollection()); in TEST_F() 481 ASSERT_TRUE(autoColl.getCollection()); in TEST_F() 509 auto coll = autoColl.getCollection(); in TEST_F() 537 auto coll = autoColl.getCollection(); in _testDestroyUncommitedCollectionBulkLoader() 671 ASSERT_FALSE(autoColl.getCollection()); in TEST_F() 711 ASSERT_FALSE(autoColl.getCollection()); in TEST_F() 729 ASSERT_FALSE(autoColl.getCollection()); in TEST_F() 748 ASSERT_FALSE(autoColl.getCollection()); in TEST_F() 765 ASSERT_TRUE(autoColl.getCollection()); in TEST_F() 782 ASSERT_TRUE(autoColl.getCollection()); in TEST_F() [all …]
|
H A D | mock_repl_coord_server_fixture.cpp | 99 AutoGetCollection autoColl(opCtx(), NamespaceString::kRsOplogNamespace, MODE_IX); in insertOplogEntry() local 100 auto coll = autoColl.getCollection(); in insertOplogEntry()
|
H A D | idempotency_test.cpp | 97 AutoGetCollectionForReadCommand autoColl(_opCtx.get(), nss); in getDoc() local 99 Helpers::findById(_opCtx.get(), autoColl.getDb(), nss.ns(), kDocIdQuery, doc); in getDoc()
|
H A D | sync_tail_test_fixture.cpp | 68 AutoGetCollectionForRead autoColl(opCtx, nss); in setUp() local 69 return autoColl.getCollection()->uuid(); in setUp()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/s/ |
H A D | migration_chunk_cloner_source_legacy_test.cpp | 213 AutoGetCollection autoColl(operationContext(), kNss, MODE_IS); in TEST_F() local 218 cloner.nextCloneBatch(operationContext(), autoColl.getCollection(), &arrBuilder)); in TEST_F() 229 cloner.nextCloneBatch(operationContext(), autoColl.getCollection(), &arrBuilder)); in TEST_F() 246 AutoGetCollection autoColl(operationContext(), kNss, MODE_IX); in TEST_F() local 263 AutoGetCollection autoColl(operationContext(), kNss, MODE_IS); in TEST_F() local 268 cloner.nextCloneBatch(operationContext(), autoColl.getCollection(), &arrBuilder)); in TEST_F() 274 ASSERT_OK(cloner.nextModsBatch(operationContext(), autoColl.getDb(), &modsBuilder)); in TEST_F() 351 AutoGetCollection autoColl(operationContext(), kNss, MODE_IS); in TEST_F() local 356 cloner.nextCloneBatch(operationContext(), autoColl.getCollection(), &arrBuilder)); in TEST_F() 363 cloner.nextCloneBatch(operationContext(), autoColl.getCollection(), &arrBuilder)); in TEST_F()
|
H A D | migration_source_manager.cpp | 171 AutoGetCollection autoColl(opCtx, getNss(), MODE_IS); in MigrationSourceManager() local 174 autoColl.getCollection()); in MigrationSourceManager() 177 if (autoColl.getCollection()->uuid()) { in MigrationSourceManager() 178 collectionUUID = autoColl.getCollection()->uuid().value(); in MigrationSourceManager() 255 AutoGetCollection autoColl(opCtx, getNss(), MODE_IX, MODE_X); in startClone() local 311 AutoGetCollection autoColl(opCtx, _args.getNss(), MODE_IS); in enterCriticalSection() local 336 AutoGetCollection autoColl(opCtx, getNss(), MODE_IX, MODE_X); in enterCriticalSection() local 441 AutoGetCollection autoColl(opCtx, getNss(), MODE_IX, MODE_X); in commitChunkMetadataOnConfig() local 559 AutoGetCollection autoColl(opCtx, getNss(), MODE_IS); in commitChunkMetadataOnConfig() local 639 AutoGetCollection autoColl(opCtx, getNss(), MODE_IS); in commitChunkMetadataOnConfig() local [all …]
|
H A D | collection_sharding_state_test.cpp | 186 AutoGetCollection autoColl(operationContext(), kTestNss, MODE_IX); in TEST_F() local 208 AutoGetCollection autoColl(operationContext(), kTestNss, MODE_IX); in TEST_F() local 235 AutoGetCollection autoColl(operationContext(), kTestNss, MODE_IX); in TEST_F() local 261 AutoGetCollection autoColl(operationContext(), kTestNss, MODE_IX); in TEST_F() local
|
H A D | sharding_state.cpp | 224 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in onStaleShardVersion() local 418 AutoGetCollection autoColl( in initializeShardingAwarenessIfNeeded() local 421 autoColl.getCollection(), in initializeShardingAwarenessIfNeeded() 485 AutoGetCollection autoColl(opCtx, nss, MODE_IX, MODE_X); in _refreshMetadata() local 494 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in _refreshMetadata() local 508 AutoGetCollection autoColl(opCtx, nss, MODE_IX, MODE_X); in _refreshMetadata() local
|
H A D | split_chunk.cpp | 101 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in checkMetadataForSuccessfulSplitChunk() local 238 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in splitChunk() local 240 Collection* const collection = autoColl.getCollection(); in splitChunk()
|
H A D | cleanup_orphaned_cmd.cpp | 81 AutoGetCollection autoColl(opCtx, ns, MODE_IX); in cleanupOrphanedData() local 115 opCtx, autoColl.getCollection(), *targetRange, CollectionShardingState::kNow); in cleanupOrphanedData()
|
H A D | check_sharding_index_command.cpp | 113 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in errmsgRun() local 115 Collection* const collection = autoColl.getCollection(); in errmsgRun()
|
H A D | collection_range_deleter.cpp | 132 AutoGetCollection autoColl(opCtx, nss, MODE_IX); in cleanUpNextRange() local 133 auto* const collection = autoColl.getCollection(); in cleanUpNextRange() 250 AutoGetCollection autoColl(opCtx, nss, MODE_IX); in cleanUpNextRange() local 251 auto* const collection = autoColl.getCollection(); in cleanUpNextRange()
|
H A D | migration_chunk_cloner_source_legacy.cpp | 556 AutoGetCollection autoColl(opCtx, _args.getNss(), MODE_IS); in _cleanup() local 558 autoColl.getCollection() ? autoColl.getCollection()->getCursorManager() : nullptr; in _cleanup() 594 AutoGetCollection autoColl(opCtx, _args.getNss(), MODE_IS); in _storeCurrentLocs() local 596 Collection* const collection = autoColl.getCollection(); in _storeCurrentLocs()
|
H A D | split_vector.cpp | 79 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in splitVector() local 81 Collection* const collection = autoColl.getCollection(); in splitVector()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ |
H A D | session_test.cpp | 160 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 192 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 250 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 266 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 330 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 338 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 356 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 377 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 472 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local 499 AutoGetCollection autoColl(opCtx(), kNss, MODE_IX); in TEST_F() local
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/pipeline/ |
H A D | pipeline_d.cpp | 116 AutoGetCollectionForReadCommand autoColl(_ctx->opCtx, nss); in isSharded() local 134 AutoGetCollectionForReadCommand autoColl(opCtx, ns); in getIndexStats() local 136 Collection* collection = autoColl.getCollection(); in getIndexStats() 237 boost::optional<AutoGetCollectionForReadCommand> autoColl; in attachCursorSourceToPipeline() local 239 autoColl.emplace(expCtx->opCtx, in attachCursorSourceToPipeline() 243 if (autoColl->getCollection() == nullptr) { in attachCursorSourceToPipeline() 249 autoColl.emplace(expCtx->opCtx, expCtx->ns, AutoStatsTracker::LogMode::kUpdateTop); in attachCursorSourceToPipeline() 367 AutoGetCollection autoColl(_ctx->opCtx, _ctx->ns, MODE_IS); in collectDocumentKeyFields() local 433 AutoGetCollection autoColl(_ctx->opCtx, nss, collectionUUID, MODE_IS); in _getCollectionDefaultCollator() local 434 if (!autoColl.getCollection()) { in _getCollectionDefaultCollator() [all …]
|
H A D | document_source_cursor.cpp | 116 AutoGetCollectionForRead autoColl(pExpCtx->opCtx, _exec->nss()); in loadBatch() local 167 cleanupExecutor(autoColl); in loadBatch() 233 AutoGetCollectionForRead autoColl(pExpCtx->opCtx, _exec->nss()); in serialize() local 235 Explain::explainStages(_exec.get(), autoColl.getCollection(), *explain, &explainBuilder); in serialize()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/commands/ |
H A D | list_indexes.cpp | 146 AutoGetCollectionForReadCommand autoColl(opCtx, ns, std::move(dbSLock)); in run() local 147 if (!autoColl.getDb()) { in run() 152 Collection* collection = autoColl.getCollection(); in run()
|
H A D | find_and_modify.cpp | 270 AutoGetCollection autoColl(opCtx, nsString, MODE_IX); in explain() local 271 if (!autoColl.getDb()) { in explain() 279 Collection* const collection = autoColl.getCollection(); in explain() 301 AutoGetCollection autoColl(opCtx, nsString, MODE_IX); in explain() local 302 if (!autoColl.getDb()) { in explain() 310 Collection* const collection = autoColl.getCollection(); in explain()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/catalog/ |
H A D | capped_utils_test.cpp | 97 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionOptions() local 98 auto collection = autoColl.getCollection(); in getCollectionOptions()
|
H A D | create_collection_test.cpp | 100 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionOptions() local 101 auto collection = autoColl.getCollection(); in getCollectionOptions()
|
H A D | rename_collection_test.cpp | 314 AutoGetCollectionForRead autoColl(opCtx, nss); in _getCollectionOptions() local 315 auto collection = autoColl.getCollection(); in _getCollectionOptions() 343 AutoGetCollectionForRead autoColl(opCtx, nss); in _isTempCollection() local 344 auto collection = autoColl.getCollection(); in _isTempCollection() 359 AutoGetCollection autoColl(opCtx, nss, MODE_X); in _createIndex() local 360 auto collection = autoColl.getCollection(); in _createIndex() 385 AutoGetCollection autoColl(opCtx, nss, MODE_X); in _insertDocument() local 386 auto collection = autoColl.getCollection(); in _insertDocument()
|