| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/storage/kv/ |
| H A D | kv_catalog_feature_tracker_test.cpp | 74 auto opCtx = newOperationContext(); in setUp() local
85 _catalog->init(opCtx.get()); in setUp()
110 auto opCtx = newOperationContext(); in TEST_F() local
117 auto opCtx = newOperationContext(); in TEST_F() local
142 auto opCtx = newOperationContext(); in TEST_F() local
148 auto opCtx = newOperationContext(); in TEST_F() local
156 auto opCtx = newOperationContext(); in TEST_F() local
190 auto opCtx = newOperationContext(); in TEST_F() local
215 auto opCtx = newOperationContext(); in TEST_F() local
221 auto opCtx = newOperationContext(); in TEST_F() local
[all …]
|
| H A D | kv_engine_test_harness.cpp | 81 WriteUnitOfWork uow(&opCtx); in TEST()
162 WriteUnitOfWork uow(&opCtx); in TEST()
181 WriteUnitOfWork uow(&opCtx); in TEST()
190 WriteUnitOfWork uow(&opCtx); in TEST()
200 WriteUnitOfWork uow(&opCtx); in TEST()
202 catalog->init(&opCtx); in TEST()
209 WriteUnitOfWork uow(&opCtx); in TEST()
227 WriteUnitOfWork uow(&opCtx); in TEST()
236 WriteUnitOfWork uow(&opCtx); in TEST()
246 WriteUnitOfWork uow(&opCtx); in TEST()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/storage/ |
| H A D | sorted_data_interface_test_unindex.cpp | 50 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
56 WriteUnitOfWork uow(opCtx.get()); in TEST()
70 WriteUnitOfWork uow(opCtx.get()); in TEST()
79 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
90 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
96 WriteUnitOfWork uow(opCtx.get()); in TEST()
110 WriteUnitOfWork uow(opCtx.get()); in TEST()
119 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
130 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
136 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_insert.cpp | 50 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
56 WriteUnitOfWork uow(opCtx.get()); in TEST()
75 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
81 WriteUnitOfWork uow(opCtx.get()); in TEST()
102 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
108 WriteUnitOfWork uow(opCtx.get()); in TEST()
123 WriteUnitOfWork uow(opCtx.get()); in TEST()
144 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
150 WriteUnitOfWork uow(opCtx.get()); in TEST()
165 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_harness.cpp | 55 WriteUnitOfWork wuow(opCtx); in insertToIndex()
65 WriteUnitOfWork wuow(opCtx); in removeFromIndex()
82 WriteUnitOfWork uow(opCtx.get()); in TEST()
91 WriteUnitOfWork uow(opCtx.get()); in TEST()
114 WriteUnitOfWork uow(opCtx.get()); in TEST()
123 WriteUnitOfWork uow(opCtx.get()); in TEST()
142 WriteUnitOfWork uow(opCtx.get()); in TEST()
151 WriteUnitOfWork uow(opCtx.get()); in TEST()
170 WriteUnitOfWork uow(opCtx.get()); in TEST()
180 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | record_store_test_harness.cpp | 63 WriteUnitOfWork uow(opCtx.get()); in TEST()
90 WriteUnitOfWork uow(opCtx.get()); in TEST()
134 WriteUnitOfWork uow(opCtx.get()); in TEST()
163 WriteUnitOfWork uow(opCtx.get()); in TEST()
183 WriteUnitOfWork uow(opCtx.get()); in TEST()
208 WriteUnitOfWork uow(opCtx.get()); in TEST()
228 WriteUnitOfWork uow(opCtx.get()); in TEST()
251 WriteUnitOfWork uow(opCtx.get()); in TEST()
268 WriteUnitOfWork uow(opCtx.get()); in TEST()
312 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_rollback.cpp | 51 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
57 WriteUnitOfWork uow(opCtx.get()); in TEST()
65 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
71 WriteUnitOfWork uow(opCtx.get()); in TEST()
80 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
93 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
99 WriteUnitOfWork uow(opCtx.get()); in TEST()
108 ASSERT_EQUALS(2, sorted->numEntries(opCtx.get())); in TEST()
114 WriteUnitOfWork uow(opCtx.get()); in TEST()
129 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_cursor_locate.cpp | 58 WriteUnitOfWork uow(opCtx.get()); in TEST()
89 WriteUnitOfWork uow(opCtx.get()); in TEST()
120 WriteUnitOfWork uow(opCtx.get()); in TEST()
151 WriteUnitOfWork uow(opCtx.get()); in TEST()
182 WriteUnitOfWork uow(opCtx.get()); in TEST()
201 WriteUnitOfWork uow(opCtx.get()); in TEST()
238 WriteUnitOfWork uow(opCtx.get()); in TEST()
258 WriteUnitOfWork uow(opCtx.get()); in TEST()
295 WriteUnitOfWork uow(opCtx.get()); in TEST()
316 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_cursor_advanceto.cpp | 54 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
60 WriteUnitOfWork uow(opCtx.get()); in TEST()
109 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
115 WriteUnitOfWork uow(opCtx.get()); in TEST()
163 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
169 WriteUnitOfWork uow(opCtx.get()); in TEST()
207 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
213 WriteUnitOfWork uow(opCtx.get()); in TEST()
254 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
260 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| H A D | sorted_data_interface_test_dupkeycheck.cpp | 52 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
58 WriteUnitOfWork uow(opCtx.get()); in TEST()
72 WriteUnitOfWork uow(opCtx.get()); in TEST()
88 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
94 WriteUnitOfWork uow(opCtx.get()); in TEST()
109 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
115 WriteUnitOfWork uow(opCtx.get()); in TEST()
129 WriteUnitOfWork uow(opCtx.get()); in TEST()
144 ASSERT(sorted->isEmpty(opCtx.get())); in TEST()
150 WriteUnitOfWork uow(opCtx.get()); in TEST()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
| H A D | replication_recovery_test.cpp | 260 recovery.recoverFromOplog(opCtx); in TEST_F()
262 _assertDocsInOplog(opCtx, {}); in TEST_F()
273 recovery.recoverFromOplog(opCtx); in TEST_F()
275 _assertDocsInOplog(opCtx, {}); in TEST_F()
293 recovery.recoverFromOplog(opCtx);
304 recovery.recoverFromOplog(opCtx);
315 recovery.recoverFromOplog(opCtx); in TEST_F()
333 recovery.recoverFromOplog(opCtx); in TEST_F()
349 recovery.recoverFromOplog(opCtx); in TEST_F()
472 _assertDocsInOplog(opCtx, {5}); in TEST_F()
[all …]
|
| H A D | storage_interface_impl_test.cpp | 274 opCtx, in _assertRollbackIDDocument()
310 createCollection(opCtx, nss); in TEST_F()
519 OperationContext* opCtx, in _testDestroyUncommitedCollectionBulkLoader() argument
931 opCtx, in TEST_F()
1055 opCtx, in TEST_F()
1172 opCtx, in TEST_F()
1425 opCtx, in TEST_F()
1536 opCtx, in TEST_F()
1921 opCtx, in TEST_F()
1943 opCtx, in TEST_F()
[all …]
|
| H A D | replication_consistency_markers_impl_test.cpp | 71 return writeConflictRetry(opCtx, "getMinValidDocument", minValidNss.ns(), [opCtx, minValidNss] { in getMinValidDocument()
88 opCtx, in getOplogTruncateAfterPointDocument()
91 [opCtx, oplogTruncateAfterPointNss] { in getOplogTruncateAfterPointDocument()
108 opCtx, in getCheckpointTimestampDocument()
111 [opCtx, checkpointTimestampNss] { in getCheckpointTimestampDocument()
176 auto opCtx = getOperationContext(); in TEST_F() local
203 auto opCtx = getOperationContext(); in TEST_F() local
225 auto opCtx = getOperationContext(); in TEST_F() local
300 auto opCtx = getOperationContext(); in TEST_F() local
349 auto opCtx = getOperationContext(); in TEST_F() local
[all …]
|
| H A D | replication_coordinator_external_state_impl.cpp | 241 _bgSync->startup(opCtx); in startSteadyStateReplication()
293 oldBgSync->join(opCtx); in _stopDataReplication_inlock()
393 createOplog(opCtx); in initializeReplSetStorage()
450 OperationContext* opCtx) { in waitForAllEarlierOplogWritesToBeVisible() argument
480 opCtx, in onTransitionToPrimary()
539 OperationContext* opCtx) { in loadLocalConfigDocument() argument
571 OperationContext* opCtx) { in createLocalLastVoteCollection() argument
602 OperationContext* opCtx) { in loadLocalLastVoteDocument() argument
605 opCtx, "load replica set lastVote", lastVoteCollectionName, [opCtx] { in loadLocalLastVoteDocument()
793 Balancer::get(opCtx)->initiateBalancer(opCtx); in _shardingOnTransitionToPrimaryHook()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/dbtests/ |
| H A D | rollbacktests.cpp | 75 WriteUnitOfWork uow(opCtx); in createCollection()
90 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in truncateCollection()
91 return coll->truncate(opCtx); in truncateCollection()
95 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in insertRecord()
100 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in assertOnlyRecord()
110 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in assertEmpty()
114 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in indexExists()
118 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in indexReady()
126 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in getNumIndexEntries()
142 Collection* coll = dbHolder().get(opCtx, nss.db())->getCollection(opCtx, nss); in dropIndex()
[all …]
|
| H A D | indexcatalogtests.cpp | 57 OldClientContext ctx(&opCtx, _ns); in IndexIteratorTests()
58 WriteUnitOfWork wuow(&opCtx); in IndexIteratorTests()
70 OldClientContext ctx(&opCtx, _ns); in ~IndexIteratorTests()
71 WriteUnitOfWork wuow(&opCtx); in ~IndexIteratorTests()
124 OldClientContext ctx(&opCtx, _ns); in RefreshEntry()
125 WriteUnitOfWork wuow(&opCtx); in RefreshEntry()
137 OldClientContext ctx(&opCtx, _ns); in ~RefreshEntry()
138 WriteUnitOfWork wuow(&opCtx); in ~RefreshEntry()
151 &opCtx, in run()
164 WriteUnitOfWork wuow(&opCtx); in run()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ |
| H A D | op_observer_impl.cpp | 275 repl::logOp(opCtx, in onCreateIndex()
288 repl::logOp(opCtx, in onCreateIndex()
349 SessionCatalog::get(opCtx)->invalidateSessions(opCtx, it->doc); in onInserts()
407 SessionCatalog::get(opCtx)->invalidateSessions(opCtx, args.updatedDoc); in onUpdate()
474 repl::logOp(opCtx, in onInternalOpMessage()
539 opCtx->recoveryUnit()->onRollback([opCtx, collectionName]() { in onCreateCollection()
611 repl::logOp(opCtx, in onDropDatabase()
627 SessionCatalog::get(opCtx)->invalidateSessions(opCtx, boost::none); in onDropDatabase()
664 SessionCatalog::get(opCtx)->invalidateSessions(opCtx, boost::none); in onDropCollection()
693 repl::logOp(opCtx, in onDropIndex()
[all …]
|
| H A D | session_test.cpp | 118 return repl::logOp(opCtx, in logOp()
139 session.beginTxn(opCtx(), txnNum); in TEST_F()
144 DBDirectClient client(opCtx()); in TEST_F()
157 session.beginTxn(opCtx(), txnNum); in TEST_F()
161 WriteUnitOfWork wuow(opCtx()); in TEST_F()
169 DBDirectClient client(opCtx()); in TEST_F()
193 WriteUnitOfWork wuow(opCtx()); in TEST_F()
204 DBDirectClient client(opCtx()); in TEST_F()
243 DBDirectClient client(opCtx()); in TEST_F()
251 WriteUnitOfWork wuow(opCtx()); in TEST_F()
[all …]
|
| H A D | service_entry_point_mongod.cpp | 177 registerError(opCtx, exception);
215 : _opCtx(opCtx), in MaintenanceModeSetter()
294 repl::ReplClientInfo::forClient(opCtx->getClient()).setLastOpToSystemLastOpTime(opCtx); in _waitForWriteConcernAndAddToCommandResponse()
300 waitForWriteConcern(opCtx, lastOpAfterRun, opCtx->getWriteConcern(), &res); in _waitForWriteConcernAndAddToCommandResponse()
445 opCtx, repl::ReadConcernArgs::get(opCtx), command->allowsAfterClusterTime(cmd)); in runCommandImpl()
584 opCtx, in execCommandDatabase()
816 auto curop = CurOp::get(opCtx); in curOpCommandSetup()
919 ServerReadConcernMetrics::get(opCtx)->recordReadConcern(repl::ReadConcernArgs::get(opCtx)); in receivedQuery()
1203 opCtx, in handleRequest()
1228 profile(opCtx, op); in handleRequest()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/storage/mmap_v1/catalog/ |
| H A D | namespace_details_collection_entry.cpp | 71 OperationContext* opCtx) const { in getCollectionOptions()
117 int idxNo = _findIndexNumber(opCtx, idxName); in isIndexMultikey()
164 int idxNo = _findIndexNumber(opCtx, idxName); in getIndexHead()
171 int idxNo = _findIndexNumber(opCtx, idxName); in getIndexSpec()
296 _details->allocExtra(opCtx, ns().ns(), _db->_namespaceIndex, getTotalIndexCount(opCtx)); in prepareForIndexBuild()
313 _db->markCollationFeatureAsInUse(opCtx); in prepareForIndexBuild()
347 invariant(isIndexReady(opCtx, indexName)); in indexBuildSuccess()
353 int idx = _findIndexNumber(opCtx, idxName); in updateTTLSetting()
416 md.replaceUserFlags(opCtx, newValue); in updateFlags()
456 _updateSystemNamespaces(opCtx, in removeUUID()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ops/ |
| H A D | write_ops_exec.cpp | 103 recordCurOpMetrics(opCtx); in finishCurOp()
105 .record(opCtx, in finishCurOp()
133 profile(opCtx, CurOp::get(opCtx)->getNetworkOp()); in finishCurOp()
190 CollectionShardingState::get(opCtx, ns)->checkShardVersionOrThrow(opCtx); in assertCanWrite_inlock()
194 writeConflictRetry(opCtx, "implicit collection creation", ns.ns(), [&opCtx, &ns] { in makeCollection()
318 WriteUnitOfWork wuow(opCtx); in insertDocuments()
340 opCtx, begin, end, &CurOp::get(opCtx)->debug(), /*enforceQuota*/ true, fromMigrate)); in insertDocuments()
472 .record(opCtx, in performInserts()
616 opCtx->checkForInterrupt(); in performSingleUpdateOp()
695 CurOp curOp(opCtx); in performUpdates()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/storage/mmap_v1/ |
| H A D | record_store_v1_capped_test.cpp | 70 OperationContextNoop opCtx; in simpleInsertTest() local
113 OperationContextNoop opCtx; in TEST() local
142 OperationContextNoop opCtx; in TEST() local
182 OperationContextNoop opCtx; in TEST() local
225 OperationContextNoop opCtx; in TEST() local
264 OperationContextNoop opCtx; in TEST() local
752 h.md->setCapExtent(&h.opCtx, h.md->lastExtent(&h.opCtx)); in TEST()
762 h.md->setCapExtent(&h.opCtx, h.em.getExtent(h.md->firstExtent(&h.opCtx))->xnext); in TEST()
773 h.md->setCapExtent(&h.opCtx, h.em.getExtent(h.md->firstExtent(&h.opCtx))->xnext); in TEST()
782 h.md->setCapExtent(&h.opCtx, h.em.getExtent(h.md->firstExtent(&h.opCtx))->xnext); in TEST()
[all …]
|
| H A D | record_store_v1_capped.cpp | 88 cappedCheckMigrate(opCtx); in CappedRecordStoreV1()
175 Status status = _cappedCallback->aboutToDeleteCapped(opCtx, fr, dataFor(opCtx, fr)); in allocRecord()
178 deleteRecord(opCtx, fr); in allocRecord()
180 _compact(opCtx); in allocRecord()
220 addDeletedRec(opCtx, newDelLoc); in allocRecord()
230 _details->setCapExtent(opCtx, _details->firstExtent(opCtx)); in truncate()
250 addDeletedRec(opCtx, _findFirstSpot(opCtx, extLoc, ext)); in truncate()
308 addDeletedRec(opCtx, a); in _compact()
348 _details->setCapExtent(opCtx, _details->firstExtent(opCtx)); in cappedCheckMigrate()
387 _details->setCapExtent(opCtx, in advanceCapExtent()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/catalog/ |
| H A D | index_catalog.h | 177 OperationContext* opCtx,
247 OperationContext* opCtx,
281 return this->_impl().init(opCtx); in init()
295 return this->_impl().numIndexesTotal(opCtx); in numIndexesTotal()
299 return this->_impl().numIndexesReady(opCtx); in numIndexesReady()
303 return numIndexesTotal(opCtx) - numIndexesReady(opCtx); in numIndexesInProgress()
312 return this->_impl().haveIdIndex(opCtx); in haveIdIndex()
324 return this->_impl().findIdIndex(opCtx); in findIdIndex()
349 OperationContext* const opCtx,
467 return this->_impl().dropIndex(opCtx, desc); in dropIndex()
[all …]
|
| H A D | database.h | 64 virtual void init(OperationContext* opCtx) = 0;
101 virtual Status createView(OperationContext* opCtx,
187 : _pimpl(makeImpl(this, opCtx, name, dbEntry)) { in Database()
188 this->_impl().init(opCtx); in Database()
207 return this->_impl().close(opCtx, reason); in close()
215 return this->_impl().clearTmpCollections(opCtx); in clearTmpCollections()
253 return this->_impl().isDropPending(opCtx); in isDropPending()
256 inline void getStats(OperationContext* const opCtx,
285 return this->_impl().dropView(opCtx, fullns); in dropView()
306 return this->_impl().getCollection(opCtx, ns); in getCollection()
[all …]
|