diff options
Diffstat (limited to 'src/mongo/db/catalog/collection_impl.cpp')
-rw-r--r-- | src/mongo/db/catalog/collection_impl.cpp | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/src/mongo/db/catalog/collection_impl.cpp b/src/mongo/db/catalog/collection_impl.cpp index c113ce8e34c..f30be055410 100644 --- a/src/mongo/db/catalog/collection_impl.cpp +++ b/src/mongo/db/catalog/collection_impl.cpp @@ -483,7 +483,7 @@ Collection::Validator CollectionImpl::parseValidator( Status CollectionImpl::insertDocumentsForOplog(OperationContext* opCtx, std::vector<Record>* records, - const std::vector<Timestamp>& timestamps) { + const std::vector<Timestamp>& timestamps) const { dassert(opCtx->lockState()->isWriteLocked()); // Since this is only for the OpLog, we can assume these for simplicity. @@ -506,7 +506,7 @@ Status CollectionImpl::insertDocuments(OperationContext* opCtx, const std::vector<InsertStatement>::const_iterator begin, const std::vector<InsertStatement>::const_iterator end, OpDebug* opDebug, - bool fromMigrate) { + bool fromMigrate) const { auto status = checkFailCollectionInsertsFailPoint(_ns, (begin != end ? begin->doc : BSONObj())); if (!status.isOK()) { @@ -574,15 +574,14 @@ Status CollectionImpl::insertDocuments(OperationContext* opCtx, Status CollectionImpl::insertDocument(OperationContext* opCtx, const InsertStatement& docToInsert, OpDebug* opDebug, - bool fromMigrate) { + bool fromMigrate) const { std::vector<InsertStatement> docs; docs.push_back(docToInsert); return insertDocuments(opCtx, docs.begin(), docs.end(), opDebug, fromMigrate); } -Status CollectionImpl::insertDocumentForBulkLoader(OperationContext* opCtx, - const BSONObj& doc, - const OnRecordInsertedFn& onRecordInserted) { +Status CollectionImpl::insertDocumentForBulkLoader( + OperationContext* opCtx, const BSONObj& doc, const OnRecordInsertedFn& onRecordInserted) const { auto status = checkFailCollectionInsertsFailPoint(_ns, doc); if (!status.isOK()) { @@ -636,7 +635,7 @@ Status CollectionImpl::insertDocumentForBulkLoader(OperationContext* opCtx, Status CollectionImpl::_insertDocuments(OperationContext* opCtx, const std::vector<InsertStatement>::const_iterator begin, const std::vector<InsertStatement>::const_iterator end, - OpDebug* opDebug) { + OpDebug* opDebug) const { dassert(opCtx->lockState()->isCollectionLockedForMode(ns(), MODE_IX)); const size_t count = std::distance(begin, end); @@ -740,7 +739,7 @@ void CollectionImpl::deleteDocument(OperationContext* opCtx, OpDebug* opDebug, bool fromMigrate, bool noWarn, - Collection::StoreDeletedDoc storeDeletedDoc) { + Collection::StoreDeletedDoc storeDeletedDoc) const { if (isCapped()) { LOGV2(20291, "failing remove on a capped ns {ns}", @@ -780,7 +779,7 @@ RecordId CollectionImpl::updateDocument(OperationContext* opCtx, const BSONObj& newDoc, bool indexesAffected, OpDebug* opDebug, - CollectionUpdateArgs* args) { + CollectionUpdateArgs* args) const { { auto status = checkValidation(opCtx, newDoc); if (!status.isOK()) { @@ -873,7 +872,7 @@ StatusWith<RecordData> CollectionImpl::updateDocumentWithDamages( const Snapshotted<RecordData>& oldRec, const char* damageSource, const mutablebson::DamageVector& damages, - CollectionUpdateArgs* args) { + CollectionUpdateArgs* args) const { dassert(opCtx->lockState()->isCollectionLockedForMode(ns(), MODE_IX)); invariant(oldRec.snapshotId() == opCtx->recoveryUnit()->getSnapshotId()); invariant(updateWithDamagesSupported()); |