durop.h

Go to the documentation of this file.

// @file durop.h class DurOp and descendants

#pragma once


#include "mongo/db/storage/mmap_v1/dur_journalformat.h"
#include "mongo/db/storage/mmap_v1/paths.h"
#include "mongo/util/bufreader.h"

namespace mongo {

class AlignedBuilder;

namespace dur {

class DurOp { /* copyable */
public:
    // @param opcode a sentinel value near max unsigned which uniquely identifies the operation.
    // @see dur::JEntry
    DurOp(unsigned opcode) : _opcode(opcode) {}

    virtual ~DurOp() {}

    void serialize(AlignedBuilder& ab);

    static std::shared_ptr<DurOp> read(unsigned opcode, BufReader& br);

    virtual void replay() = 0;

    virtual std::string toString() = 0;

    virtual bool needFilesClosed() {
        return false;
    }

protected:
    virtual void _serialize(AlignedBuilder& ab) = 0;

private:
    const unsigned _opcode;
};

class FileCreatedOp : public DurOp {
public:
    FileCreatedOp(BufReader& log);
    FileCreatedOp(const std::string& f, unsigned long long l);
    virtual void replay();
    virtual std::string toString();
    virtual bool needFilesClosed();

protected:
    virtual void _serialize(AlignedBuilder& ab);

private:
    RelativePath _p;
    unsigned long long _len;  // size of file, not length of name
};

class DropDbOp : public DurOp {
public:
    DropDbOp(BufReader& log);
    DropDbOp(const std::string& db) : DurOp(JEntry::OpCode_DropDb), _db(db) {}
    virtual void replay();
    virtual std::string toString() {
        return std::string("DropDbOp ") + _db;
    }
    virtual bool needFilesClosed() {
        return true;
    }

protected:
    virtual void _serialize(AlignedBuilder& ab);

private:
    std::string _db;
};
}
}