Home
last modified time | relevance | path

Searched refs:autoColl (Results 1 – 25 of 54) sorted by relevance

123

/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/dbtests/
H A Dstorage_timestamp_tests.cpp373 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 Dmultikey_paths_test.cpp142 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 Dstorage_interface_impl.cpp214 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 Dstorage_interface_impl_test.cpp470 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 Dmock_repl_coord_server_fixture.cpp99 AutoGetCollection autoColl(opCtx(), NamespaceString::kRsOplogNamespace, MODE_IX); in insertOplogEntry() local
100 auto coll = autoColl.getCollection(); in insertOplogEntry()
H A Didempotency_test.cpp97 AutoGetCollectionForReadCommand autoColl(_opCtx.get(), nss); in getDoc() local
99 Helpers::findById(_opCtx.get(), autoColl.getDb(), nss.ns(), kDocIdQuery, doc); in getDoc()
H A Dsync_tail_test_fixture.cpp68 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 Dmigration_chunk_cloner_source_legacy_test.cpp213 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 Dmigration_source_manager.cpp171 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 Dcollection_sharding_state_test.cpp186 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 Dsharding_state.cpp224 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 Dsplit_chunk.cpp101 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 Dcleanup_orphaned_cmd.cpp81 AutoGetCollection autoColl(opCtx, ns, MODE_IX); in cleanupOrphanedData() local
115 opCtx, autoColl.getCollection(), *targetRange, CollectionShardingState::kNow); in cleanupOrphanedData()
H A Dcheck_sharding_index_command.cpp113 AutoGetCollection autoColl(opCtx, nss, MODE_IS); in errmsgRun() local
115 Collection* const collection = autoColl.getCollection(); in errmsgRun()
H A Dcollection_range_deleter.cpp132 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 Dmigration_chunk_cloner_source_legacy.cpp556 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 Dsplit_vector.cpp79 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 Dsession_test.cpp160 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 Dpipeline_d.cpp116 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 Ddocument_source_cursor.cpp116 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 Dlist_indexes.cpp146 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 Dfind_and_modify.cpp270 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 Dcapped_utils_test.cpp97 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionOptions() local
98 auto collection = autoColl.getCollection(); in getCollectionOptions()
H A Dcreate_collection_test.cpp100 AutoGetCollectionForRead autoColl(opCtx, nss); in getCollectionOptions() local
101 auto collection = autoColl.getCollection(); in getCollectionOptions()
H A Drename_collection_test.cpp314 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()

123