leveldb::RecoveryTest Class Reference

Collaboration diagram for leveldb::RecoveryTest:

Public Member Functions
	RecoveryTest ()
	~RecoveryTest ()
DBImpl *	dbfull () const
Env *	env () const
bool	CanAppend ()
void	Close ()
void	Open (Options *options=NULL)
Status	Put (const std::string &k, const std::string &v)
std::string	Get (const std::string &k, const Snapshot *snapshot=NULL)
std::string	ManifestFileName ()
std::string	LogName (uint64_t number)
size_t	DeleteLogFiles ()
uint64_t	FirstLogFile ()
std::vector< uint64_t >	GetFiles (FileType t)
int	NumLogs ()
int	NumTables ()
uint64_t	FileSize (const std::string &fname)
void	CompactMemTable ()
void	MakeLogFile (uint64_t lognum, SequenceNumber seq, Slice key, Slice val)

Private Attributes
std::string	dbname_
Env *	env_
DB *	db_

Detailed Description

Definition at line 18 of file recovery_test.cc.

Constructor & Destructor Documentation

RecoveryTest()

leveldb::RecoveryTest::RecoveryTest ( )

inline

Definition at line 20 of file recovery_test.cc.

                 : env_(Env::Default()), db_(NULL) {
    dbname_ = test::TmpDir() + "/recovery_test";
    DestroyDB(dbname_, Options());
    Open();
  }

Here is the call graph for this function:

~RecoveryTest()

leveldb::RecoveryTest::~RecoveryTest ( )

inline

Definition at line 26 of file recovery_test.cc.

                  {
    Close();
    DestroyDB(dbname_, Options());
  }

Here is the call graph for this function:

Member Function Documentation

CanAppend()

bool leveldb::RecoveryTest::CanAppend ( )

inline

Definition at line 34 of file recovery_test.cc.

                   {
    WritableFile* tmp;
    Status s = env_->NewAppendableFile(CurrentFileName(dbname_), &tmp);
    delete tmp;
    if (s.IsNotSupportedError()) {
      return false;
    } else {
      return true;
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Close()

void leveldb::RecoveryTest::Close ( )

inline

Definition at line 45 of file recovery_test.cc.

               {
    delete db_;
    db_ = NULL;
  }

Here is the caller graph for this function:

CompactMemTable()

void leveldb::RecoveryTest::CompactMemTable ( )

inline

Definition at line 135 of file recovery_test.cc.

                         {
    dbfull()->TEST_CompactMemTable();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

dbfull()

DBImpl* leveldb::RecoveryTest::dbfull ( ) const

inline

Definition at line 31 of file recovery_test.cc.

{ return reinterpret_cast<DBImpl*>(db_); }

Here is the caller graph for this function:

DeleteLogFiles()

size_t leveldb::RecoveryTest::DeleteLogFiles ( )

inline

Definition at line 95 of file recovery_test.cc.

                          {
    std::vector<uint64_t> logs = GetFiles(kLogFile);
    for (size_t i = 0; i < logs.size(); i++) {
      ASSERT_OK(env_->DeleteFile(LogName(logs[i]))) << LogName(logs[i]);
    }
    return logs.size();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

env()

Env* leveldb::RecoveryTest::env ( ) const

inline

Definition at line 32 of file recovery_test.cc.

{ return env_; }

Here is the caller graph for this function:

FileSize()

uint64_t leveldb::RecoveryTest::FileSize ( const std::string &  fname )

inline

Definition at line 129 of file recovery_test.cc.

                                            {
    uint64_t result;
    ASSERT_OK(env_->GetFileSize(fname, &result)) << fname;
    return result;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

FirstLogFile()

uint64_t leveldb::RecoveryTest::FirstLogFile ( )

inline

Definition at line 103 of file recovery_test.cc.

                          {
    return GetFiles(kLogFile)[0];
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Get()

std::string leveldb::RecoveryTest::Get ( const std::string &  k, const Snapshot *  snapshot = NULL  )

inline

Definition at line 70 of file recovery_test.cc.

                                                                     {
    std::string result;
    Status s = db_->Get(ReadOptions(), k, &result);
    if (s.IsNotFound()) {
      result = "NOT_FOUND";
    } else if (!s.ok()) {
      result = s.ToString();
    }
    return result;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

GetFiles()

std::vector<uint64_t> leveldb::RecoveryTest::GetFiles ( FileType  t )

inline

Definition at line 107 of file recovery_test.cc.

                                           {
    std::vector<std::string> filenames;
    ASSERT_OK(env_->GetChildren(dbname_, &filenames));
    std::vector<uint64_t> result;
    for (size_t i = 0; i < filenames.size(); i++) {
      uint64_t number;
      FileType type;
      if (ParseFileName(filenames[i], &number, &type) && type == t) {
        result.push_back(number);
      }
    }
    return result;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

LogName()

std::string leveldb::RecoveryTest::LogName ( uint64_t  number )

inline

Definition at line 91 of file recovery_test.cc.

                                     {
    return LogFileName(dbname_, number);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

MakeLogFile()

void leveldb::RecoveryTest::MakeLogFile ( uint64_t  lognum, SequenceNumber  seq, Slice  key, Slice  val  )

inline

Definition at line 140 of file recovery_test.cc.

                                                                              {
    std::string fname = LogFileName(dbname_, lognum);
    WritableFile* file;
    ASSERT_OK(env_->NewWritableFile(fname, &file));
    log::Writer writer(file);
    WriteBatch batch;
    batch.Put(key, val);
    WriteBatchInternal::SetSequence(&batch, seq);
    ASSERT_OK(writer.AddRecord(WriteBatchInternal::Contents(&batch)));
    ASSERT_OK(file->Flush());
    delete file;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

ManifestFileName()

std::string leveldb::RecoveryTest::ManifestFileName ( )

inline

Definition at line 81 of file recovery_test.cc.

                               {
    std::string current;
    ASSERT_OK(ReadFileToString(env_, CurrentFileName(dbname_), &current));
    size_t len = current.size();
    if (len > 0 && current[len-1] == '\n') {
      current.resize(len - 1);
    }
    return dbname_ + "/" + current;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

NumLogs()

int leveldb::RecoveryTest::NumLogs ( )

inline

Definition at line 121 of file recovery_test.cc.

                {
    return GetFiles(kLogFile).size();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

NumTables()

int leveldb::RecoveryTest::NumTables ( )

inline

Definition at line 125 of file recovery_test.cc.

                  {
    return GetFiles(kTableFile).size();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Open()

void leveldb::RecoveryTest::Open ( Options *  options = NULL )

inline

Definition at line 50 of file recovery_test.cc.

                                     {
    Close();
    Options opts;
    if (options != NULL) {
      opts = *options;
    } else {
      opts.reuse_logs = true;  // TODO(sanjay): test both ways
      opts.create_if_missing = true;
    }
    if (opts.env == NULL) {
      opts.env = env_;
    }
    ASSERT_OK(DB::Open(opts, dbname_, &db_));
    ASSERT_EQ(1, NumLogs());
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Put()

Status leveldb::RecoveryTest::Put ( const std::string &  k, const std::string &  v  )

inline

Definition at line 66 of file recovery_test.cc.

                                                     {
    return db_->Put(WriteOptions(), k, v);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

db_

DB* leveldb::RecoveryTest::db_

private

Definition at line 156 of file recovery_test.cc.

dbname_

std::string leveldb::RecoveryTest::dbname_

private

Definition at line 154 of file recovery_test.cc.

env_

Env* leveldb::RecoveryTest::env_

private

Definition at line 155 of file recovery_test.cc.

---

The documentation for this class was generated from the following file:

• db/recovery_test.cc