summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp')
-rw-r--r--src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp61
1 files changed, 31 insertions, 30 deletions
diff --git a/src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp b/src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp
index eaa3a1cf958..7d5f1805d68 100644
--- a/src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp
+++ b/src/mongo/db/storage/mmap_v1/catalog/namespace_details_rsv1_metadata.cpp
@@ -48,16 +48,17 @@ const DiskLoc& NamespaceDetailsRSV1MetaData::capExtent() const {
return _details->capExtent;
}
-void NamespaceDetailsRSV1MetaData::setCapExtent(OperationContext* txn, const DiskLoc& loc) {
- *txn->recoveryUnit()->writing(&_details->capExtent) = loc;
+void NamespaceDetailsRSV1MetaData::setCapExtent(OperationContext* opCtx, const DiskLoc& loc) {
+ *opCtx->recoveryUnit()->writing(&_details->capExtent) = loc;
}
const DiskLoc& NamespaceDetailsRSV1MetaData::capFirstNewRecord() const {
return _details->capFirstNewRecord;
}
-void NamespaceDetailsRSV1MetaData::setCapFirstNewRecord(OperationContext* txn, const DiskLoc& loc) {
- *txn->recoveryUnit()->writing(&_details->capFirstNewRecord) = loc;
+void NamespaceDetailsRSV1MetaData::setCapFirstNewRecord(OperationContext* opCtx,
+ const DiskLoc& loc) {
+ *opCtx->recoveryUnit()->writing(&_details->capFirstNewRecord) = loc;
}
bool NamespaceDetailsRSV1MetaData::capLooped() const {
@@ -71,19 +72,19 @@ long long NamespaceDetailsRSV1MetaData::numRecords() const {
return _details->stats.nrecords;
}
-void NamespaceDetailsRSV1MetaData::incrementStats(OperationContext* txn,
+void NamespaceDetailsRSV1MetaData::incrementStats(OperationContext* opCtx,
long long dataSizeIncrement,
long long numRecordsIncrement) {
// durability todo : this could be a bit annoying / slow to record constantly
- NamespaceDetails::Stats* s = txn->recoveryUnit()->writing(&_details->stats);
+ NamespaceDetails::Stats* s = opCtx->recoveryUnit()->writing(&_details->stats);
s->datasize += dataSizeIncrement;
s->nrecords += numRecordsIncrement;
}
-void NamespaceDetailsRSV1MetaData::setStats(OperationContext* txn,
+void NamespaceDetailsRSV1MetaData::setStats(OperationContext* opCtx,
long long dataSize,
long long numRecords) {
- NamespaceDetails::Stats* s = txn->recoveryUnit()->writing(&_details->stats);
+ NamespaceDetails::Stats* s = opCtx->recoveryUnit()->writing(&_details->stats);
s->datasize = dataSize;
s->nrecords = numRecords;
}
@@ -103,45 +104,45 @@ DiskLoc NamespaceDetailsRSV1MetaData::deletedListEntry(int bucket) const {
return head;
}
-void NamespaceDetailsRSV1MetaData::setDeletedListEntry(OperationContext* txn,
+void NamespaceDetailsRSV1MetaData::setDeletedListEntry(OperationContext* opCtx,
int bucket,
const DiskLoc& loc) {
DiskLoc* head = (bucket < NamespaceDetails::SmallBuckets)
? &_details->deletedListSmall[bucket]
: &_details->deletedListLarge[bucket - NamespaceDetails::SmallBuckets];
- *txn->recoveryUnit()->writing(head) = loc;
+ *opCtx->recoveryUnit()->writing(head) = loc;
}
DiskLoc NamespaceDetailsRSV1MetaData::deletedListLegacyGrabBag() const {
return _details->deletedListLegacyGrabBag;
}
-void NamespaceDetailsRSV1MetaData::setDeletedListLegacyGrabBag(OperationContext* txn,
+void NamespaceDetailsRSV1MetaData::setDeletedListLegacyGrabBag(OperationContext* opCtx,
const DiskLoc& loc) {
- *txn->recoveryUnit()->writing(&_details->deletedListLegacyGrabBag) = loc;
+ *opCtx->recoveryUnit()->writing(&_details->deletedListLegacyGrabBag) = loc;
}
-void NamespaceDetailsRSV1MetaData::orphanDeletedList(OperationContext* txn) {
+void NamespaceDetailsRSV1MetaData::orphanDeletedList(OperationContext* opCtx) {
for (int i = 0; i < RecordStoreV1Base::Buckets; i++) {
- setDeletedListEntry(txn, i, DiskLoc());
+ setDeletedListEntry(opCtx, i, DiskLoc());
}
- setDeletedListLegacyGrabBag(txn, DiskLoc());
+ setDeletedListLegacyGrabBag(opCtx, DiskLoc());
}
-const DiskLoc& NamespaceDetailsRSV1MetaData::firstExtent(OperationContext* txn) const {
+const DiskLoc& NamespaceDetailsRSV1MetaData::firstExtent(OperationContext* opCtx) const {
return _details->firstExtent;
}
-void NamespaceDetailsRSV1MetaData::setFirstExtent(OperationContext* txn, const DiskLoc& loc) {
- *txn->recoveryUnit()->writing(&_details->firstExtent) = loc;
+void NamespaceDetailsRSV1MetaData::setFirstExtent(OperationContext* opCtx, const DiskLoc& loc) {
+ *opCtx->recoveryUnit()->writing(&_details->firstExtent) = loc;
}
-const DiskLoc& NamespaceDetailsRSV1MetaData::lastExtent(OperationContext* txn) const {
+const DiskLoc& NamespaceDetailsRSV1MetaData::lastExtent(OperationContext* opCtx) const {
return _details->lastExtent;
}
-void NamespaceDetailsRSV1MetaData::setLastExtent(OperationContext* txn, const DiskLoc& loc) {
- *txn->recoveryUnit()->writing(&_details->lastExtent) = loc;
+void NamespaceDetailsRSV1MetaData::setLastExtent(OperationContext* opCtx, const DiskLoc& loc) {
+ *opCtx->recoveryUnit()->writing(&_details->lastExtent) = loc;
}
bool NamespaceDetailsRSV1MetaData::isCapped() const {
@@ -156,38 +157,38 @@ int NamespaceDetailsRSV1MetaData::userFlags() const {
return _details->userFlags;
}
-bool NamespaceDetailsRSV1MetaData::setUserFlag(OperationContext* txn, int flag) {
+bool NamespaceDetailsRSV1MetaData::setUserFlag(OperationContext* opCtx, int flag) {
if ((_details->userFlags & flag) == flag)
return false;
- txn->recoveryUnit()->writingInt(_details->userFlags) |= flag;
+ opCtx->recoveryUnit()->writingInt(_details->userFlags) |= flag;
return true;
}
-bool NamespaceDetailsRSV1MetaData::clearUserFlag(OperationContext* txn, int flag) {
+bool NamespaceDetailsRSV1MetaData::clearUserFlag(OperationContext* opCtx, int flag) {
if ((_details->userFlags & flag) == 0)
return false;
- txn->recoveryUnit()->writingInt(_details->userFlags) &= ~flag;
+ opCtx->recoveryUnit()->writingInt(_details->userFlags) &= ~flag;
return true;
}
-bool NamespaceDetailsRSV1MetaData::replaceUserFlags(OperationContext* txn, int flags) {
+bool NamespaceDetailsRSV1MetaData::replaceUserFlags(OperationContext* opCtx, int flags) {
if (_details->userFlags == flags)
return false;
- txn->recoveryUnit()->writingInt(_details->userFlags) = flags;
+ opCtx->recoveryUnit()->writingInt(_details->userFlags) = flags;
return true;
}
-int NamespaceDetailsRSV1MetaData::lastExtentSize(OperationContext* txn) const {
+int NamespaceDetailsRSV1MetaData::lastExtentSize(OperationContext* opCtx) const {
return _details->lastExtentSize;
}
-void NamespaceDetailsRSV1MetaData::setLastExtentSize(OperationContext* txn, int newMax) {
+void NamespaceDetailsRSV1MetaData::setLastExtentSize(OperationContext* opCtx, int newMax) {
if (_details->lastExtentSize == newMax)
return;
- txn->recoveryUnit()->writingInt(_details->lastExtentSize) = newMax;
+ opCtx->recoveryUnit()->writingInt(_details->lastExtentSize) = newMax;
}
long long NamespaceDetailsRSV1MetaData::maxCappedDocs() const {