summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h')
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h426
1 files changed, 217 insertions, 209 deletions
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h b/src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h
index 00fd04d42b9..1aa0dec93e7 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_record_store.h
@@ -49,217 +49,225 @@
namespace mongo {
- class RecoveryUnit;
- class WiredTigerCursor;
- class WiredTigerRecoveryUnit;
- class WiredTigerSizeStorer;
-
- extern const std::string kWiredTigerEngineName;
-
- class WiredTigerRecordStore : public RecordStore {
- public:
-
- /**
- * Parses collections options for wired tiger configuration string for table creation.
- * The document 'options' is typically obtained from the 'wiredTiger' field of
- * CollectionOptions::storageEngine.
- */
- static StatusWith<std::string> parseOptionsField(const BSONObj options);
-
- /**
- * Creates a configuration string suitable for 'config' parameter in WT_SESSION::create().
- * Configuration string is constructed from:
- * built-in defaults
- * storageEngine.wiredTiger.configString in 'options'
- * 'extraStrings'
- * Performs simple validation on the supplied parameters.
- * Returns error status if validation fails.
- * Note that even if this function returns an OK status, WT_SESSION:create() may still
- * fail with the constructed configuration string.
- */
- static StatusWith<std::string> generateCreateString(StringData ns,
- const CollectionOptions &options,
- StringData extraStrings);
-
- WiredTigerRecordStore(OperationContext* txn,
- StringData ns,
- StringData uri,
- bool isCapped = false,
- int64_t cappedMaxSize = -1,
- int64_t cappedMaxDocs = -1,
- CappedDocumentDeleteCallback* cappedDeleteCallback = NULL,
- WiredTigerSizeStorer* sizeStorer = NULL );
+class RecoveryUnit;
+class WiredTigerCursor;
+class WiredTigerRecoveryUnit;
+class WiredTigerSizeStorer;
+
+extern const std::string kWiredTigerEngineName;
+
+class WiredTigerRecordStore : public RecordStore {
+public:
+ /**
+ * Parses collections options for wired tiger configuration string for table creation.
+ * The document 'options' is typically obtained from the 'wiredTiger' field of
+ * CollectionOptions::storageEngine.
+ */
+ static StatusWith<std::string> parseOptionsField(const BSONObj options);
+
+ /**
+ * Creates a configuration string suitable for 'config' parameter in WT_SESSION::create().
+ * Configuration string is constructed from:
+ * built-in defaults
+ * storageEngine.wiredTiger.configString in 'options'
+ * 'extraStrings'
+ * Performs simple validation on the supplied parameters.
+ * Returns error status if validation fails.
+ * Note that even if this function returns an OK status, WT_SESSION:create() may still
+ * fail with the constructed configuration string.
+ */
+ static StatusWith<std::string> generateCreateString(StringData ns,
+ const CollectionOptions& options,
+ StringData extraStrings);
+
+ WiredTigerRecordStore(OperationContext* txn,
+ StringData ns,
+ StringData uri,
+ bool isCapped = false,
+ int64_t cappedMaxSize = -1,
+ int64_t cappedMaxDocs = -1,
+ CappedDocumentDeleteCallback* cappedDeleteCallback = NULL,
+ WiredTigerSizeStorer* sizeStorer = NULL);
+
+ virtual ~WiredTigerRecordStore();
+
+ // name of the RecordStore implementation
+ virtual const char* name() const;
+
+ virtual long long dataSize(OperationContext* txn) const;
+
+ virtual long long numRecords(OperationContext* txn) const;
+
+ virtual bool isCapped() const;
+
+ virtual int64_t storageSize(OperationContext* txn,
+ BSONObjBuilder* extraInfo = NULL,
+ int infoLevel = 0) const;
+
+ // CRUD related
+
+ virtual RecordData dataFor(OperationContext* txn, const RecordId& loc) const;
+
+ virtual bool findRecord(OperationContext* txn, const RecordId& loc, RecordData* out) const;
+
+ virtual void deleteRecord(OperationContext* txn, const RecordId& dl);
+
+ virtual StatusWith<RecordId> insertRecord(OperationContext* txn,
+ const char* data,
+ int len,
+ bool enforceQuota);
+
+ virtual StatusWith<RecordId> insertRecord(OperationContext* txn,
+ const DocWriter* doc,
+ bool enforceQuota);
+
+ virtual StatusWith<RecordId> updateRecord(OperationContext* txn,
+ const RecordId& oldLocation,
+ const char* data,
+ int len,
+ bool enforceQuota,
+ UpdateNotifier* notifier);
+
+ virtual bool updateWithDamagesSupported() const;
+
+ virtual Status updateWithDamages(OperationContext* txn,
+ const RecordId& loc,
+ const RecordData& oldRec,
+ const char* damageSource,
+ const mutablebson::DamageVector& damages);
+
+ std::unique_ptr<RecordCursor> getCursor(OperationContext* txn, bool forward) const final;
+ std::vector<std::unique_ptr<RecordCursor>> getManyCursors(OperationContext* txn) const final;
+
+ virtual Status truncate(OperationContext* txn);
+
+ virtual bool compactSupported() const {
+ return true;
+ }
+ virtual bool compactsInPlace() const {
+ return true;
+ }
+
+ virtual Status compact(OperationContext* txn,
+ RecordStoreCompactAdaptor* adaptor,
+ const CompactOptions* options,
+ CompactStats* stats);
+
+ virtual Status validate(OperationContext* txn,
+ bool full,
+ bool scanData,
+ ValidateAdaptor* adaptor,
+ ValidateResults* results,
+ BSONObjBuilder* output);
+
+ virtual void appendCustomStats(OperationContext* txn,
+ BSONObjBuilder* result,
+ double scale) const;
+
+ virtual void temp_cappedTruncateAfter(OperationContext* txn, RecordId end, bool inclusive);
+
+ virtual boost::optional<RecordId> oplogStartHack(OperationContext* txn,
+ const RecordId& startingPosition) const;
+
+ virtual Status oplogDiskLocRegister(OperationContext* txn, const Timestamp& opTime);
+
+ virtual void updateStatsAfterRepair(OperationContext* txn,
+ long long numRecords,
+ long long dataSize);
+
+ bool isOplog() const {
+ return _isOplog;
+ }
+ bool usingOplogHack() const {
+ return _useOplogHack;
+ }
- virtual ~WiredTigerRecordStore();
+ void setCappedDeleteCallback(CappedDocumentDeleteCallback* cb) {
+ _cappedDeleteCallback = cb;
+ }
+ int64_t cappedMaxDocs() const;
+ int64_t cappedMaxSize() const;
- // name of the RecordStore implementation
- virtual const char* name() const;
+ const std::string& getURI() const {
+ return _uri;
+ }
+ uint64_t instanceId() const {
+ return _instanceId;
+ }
- virtual long long dataSize( OperationContext *txn ) const;
-
- virtual long long numRecords( OperationContext* txn ) const;
-
- virtual bool isCapped() const;
-
- virtual int64_t storageSize( OperationContext* txn,
- BSONObjBuilder* extraInfo = NULL,
- int infoLevel = 0 ) const;
-
- // CRUD related
-
- virtual RecordData dataFor( OperationContext* txn, const RecordId& loc ) const;
-
- virtual bool findRecord( OperationContext* txn, const RecordId& loc, RecordData* out ) const;
-
- virtual void deleteRecord( OperationContext* txn, const RecordId& dl );
-
- virtual StatusWith<RecordId> insertRecord( OperationContext* txn,
- const char* data,
- int len,
- bool enforceQuota );
-
- virtual StatusWith<RecordId> insertRecord( OperationContext* txn,
- const DocWriter* doc,
- bool enforceQuota );
-
- virtual StatusWith<RecordId> updateRecord( OperationContext* txn,
- const RecordId& oldLocation,
- const char* data,
- int len,
- bool enforceQuota,
- UpdateNotifier* notifier );
-
- virtual bool updateWithDamagesSupported() const;
-
- virtual Status updateWithDamages( OperationContext* txn,
- const RecordId& loc,
- const RecordData& oldRec,
- const char* damageSource,
- const mutablebson::DamageVector& damages );
-
- std::unique_ptr<RecordCursor> getCursor(OperationContext* txn, bool forward) const final;
- std::vector<std::unique_ptr<RecordCursor>> getManyCursors(
- OperationContext* txn) const final;
-
- virtual Status truncate( OperationContext* txn );
-
- virtual bool compactSupported() const { return true; }
- virtual bool compactsInPlace() const { return true; }
-
- virtual Status compact( OperationContext* txn,
- RecordStoreCompactAdaptor* adaptor,
- const CompactOptions* options,
- CompactStats* stats );
-
- virtual Status validate( OperationContext* txn,
- bool full,
- bool scanData,
- ValidateAdaptor* adaptor,
- ValidateResults* results,
- BSONObjBuilder* output );
-
- virtual void appendCustomStats( OperationContext* txn,
- BSONObjBuilder* result,
- double scale ) const;
-
- virtual void temp_cappedTruncateAfter(OperationContext* txn,
- RecordId end,
- bool inclusive);
-
- virtual boost::optional<RecordId> oplogStartHack(OperationContext* txn,
- const RecordId& startingPosition) const;
-
- virtual Status oplogDiskLocRegister( OperationContext* txn,
- const Timestamp& opTime );
-
- virtual void updateStatsAfterRepair(OperationContext* txn,
- long long numRecords,
- long long dataSize);
-
- bool isOplog() const { return _isOplog; }
- bool usingOplogHack() const { return _useOplogHack; }
-
- void setCappedDeleteCallback(CappedDocumentDeleteCallback* cb) {
- _cappedDeleteCallback = cb;
- }
- int64_t cappedMaxDocs() const;
- int64_t cappedMaxSize() const;
-
- const std::string& getURI() const { return _uri; }
- uint64_t instanceId() const { return _instanceId; }
-
- void setSizeStorer( WiredTigerSizeStorer* ss ) { _sizeStorer = ss; }
-
- void dealtWithCappedLoc( const RecordId& loc );
- bool isCappedHidden( const RecordId& loc ) const;
-
- bool inShutdown() const;
- int64_t cappedDeleteAsNeeded(OperationContext* txn,
- const RecordId& justInserted);
-
- int64_t cappedDeleteAsNeeded_inlock(OperationContext* txn,
- const RecordId& justInserted);
-
- stdx::timed_mutex& cappedDeleterMutex() { return _cappedDeleterMutex; }
-
- private:
- class Cursor;
-
- class CappedInsertChange;
- class NumRecordsChange;
- class DataSizeChange;
-
- static WiredTigerRecoveryUnit* _getRecoveryUnit( OperationContext* txn );
-
- static int64_t _makeKey(const RecordId &loc);
- static RecordId _fromKey(int64_t k);
-
- void _addUncommitedDiskLoc_inlock( OperationContext* txn, const RecordId& loc );
-
- RecordId _nextId();
- void _setId(RecordId loc);
- bool cappedAndNeedDelete() const;
- void _changeNumRecords(OperationContext* txn, int64_t diff);
- void _increaseDataSize(OperationContext* txn, int amount);
- RecordData _getData( const WiredTigerCursor& cursor) const;
- StatusWith<RecordId> extractAndCheckLocForOplog(const char* data, int len);
- void _oplogSetStartHack( WiredTigerRecoveryUnit* wru ) const;
-
- const std::string _uri;
- const uint64_t _instanceId; // not persisted
-
- // The capped settings should not be updated once operations have started
- const bool _isCapped;
- const bool _isOplog;
- const int64_t _cappedMaxSize;
- const int64_t _cappedMaxSizeSlack; // when to start applying backpressure
- const int64_t _cappedMaxDocs;
- AtomicInt64 _cappedSleep;
- AtomicInt64 _cappedSleepMS;
- CappedDocumentDeleteCallback* _cappedDeleteCallback;
- int _cappedDeleteCheckCount; // see comment in ::cappedDeleteAsNeeded
- mutable stdx::timed_mutex _cappedDeleterMutex; // see comment in ::cappedDeleteAsNeeded
-
- const bool _useOplogHack;
-
- typedef std::vector<RecordId> SortedDiskLocs;
- SortedDiskLocs _uncommittedDiskLocs;
- RecordId _oplog_visibleTo;
- RecordId _oplog_highestSeen;
- mutable stdx::mutex _uncommittedDiskLocsMutex;
-
- AtomicInt64 _nextIdNum;
- AtomicInt64 _dataSize;
- AtomicInt64 _numRecords;
-
- WiredTigerSizeStorer* _sizeStorer; // not owned, can be NULL
- int _sizeStorerCounter;
-
- bool _shuttingDown;
- bool _hasBackgroundThread;
- };
-
- // WT failpoint to throw write conflict exceptions randomly
- MONGO_FP_FORWARD_DECLARE(WTWriteConflictException);
+ void setSizeStorer(WiredTigerSizeStorer* ss) {
+ _sizeStorer = ss;
+ }
+
+ void dealtWithCappedLoc(const RecordId& loc);
+ bool isCappedHidden(const RecordId& loc) const;
+
+ bool inShutdown() const;
+ int64_t cappedDeleteAsNeeded(OperationContext* txn, const RecordId& justInserted);
+
+ int64_t cappedDeleteAsNeeded_inlock(OperationContext* txn, const RecordId& justInserted);
+
+ stdx::timed_mutex& cappedDeleterMutex() {
+ return _cappedDeleterMutex;
+ }
+
+private:
+ class Cursor;
+
+ class CappedInsertChange;
+ class NumRecordsChange;
+ class DataSizeChange;
+
+ static WiredTigerRecoveryUnit* _getRecoveryUnit(OperationContext* txn);
+
+ static int64_t _makeKey(const RecordId& loc);
+ static RecordId _fromKey(int64_t k);
+
+ void _addUncommitedDiskLoc_inlock(OperationContext* txn, const RecordId& loc);
+
+ RecordId _nextId();
+ void _setId(RecordId loc);
+ bool cappedAndNeedDelete() const;
+ void _changeNumRecords(OperationContext* txn, int64_t diff);
+ void _increaseDataSize(OperationContext* txn, int amount);
+ RecordData _getData(const WiredTigerCursor& cursor) const;
+ StatusWith<RecordId> extractAndCheckLocForOplog(const char* data, int len);
+ void _oplogSetStartHack(WiredTigerRecoveryUnit* wru) const;
+
+ const std::string _uri;
+ const uint64_t _instanceId; // not persisted
+
+ // The capped settings should not be updated once operations have started
+ const bool _isCapped;
+ const bool _isOplog;
+ const int64_t _cappedMaxSize;
+ const int64_t _cappedMaxSizeSlack; // when to start applying backpressure
+ const int64_t _cappedMaxDocs;
+ AtomicInt64 _cappedSleep;
+ AtomicInt64 _cappedSleepMS;
+ CappedDocumentDeleteCallback* _cappedDeleteCallback;
+ int _cappedDeleteCheckCount; // see comment in ::cappedDeleteAsNeeded
+ mutable stdx::timed_mutex _cappedDeleterMutex; // see comment in ::cappedDeleteAsNeeded
+
+ const bool _useOplogHack;
+
+ typedef std::vector<RecordId> SortedDiskLocs;
+ SortedDiskLocs _uncommittedDiskLocs;
+ RecordId _oplog_visibleTo;
+ RecordId _oplog_highestSeen;
+ mutable stdx::mutex _uncommittedDiskLocsMutex;
+
+ AtomicInt64 _nextIdNum;
+ AtomicInt64 _dataSize;
+ AtomicInt64 _numRecords;
+
+ WiredTigerSizeStorer* _sizeStorer; // not owned, can be NULL
+ int _sizeStorerCounter;
+ bool _shuttingDown;
+ bool _hasBackgroundThread;
+};
+
+// WT failpoint to throw write conflict exceptions randomly
+MONGO_FP_FORWARD_DECLARE(WTWriteConflictException);
}
View Lorry Controller Status