summaryrefslogtreecommitdiff
path: root/src/mongo/db/catalog/collection_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/catalog/collection_impl.cpp')
-rw-r--r--src/mongo/db/catalog/collection_impl.cpp19
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());