record_store_v1_simple.h

Go to the documentation of this file.

// record_store_v1_simple.h

#pragma once

#include "mongo/db/catalog/collection_options.h"
#include "mongo/db/storage/mmap_v1/diskloc.h"
#include "mongo/db/storage/mmap_v1/record_store_v1_base.h"

namespace mongo {

class SimpleRecordStoreV1Cursor;

// used by index and original collections
class SimpleRecordStoreV1 : public RecordStoreV1Base {
public:
    SimpleRecordStoreV1(OperationContext* opCtx,
                        StringData ns,
                        RecordStoreV1MetaData* details,
                        ExtentManager* em,
                        bool isSystemIndexes);

    virtual ~SimpleRecordStoreV1();

    const char* name() const {
        return "SimpleRecordStoreV1";
    }

    std::unique_ptr<SeekableRecordCursor> getCursor(OperationContext* opCtx,
                                                    bool forward) const final;

    std::vector<std::unique_ptr<RecordCursor>> getManyCursors(OperationContext* opCtx) const final;

    virtual Status truncate(OperationContext* opCtx);

    virtual void cappedTruncateAfter(OperationContext* opCtx, RecordId end, bool inclusive) {
        invariant(!"cappedTruncateAfter not supported");
    }

    virtual bool compactSupported() const {
        return true;
    }
    virtual bool compactsInPlace() const {
        return false;
    }
    virtual Status compact(OperationContext* opCtx,
                           RecordStoreCompactAdaptor* adaptor,
                           const CompactOptions* options,
                           CompactStats* stats);

protected:
    virtual bool isCapped() const {
        return false;
    }
    virtual bool shouldPadInserts() const {
        return !_details->isUserFlagSet(CollectionOptions::Flag_NoPadding);
    }

    virtual StatusWith<DiskLoc> allocRecord(OperationContext* opCtx,
                                            int lengthWithHeaders,
                                            bool enforceQuota);

    virtual void addDeletedRec(OperationContext* opCtx, const DiskLoc& dloc);

private:
    DiskLoc _allocFromExistingExtents(OperationContext* opCtx, int lengthWithHeaders);

    void _compactExtent(OperationContext* opCtx,
                        const DiskLoc diskloc,
                        int extentNumber,
                        RecordStoreCompactAdaptor* adaptor,
                        const CompactOptions* compactOptions,
                        CompactStats* stats);

    bool _normalCollection;

    friend class SimpleRecordStoreV1Iterator;
};
}