kv_database_catalog_entry_base.h

Go to the documentation of this file.

#pragma once

#include <map>
#include <memory>
#include <string>

#include "mongo/db/catalog/database_catalog_entry.h"

namespace mongo {

class KVStorageEngine;
class KVCollectionCatalogEntry;

class KVDatabaseCatalogEntryBase : public DatabaseCatalogEntry {
public:
    KVDatabaseCatalogEntryBase(StringData db, KVStorageEngine* engine);
    ~KVDatabaseCatalogEntryBase() override;

    bool exists() const override;
    bool isEmpty() const override;
    bool hasUserData() const override;

    int64_t sizeOnDisk(OperationContext* opCtx) const override;

    void appendExtraStats(OperationContext* opCtx,
                          BSONObjBuilder* out,
                          double scale) const override;

    bool isOlderThan24(OperationContext* opCtx) const override {
        return false;
    }
    void markIndexSafe24AndUp(OperationContext* opCtx) override {}

    Status currentFilesCompatible(OperationContext* opCtx) const override;

    void getCollectionNamespaces(std::list<std::string>* out) const override;

    CollectionCatalogEntry* getCollectionCatalogEntry(StringData ns) const override;

    RecordStore* getRecordStore(StringData ns) const override;

    IndexAccessMethod* getIndex(OperationContext* opCtx,
                                const CollectionCatalogEntry* collection,
                                IndexCatalogEntry* index) override = 0;

    Status createCollection(OperationContext* opCtx,
                            StringData ns,
                            const CollectionOptions& options,
                            bool allocateDefaultSpace) override;

    Status renameCollection(OperationContext* opCtx,
                            StringData fromNS,
                            StringData toNS,
                            bool stayTemp) override;

    Status dropCollection(OperationContext* opCtx, StringData ns) override;

    // --------------

    void initCollection(OperationContext* opCtx, const std::string& ns, bool forRepair);

    void initCollectionBeforeRepair(OperationContext* opCtx, const std::string& ns);
    void reinitCollectionAfterRepair(OperationContext* opCtx, const std::string& ns);

protected:
    class AddCollectionChange;
    class RemoveCollectionChange;

    typedef std::map<std::string, KVCollectionCatalogEntry*> CollectionMap;


    KVStorageEngine* const _engine;  // not owned here
    CollectionMap _collections;
};
}  // namespace mongo