31 #include "mongo/bson/timestamp.h" 38 class IndexConsistency;
48 OperationContext*
opCtx,
59 bool ok() const final {
79 const NamespaceString&
ns() const final {
120 bool findDoc(OperationContext* opCtx,
124 std::unique_ptr<SeekableRecordCursor>
getCursor(OperationContext* opCtx,
125 bool forward =
true)
const final;
131 std::vector<std::unique_ptr<RecordCursor>>
getManyCursors(OperationContext* opCtx)
const final;
149 OperationContext* opCtx,
153 bool fromMigrate =
false,
165 std::vector<InsertStatement>::const_iterator begin,
166 std::vector<InsertStatement>::const_iterator end,
169 bool fromMigrate =
false)
final;
179 const InsertStatement& doc,
182 bool fromMigrate =
false)
final;
190 Timestamp* timestamps,
200 const std::vector<MultiIndexBlock*>& indexBlocks,
201 bool enforceQuota)
final;
213 const RecordId& oldLocation,
215 const BSONObj& newDoc,
217 bool indexesAffected,
219 OplogUpdateEntryArgs* args)
final;
233 const char* damageSource,
234 const mutablebson::DamageVector& damages,
235 OplogUpdateEntryArgs* args)
final;
256 std::unique_ptr<Lock::CollectionLock> collLk,
258 BSONObjBuilder* output)
final;
266 BSONObjBuilder* output)
const final;
284 OperationContext* opCtx,
285 const BSONObj& validator,
286 MatchExpressionParser::AllowedFeatureSet allowedFeatures,
287 boost::optional<ServerGlobalParams::FeatureCompatibility::Version>
288 maxFeatureCompatibilityVersion = boost::none)
const final;
313 BSONObj newValidator,
315 StringData newAction) final;
333 uint64_t
numRecords(OperationContext* opCtx) const final;
335 uint64_t
dataSize(OperationContext* opCtx) const final;
342 return static_cast<int>(
dataSize(opCtx) / n);
346 BSONObjBuilder*
details = NULL,
347 int scale = 1)
final;
400 std::vector<InsertStatement>::const_iterator begin,
401 std::vector<InsertStatement>::const_iterator end,
410 const RecordId& oldLocation,
412 const BSONObj& newDoc,
415 OplogUpdateEntryArgs* args,
422 const NamespaceString
_ns;
Queries with the awaitData option use this notifier object to wait for more data to be inserted into ...
Definition: collection.h:105
ValidateCmdLevel
Definition: record_store.h:93
StoreDeletedDoc
Definition: collection.h:164
CursorManager _cursorManager
Definition: collection_impl.h:450
StatusWith< CompactStats > compact(OperationContext *opCtx, const CompactOptions *options) final
Definition: collection_compact.cpp:108
ValidationLevel _validationLevel
Definition: collection_impl.h:445
Definition: snapshot.h:69
Status setValidationLevel(OperationContext *opCtx, StringData newLevel) final
Definition: collection_impl.cpp:994
Definition: record_store.h:671
std::unique_ptr< SeekableRecordCursor > getCursor(OperationContext *opCtx, bool forward=true) const final
Definition: collection_impl.cpp:223
Status _insertDocuments(OperationContext *opCtx, std::vector< InsertStatement >::const_iterator begin, std::vector< InsertStatement >::const_iterator end, bool enforceQuota, OpDebug *opDebug)
Definition: collection_impl.cpp:460
ValidationAction _validationAction
Definition: collection_impl.h:444
StringData getValidationAction() const final
Definition: collection_impl.cpp:984
Status aboutToDeleteCapped(OperationContext *opCtx, const RecordId &loc, RecordData data)
This will be called right before loc is deleted when wrapping.
Definition: collection_impl.cpp:535
bool requiresIdIndex() const final
Definition: collection_impl.cpp:207
const NamespaceString _ns
Definition: collection_impl.h:422
CollectionCatalogEntry * details() const final
Definition: collection_impl.h:379
RecordStore * getRecordStore() final
Definition: collection_impl.h:101
static StatusWith< ValidationAction > parseValidationAction(StringData)
Definition: collection_impl.cpp:958
Copyright (C) 2014 MongoDB Inc.
Definition: bson_collection_catalog_entry.cpp:38
bool _enforceQuota(bool userEnforeQuota) const
Definition: collection_impl.cpp:807
Definition: collection_catalog_entry.h:47
Definition: collection_impl.h:40
OperationContext Database StringData BSONObj CollectionOptions::ParseKind bool const BSONObj &idIndex Status
Definition: database_impl.cpp:956
void refreshUUID(OperationContext *opCtx) final
Definition: collection_impl.cpp:198
A replacement for the Record class.
Definition: record_data.h:43
const NamespaceString & ns() const final
Definition: collection_impl.h:79
Status _insertDocument(OperationContext *opCtx, const BSONObj &doc, bool enforceQuota)
same semantics as insertDocument, but doesn't do:
int _magic
Definition: collection_impl.h:420
std::unique_ptr< CollatorInterface > _collator
Definition: collection_impl.h:436
const CollatorInterface * getDefaultCollator() const final
Get a pointer to the collection's default collator.
Definition: collection_impl.cpp:1074
Status setValidator(OperationContext *opCtx, BSONObj validator) final
Sets the validator for this collection.
Definition: collection_impl.cpp:913
Definition: collection.h:166
CollectionCatalogEntry * getCatalogEntry() final
Definition: collection_impl.h:63
Definition: record_store.h:78
BSONObj _validatorDoc
Definition: collection_impl.h:439
Status insertDocument(OperationContext *opCtx, const InsertStatement &doc, OpDebug *opDebug, bool enforceQuota, bool fromMigrate=false) final
this does NOT modify the doc before inserting i.e.
Definition: collection_impl.cpp:390
RecordStore *const _recordStore
Definition: collection_impl.h:425
Snapshotted< BSONObj > docFor(OperationContext *opCtx, const RecordId &loc) const final
Definition: collection_impl.h:111
bool inclusive
Definition: btree_interface.cpp:335
CollectionCatalogEntry *const _details
Definition: collection_impl.h:424
CollectionInfoCache * infoCache() final
Definition: collection_impl.h:71
int averageObjectSize(OperationContext *opCtx) const
Definition: collection_impl.h:337
this is NOT safe through a yield right now.
Definition: collection.h:160
bool findDoc(OperationContext *opCtx, const RecordId &loc, Snapshotted< BSONObj > *out) const final
Definition: collection_impl.cpp:239
Definition: collection.h:77
Allows inserting a Record "in-place" without creating a copy ahead of time.
Definition: record_store.h:62
StatusWith< RecordId > _updateDocumentWithMove(OperationContext *opCtx, const RecordId &oldLocation, const Snapshotted< BSONObj > &oldDoc, const BSONObj &newDoc, bool enforceQuota, OpDebug *opDebug, OplogUpdateEntryArgs *args, const SnapshotId &sid)
Perform update when document move will be required.
Definition: collection_impl.cpp:712
ValidationAction
Definition: collection.h:162
Definition: namespace_details.h:47
std::shared_ptr< void > data
Definition: ephemeral_for_test_record_store_test.cpp:74
Status touch(OperationContext *opCtx, bool touchData, bool touchIndexes, BSONObjBuilder *output) const final
forces data into cache
Definition: collection_impl.cpp:1352
RecordId updateDocument(OperationContext *opCtx, const RecordId &oldLocation, const Snapshotted< BSONObj > &oldDoc, const BSONObj &newDoc, bool enforceQuota, bool indexesAffected, OpDebug *opDebug, OplogUpdateEntryArgs *args) final
Updates the document @ oldLocation with newDoc.
Definition: collection_impl.cpp:593
Status checkValidation(OperationContext *opCtx, const BSONObj &document) const
Returns a non-ok Status if document does not pass this collection's validator.
Definition: collection_impl.cpp:251
const CollectionInfoCache * infoCache() const final
Definition: collection_impl.h:75
how many: 1 per Collection.
Definition: index_catalog.h:62
uint64_t getIndexSize(OperationContext *opCtx, BSONObjBuilder *details=NULL, int scale=1) final
Definition: collection_impl.cpp:840
bool updateWithDamagesSupported() const final
Definition: collection_impl.cpp:775
const bool _needCappedLock
Definition: collection_impl.h:427
bool isCapped() const final
Definition: collection_impl.cpp:823
Collection *const OperationContext *const const StringData OptionalCollectionUUID CollectionCatalogEntry *const RecordStore *const recordStore
Definition: collection_impl.cpp:80
CollectionInfoCache _infoCache
Definition: collection_impl.h:428
Status insertDocuments(OperationContext *opCtx, std::vector< InsertStatement >::const_iterator begin, std::vector< InsertStatement >::const_iterator end, OpDebug *opDebug, bool enforceQuota, bool fromMigrate=false) final
Definition: collection_impl.cpp:338
boost::optional< CollectionUUID > OptionalCollectionUUID
Definition: collection_options.h:55
static const int kMagicNumber
Definition: collection_impl.h:44
bool haveCappedWaiters() final
Returns true if there may be waiters.
Definition: collection_impl.cpp:522
IndexCatalog _indexCatalog
Definition: collection_impl.h:429
OptionalCollectionUUID uuid() const
Definition: collection_impl.h:83
Definition: index_key_validate.h:40
static StatusWith< ValidationLevel > parseValidationLevel(StringData)
Definition: collection_impl.cpp:942
void init(OperationContext *opCtx) final
Definition: collection_impl.cpp:169
virtual RecordData dataFor(OperationContext *opCtx, const RecordId &loc) const
Get the RecordData at loc, which must exist.
Definition: record_store.h:337
An abstraction used for storing documents in a collection or entries in an index. ...
Definition: record_store.h:282
When a capped collection is modified (delete/insert/etc) then certain notifications need to be made...
Definition: capped_callback.h:44
Status validate(OperationContext *opCtx, ValidateCmdLevel level, bool background, std::unique_ptr< Lock::CollectionLock > collLk, ValidateResults *results, BSONObjBuilder *output) final
Definition: collection_impl.cpp:1281
std::vector< std::unique_ptr< RecordCursor > > getManyCursors(OperationContext *opCtx) const final
Returns many cursors that partition the Collection into many disjoint sets.
Definition: collection_impl.cpp:231
Status truncate(OperationContext *opCtx) final
removes all documents as fast as possible indexes before and after will be the same as will other cha...
Definition: collection_impl.cpp:869
BSONObj releaseToBson()
Definition: record_data.h:74
StringData getValidationLevel() const final
Definition: collection_impl.cpp:972
uint64_t numRecords(OperationContext *opCtx) const final
Definition: collection_impl.cpp:832
~CollectionImpl()
Definition: collection_impl.cpp:178
IndexCatalog * getIndexCatalog() final
Definition: collection_impl.h:93
Status insertDocumentsForOplog(OperationContext *opCtx, const DocWriter *const *docs, Timestamp *timestamps, size_t nDocs) final
Callers must ensure no document validation is performed for this collection when calling this method...
Definition: collection_impl.cpp:315
CursorManager * getCursorManager() const final
Definition: collection_impl.h:105
Definition: database_catalog_entry.h:50
Collection *const OperationContext *const const StringData fullNS
Definition: collection_impl.cpp:80
std::shared_ptr< CappedInsertNotifier > getCappedInsertNotifier() const final
Get a pointer to a capped insert notifier object.
Definition: collection_impl.cpp:827
boost::optional< Timestamp > _minVisibleSnapshot
Definition: collection_impl.h:459
Collection * _this
Definition: collection_impl.h:461
Status setValidationAction(OperationContext *opCtx, StringData newAction) final
Definition: collection_impl.cpp:1012
DatabaseCatalogEntry *const _dbce
Definition: collection_impl.h:426
OperationContext Database StringData BSONObj options
Definition: database_impl.cpp:949
const IndexCatalog * getIndexCatalog() const final
Definition: collection_impl.h:89
Status updateValidator(OperationContext *opCtx, BSONObj newValidator, StringData newLevel, StringData newAction) final
Sets the validator to exactly what's provided.
Definition: collection_impl.cpp:1030
void cappedTruncateAfter(OperationContext *opCtx, RecordId end, bool inclusive) final
Truncate documents newer than the document at 'end' from the capped collection.
Definition: collection_impl.cpp:903
StatusWithMatchExpression parseValidator(OperationContext *opCtx, const BSONObj &validator, MatchExpressionParser::AllowedFeatureSet allowedFeatures, boost::optional< ServerGlobalParams::FeatureCompatibility::Version > maxFeatureCompatibilityVersion=boost::none) const final
Returns a non-ok Status if validator is not legal for this collection.
Definition: collection_impl.cpp:273
Status recordStoreGoingToUpdateInPlace(OperationContext *opCtx, const RecordId &loc)
Definition: collection_impl.cpp:767
boost::optional< Timestamp > getMinimumVisibleSnapshot() final
If return value is not boost::none, reads with majority read concern using an older snapshot must err...
Definition: collection_impl.h:353
Definition: snapshot.h:37
ValidationLevel
Definition: collection.h:163
bool ok() const final
Definition: collection_impl.h:59
uint64_t dataSize(OperationContext *opCtx) const final
Definition: collection_impl.cpp:836
Database *const OperationContext *const const StringData name
Definition: database_impl.cpp:82
Collection *const OperationContext *const opCtx
Definition: collection_impl.cpp:80
CollectionImpl(Collection *_this, OperationContext *opCtx, StringData fullNS, OptionalCollectionUUID uuid, CollectionCatalogEntry *details, RecordStore *recordStore, DatabaseCatalogEntry *dbce)
Definition: collection_impl.cpp:141
OptionalCollectionUUID _uuid
Definition: collection_impl.h:423
this is for storing things that you want to cache about a single collection life cycle is managed for...
Definition: collection_info_cache.h:47
DatabaseCatalogEntry * dbce() const final
Definition: collection_impl.h:375
const RecordStore * getRecordStore() const final
Definition: collection_impl.h:97
void setMinimumVisibleSnapshot(Timestamp name) final
Definition: collection_impl.h:357
const CollectionCatalogEntry * getCatalogEntry() const final
Definition: collection_impl.h:67
void notifyCappedWaitersIfNeeded() final
Notify (capped collection) waiters of data changes, like an insert.
Definition: collection_impl.cpp:528
void deleteDocument(OperationContext *opCtx, StmtId stmtId, const RecordId &loc, OpDebug *opDebug, bool fromMigrate=false, bool noWarn=false, Collection::StoreDeletedDoc storeDeletedDoc=Collection::StoreDeletedDoc::Off) final
Deletes the document with the given RecordId from the collection.
Definition: collection_impl.cpp:554
StatusWith< RecordData > updateDocumentWithDamages(OperationContext *opCtx, const RecordId &loc, const Snapshotted< RecordData > &oldRec, const char *damageSource, const mutablebson::DamageVector &damages, OplogUpdateEntryArgs *args) final
Not allowed to modify indexes.
Definition: collection_impl.cpp:782
std::unique_ptr< MatchExpression > _validator
Definition: collection_impl.h:442
const std::shared_ptr< CappedInsertNotifier > _cappedNotifier
Definition: collection_impl.h:456