diff options
Diffstat (limited to 'src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h')
| -rw-r--r-- | src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h b/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h index 33168e1dc99..b9d44c6905e 100644 --- a/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h +++ b/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.h @@ -54,23 +54,23 @@ public: virtual const char* name() const; - virtual RecordData dataFor(OperationContext* txn, const RecordId& loc) const; + virtual RecordData dataFor(OperationContext* opCtx, const RecordId& loc) const; - virtual bool findRecord(OperationContext* txn, const RecordId& loc, RecordData* rd) const; + virtual bool findRecord(OperationContext* opCtx, const RecordId& loc, RecordData* rd) const; - virtual void deleteRecord(OperationContext* txn, const RecordId& dl); + virtual void deleteRecord(OperationContext* opCtx, const RecordId& dl); - virtual StatusWith<RecordId> insertRecord(OperationContext* txn, + virtual StatusWith<RecordId> insertRecord(OperationContext* opCtx, const char* data, int len, bool enforceQuota); - virtual Status insertRecordsWithDocWriter(OperationContext* txn, + virtual Status insertRecordsWithDocWriter(OperationContext* opCtx, const DocWriter* const* docs, size_t nDocs, RecordId* idsOut); - virtual Status updateRecord(OperationContext* txn, + virtual Status updateRecord(OperationContext* opCtx, const RecordId& oldLocation, const char* data, int len, @@ -79,51 +79,51 @@ public: virtual bool updateWithDamagesSupported() const; - virtual StatusWith<RecordData> updateWithDamages(OperationContext* txn, + virtual StatusWith<RecordData> updateWithDamages(OperationContext* opCtx, const RecordId& loc, const RecordData& oldRec, const char* damageSource, const mutablebson::DamageVector& damages); - std::unique_ptr<SeekableRecordCursor> getCursor(OperationContext* txn, + std::unique_ptr<SeekableRecordCursor> getCursor(OperationContext* opCtx, bool forward) const final; - virtual Status truncate(OperationContext* txn); + virtual Status truncate(OperationContext* opCtx); - virtual void cappedTruncateAfter(OperationContext* txn, RecordId end, bool inclusive); + virtual void cappedTruncateAfter(OperationContext* opCtx, RecordId end, bool inclusive); - virtual Status validate(OperationContext* txn, + virtual Status validate(OperationContext* opCtx, ValidateCmdLevel level, ValidateAdaptor* adaptor, ValidateResults* results, BSONObjBuilder* output); - virtual void appendCustomStats(OperationContext* txn, + virtual void appendCustomStats(OperationContext* opCtx, BSONObjBuilder* result, double scale) const; - virtual Status touch(OperationContext* txn, BSONObjBuilder* output) const; + virtual Status touch(OperationContext* opCtx, BSONObjBuilder* output) const; - virtual void increaseStorageSize(OperationContext* txn, int size, bool enforceQuota); + virtual void increaseStorageSize(OperationContext* opCtx, int size, bool enforceQuota); - virtual int64_t storageSize(OperationContext* txn, + virtual int64_t storageSize(OperationContext* opCtx, BSONObjBuilder* extraInfo = NULL, int infoLevel = 0) const; - virtual long long dataSize(OperationContext* txn) const { + virtual long long dataSize(OperationContext* opCtx) const { return _data->dataSize; } - virtual long long numRecords(OperationContext* txn) const { + virtual long long numRecords(OperationContext* opCtx) const { return _data->records.size(); } - virtual boost::optional<RecordId> oplogStartHack(OperationContext* txn, + virtual boost::optional<RecordId> oplogStartHack(OperationContext* opCtx, const RecordId& startingPosition) const; - void waitForAllEarlierOplogWritesToBeVisible(OperationContext* txn) const override {} + void waitForAllEarlierOplogWritesToBeVisible(OperationContext* opCtx) const override {} - virtual void updateStatsAfterRepair(OperationContext* txn, + virtual void updateStatsAfterRepair(OperationContext* opCtx, long long numRecords, long long dataSize) { invariant(_data->records.size() == size_t(numRecords)); @@ -179,8 +179,8 @@ private: StatusWith<RecordId> extractAndCheckLocForOplog(const char* data, int len) const; RecordId allocateLoc(); - bool cappedAndNeedDelete(OperationContext* txn) const; - void cappedDeleteAsNeeded(OperationContext* txn); + bool cappedAndNeedDelete(OperationContext* opCtx) const; + void cappedDeleteAsNeeded(OperationContext* opCtx); // TODO figure out a proper solution to metadata const bool _isCapped; |