namespace_details_collection_entry.h

Go to the documentation of this file.

// namespace_details_collection_entry.h

#pragma once

#include "mongo/base/string_data.h"
#include "mongo/bson/bsonobj.h"
#include "mongo/db/catalog/collection_catalog_entry.h"
#include "mongo/db/server_options.h"
#include "mongo/db/storage/mmap_v1/diskloc.h"

namespace mongo {

class NamespaceDetails;

class MMAPV1DatabaseCatalogEntry;
;
class RecordStore;
class OperationContext;

class NamespaceDetailsCollectionCatalogEntry : public CollectionCatalogEntry {
public:
    NamespaceDetailsCollectionCatalogEntry(StringData ns,
                                           NamespaceDetails* details,
                                           RecordStore* namespacesRecordStore,
                                           RecordId namespacesRecordId,
                                           RecordStore* indexRecordStore,
                                           MMAPV1DatabaseCatalogEntry* db);

    ~NamespaceDetailsCollectionCatalogEntry() {}

    CollectionOptions getCollectionOptions(OperationContext* opCtx) const final;

    int getTotalIndexCount(OperationContext* opCtx) const final;

    int getCompletedIndexCount(OperationContext* opCtx) const final;

    int getMaxAllowedIndexes() const final;

    void getAllIndexes(OperationContext* opCtx, std::vector<std::string>* names) const final;

    void getReadyIndexes(OperationContext* opCtx, std::vector<std::string>* names) const final;

    BSONObj getIndexSpec(OperationContext* opCtx, StringData idxName) const final;

    bool isIndexMultikey(OperationContext* opCtx,
                         StringData indexName,
                         MultikeyPaths* multikeyPaths) const final;
    bool isIndexMultikey(int idxNo) const;

    bool setIndexIsMultikey(OperationContext* opCtx, int idxNo, bool multikey = true);
    bool setIndexIsMultikey(OperationContext* opCtx,
                            StringData indexName,
                            const MultikeyPaths& multikeyPaths) final;

    RecordId getIndexHead(OperationContext* opCtx, StringData indexName) const final;

    void setIndexHead(OperationContext* opCtx, StringData indexName, const RecordId& newHead) final;

    bool isIndexReady(OperationContext* opCtx, StringData indexName) const final;

    KVPrefix getIndexPrefix(OperationContext* opCtx, StringData indexName) const final;

    Status removeIndex(OperationContext* opCtx, StringData indexName) final;

    Status prepareForIndexBuild(OperationContext* opCtx,
                                const IndexDescriptor* spec,
                                bool isBackgroundSecondaryBuild) final;

    void indexBuildSuccess(OperationContext* opCtx, StringData indexName) final;

    void updateTTLSetting(OperationContext* opCtx,
                          StringData idxName,
                          long long newExpireSeconds) final;

    void updateFlags(OperationContext* opCtx, int newValue) final;

    bool isEqualToMetadataUUID(OperationContext* opCtx, OptionalCollectionUUID uuid);

    void updateValidator(OperationContext* opCtx,
                         const BSONObj& validator,
                         StringData validationLevel,
                         StringData validationAction) final;

    void setIsTemp(OperationContext* opCtx, bool isTemp) final;

    void updateCappedSize(OperationContext* opCtx, long long size) final;

    // not part of interface, but available to my storage engine

    int _findIndexNumber(OperationContext* opCtx, StringData indexName) const;

    RecordId getNamespacesRecordId() {
        return _namespacesRecordId;
    }

    void setNamespacesRecordId(OperationContext* opCtx, RecordId newId);

private:
    NamespaceDetails* _details;
    RecordStore* _namespacesRecordStore;

    // Where this entry lives in the _namespacesRecordStore.
    RecordId _namespacesRecordId;

    RecordStore* _indexRecordStore;
    MMAPV1DatabaseCatalogEntry* _db;

    void _updateSystemNamespaces(OperationContext* opCtx, const BSONObj& update);

    friend class MMAPV1DatabaseCatalogEntry;
};
}