leveldb::DBTest Class Reference

Collaboration diagram for leveldb::DBTest:

Public Member Functions
	DBTest ()
	~DBTest ()
bool	ChangeOptions ()
Options	CurrentOptions ()
DBImpl *	dbfull ()
void	Reopen (Options *options=NULL)
void	Close ()
void	DestroyAndReopen (Options *options=NULL)
Status	TryReopen (Options *options)
Status	Put (const std::string &k, const std::string &v)
Status	Delete (const std::string &k)
std::string	Get (const std::string &k, const Snapshot *snapshot=NULL)
std::string	Contents ()
std::string	AllEntriesFor (const Slice &user_key)
int	NumTableFilesAtLevel (int level)
int	TotalTableFiles ()
std::string	FilesPerLevel ()
int	CountFiles ()
uint64_t	Size (const Slice &start, const Slice &limit)
void	Compact (const Slice &start, const Slice &limit)
void	MakeTables (int n, const std::string &small, const std::string &large)
void	FillLevels (const std::string &smallest, const std::string &largest)
void	DumpFileCounts (const char *label)
std::string	DumpSSTableList ()
std::string	IterStatus (Iterator *iter)
bool	DeleteAnSSTFile ()
int	RenameLDBToSST ()

Public Attributes
std::string	dbname_
SpecialEnv *	env_
DB *	db_
Options	last_options_

Private Types
enum	OptionConfig {   kDefault, kReuse, kFilter, kUncompressed,   kEnd }

Private Attributes
const FilterPolicy *	filter_policy_
int	option_config_

Detailed Description

Definition at line 189 of file db_test.cc.

Member Enumeration Documentation

OptionConfig

enum leveldb::DBTest::OptionConfig

private

Enumerator
kDefault
kReuse
kFilter
kUncompressed
kEnd

Definition at line 194 of file db_test.cc.

                    {
    kDefault,
    kReuse,
    kFilter,
    kUncompressed,
    kEnd
  };

Constructor & Destructor Documentation

DBTest()

leveldb::DBTest::DBTest ( )

inline

Definition at line 210 of file db_test.cc.

           : option_config_(kDefault),
             env_(new SpecialEnv(Env::Default())) {
    filter_policy_ = NewBloomFilterPolicy(10);
    dbname_ = test::TmpDir() + "/db_test";
    DestroyDB(dbname_, Options());
    db_ = NULL;
    Reopen();
  }

Here is the call graph for this function:

~DBTest()

leveldb::DBTest::~DBTest ( )

inline

Definition at line 219 of file db_test.cc.

            {
    delete db_;
    DestroyDB(dbname_, Options());
    delete env_;
    delete filter_policy_;
  }

Here is the call graph for this function:

Member Function Documentation

AllEntriesFor()

std::string leveldb::DBTest::AllEntriesFor ( const Slice &  user_key )

inline

Definition at line 341 of file db_test.cc.

                                                 {
    Iterator* iter = dbfull()->TEST_NewInternalIterator();
    InternalKey target(user_key, kMaxSequenceNumber, kTypeValue);
    iter->Seek(target.Encode());
    std::string result;
    if (!iter->status().ok()) {
      result = iter->status().ToString();
    } else {
      result = "[ ";
      bool first = true;
      while (iter->Valid()) {
        ParsedInternalKey ikey;
        if (!ParseInternalKey(iter->key(), &ikey)) {
          result += "CORRUPTED";
        } else {
          if (last_options_.comparator->Compare(ikey.user_key, user_key) != 0) {
            break;
          }
          if (!first) {
            result += ", ";
          }
          first = false;
          switch (ikey.type) {
            case kTypeValue:
              result += iter->value().ToString();
              break;
            case kTypeDeletion:
              result += "DEL";
              break;
          }
        }
        iter->Next();
      }
      if (!first) {
        result += " ";
      }
      result += "]";
    }
    delete iter;
    return result;
  }

Here is the call graph for this function:

ChangeOptions()

bool leveldb::DBTest::ChangeOptions ( )

inline

Definition at line 228 of file db_test.cc.

                       {
    option_config_++;
    if (option_config_ >= kEnd) {
      return false;
    } else {
      DestroyAndReopen();
      return true;
    }
  }

Close()

void leveldb::DBTest::Close ( )

inline

Definition at line 266 of file db_test.cc.

               {
    delete db_;
    db_ = NULL;
  }

Compact()

void leveldb::DBTest::Compact ( const Slice &  start, const Slice &  limit  )

inline

Definition at line 429 of file db_test.cc.

                                                       {
    db_->CompactRange(&start, &limit);
  }

Here is the call graph for this function:

Contents()

std::string leveldb::DBTest::Contents ( )

inline

Definition at line 316 of file db_test.cc.

                       {
    std::vector<std::string> forward;
    std::string result;
    Iterator* iter = db_->NewIterator(ReadOptions());
    for (iter->SeekToFirst(); iter->Valid(); iter->Next()) {
      std::string s = IterStatus(iter);
      result.push_back('(');
      result.append(s);
      result.push_back(')');
      forward.push_back(s);
    }

    // Check reverse iteration results are the reverse of forward results
    size_t matched = 0;
    for (iter->SeekToLast(); iter->Valid(); iter->Prev()) {
      ASSERT_LT(matched, forward.size());
      ASSERT_EQ(IterStatus(iter), forward[forward.size() - matched - 1]);
      matched++;
    }
    ASSERT_EQ(matched, forward.size());

    delete iter;
    return result;
  }

Here is the call graph for this function:

CountFiles()

int leveldb::DBTest::CountFiles ( )

inline

Definition at line 416 of file db_test.cc.

                   {
    std::vector<std::string> files;
    env_->GetChildren(dbname_, &files);
    return static_cast<int>(files.size());
  }

Here is the call graph for this function:

CurrentOptions()

Options leveldb::DBTest::CurrentOptions ( )

inline

Definition at line 239 of file db_test.cc.

                           {
    Options options;
    options.reuse_logs = false;
    switch (option_config_) {
      case kReuse:
        options.reuse_logs = true;
        break;
      case kFilter:
        options.filter_policy = filter_policy_;
        break;
      case kUncompressed:
        options.compression = kNoCompression;
        break;
      default:
        break;
    }
    return options;
  }

dbfull()

DBImpl* leveldb::DBTest::dbfull ( )

inline

Definition at line 258 of file db_test.cc.

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

Delete()

Status leveldb::DBTest::Delete ( const std::string &  k )

inline

Definition at line 297 of file db_test.cc.

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

Here is the call graph for this function:

DeleteAnSSTFile()

bool leveldb::DBTest::DeleteAnSSTFile ( )

inline

Definition at line 478 of file db_test.cc.

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

Here is the call graph for this function:

DestroyAndReopen()

void leveldb::DBTest::DestroyAndReopen ( Options *  options = NULL )

inline

Definition at line 271 of file db_test.cc.

                                                 {
    delete db_;
    db_ = NULL;
    DestroyDB(dbname_, Options());
    ASSERT_OK(TryReopen(options));
  }

Here is the call graph for this function:

DumpFileCounts()

void leveldb::DBTest::DumpFileCounts ( const char *  label )

inline

Definition at line 449 of file db_test.cc.

                                         {
    fprintf(stderr, "---\n%s:\n", label);
    fprintf(stderr, "maxoverlap: %lld\n",
            static_cast<long long>(
                dbfull()->TEST_MaxNextLevelOverlappingBytes()));
    for (int level = 0; level < config::kNumLevels; level++) {
      int num = NumTableFilesAtLevel(level);
      if (num > 0) {
        fprintf(stderr, "  level %3d : %d files\n", level, num);
      }
    }
  }

DumpSSTableList()

std::string leveldb::DBTest::DumpSSTableList ( )

inline

Definition at line 462 of file db_test.cc.

                              {
    std::string property;
    db_->GetProperty("leveldb.sstables", &property);
    return property;
  }

Here is the call graph for this function:

FilesPerLevel()

std::string leveldb::DBTest::FilesPerLevel ( )

inline

Definition at line 400 of file db_test.cc.

                            {
    std::string result;
    int last_non_zero_offset = 0;
    for (int level = 0; level < config::kNumLevels; level++) {
      int f = NumTableFilesAtLevel(level);
      char buf[100];
      snprintf(buf, sizeof(buf), "%s%d", (level ? "," : ""), f);
      result += buf;
      if (f > 0) {
        last_non_zero_offset = result.size();
      }
    }
    result.resize(last_non_zero_offset);
    return result;
  }

FillLevels()

void leveldb::DBTest::FillLevels ( const std::string &  smallest, const std::string &  largest  )

inline

Definition at line 445 of file db_test.cc.

                                                                       {
    MakeTables(config::kNumLevels, smallest, largest);
  }

Get()

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

inline

Definition at line 301 of file db_test.cc.

                                                                     {
    ReadOptions options;
    options.snapshot = snapshot;
    std::string result;
    Status s = db_->Get(options, 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:

IterStatus()

std::string leveldb::DBTest::IterStatus ( Iterator *  iter )

inline

Definition at line 468 of file db_test.cc.

                                       {
    std::string result;
    if (iter->Valid()) {
      result = iter->key().ToString() + "->" + iter->value().ToString();
    } else {
      result = "(invalid)";
    }
    return result;
  }

Here is the call graph for this function:

MakeTables()

void leveldb::DBTest::MakeTables ( int  n, const std::string &  small, const std::string &  large  )

inline

Definition at line 435 of file db_test.cc.

                                                                         {
    for (int i = 0; i < n; i++) {
      Put(small, "begin");
      Put(large, "end");
      dbfull()->TEST_CompactMemTable();
    }
  }

NumTableFilesAtLevel()

int leveldb::DBTest::NumTableFilesAtLevel ( int  level )

inline

Definition at line 383 of file db_test.cc.

                                      {
    std::string property;
    ASSERT_TRUE(
        db_->GetProperty("leveldb.num-files-at-level" + NumberToString(level),
                         &property));
    return atoi(property.c_str());
  }

Here is the call graph for this function:

Put()

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

inline

Definition at line 293 of file db_test.cc.

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

Here is the call graph for this function:

RenameLDBToSST()

int leveldb::DBTest::RenameLDBToSST ( )

inline

Definition at line 493 of file db_test.cc.

                       {
    std::vector<std::string> filenames;
    ASSERT_OK(env_->GetChildren(dbname_, &filenames));
    uint64_t number;
    FileType type;
    int files_renamed = 0;
    for (size_t i = 0; i < filenames.size(); i++) {
      if (ParseFileName(filenames[i], &number, &type) && type == kTableFile) {
        const std::string from = TableFileName(dbname_, number);
        const std::string to = SSTTableFileName(dbname_, number);
        ASSERT_OK(env_->RenameFile(from, to));
        files_renamed++;
      }
    }
    return files_renamed;
  }

Here is the call graph for this function:

Reopen()

void leveldb::DBTest::Reopen ( Options *  options = NULL )

inline

Definition at line 262 of file db_test.cc.

                                       {
    ASSERT_OK(TryReopen(options));
  }

Size()

uint64_t leveldb::DBTest::Size ( const Slice &  start, const Slice &  limit  )

inline

Definition at line 422 of file db_test.cc.

                                                        {
    Range r(start, limit);
    uint64_t size;
    db_->GetApproximateSizes(&r, 1, &size);
    return size;
  }

Here is the call graph for this function:

TotalTableFiles()

int leveldb::DBTest::TotalTableFiles ( )

inline

Definition at line 391 of file db_test.cc.

                        {
    int result = 0;
    for (int level = 0; level < config::kNumLevels; level++) {
      result += NumTableFilesAtLevel(level);
    }
    return result;
  }

TryReopen()

Status leveldb::DBTest::TryReopen ( Options *  options )

inline

Definition at line 278 of file db_test.cc.

                                     {
    delete db_;
    db_ = NULL;
    Options opts;
    if (options != NULL) {
      opts = *options;
    } else {
      opts = CurrentOptions();
      opts.create_if_missing = true;
    }
    last_options_ = opts;

    return DB::Open(opts, dbname_, &db_);
  }

Here is the call graph for this function:

Member Data Documentation

db_

DB* leveldb::DBTest::db_

Definition at line 206 of file db_test.cc.

dbname_

std::string leveldb::DBTest::dbname_

Definition at line 204 of file db_test.cc.

env_

SpecialEnv* leveldb::DBTest::env_

Definition at line 205 of file db_test.cc.

filter_policy_

const FilterPolicy* leveldb::DBTest::filter_policy_

private

Definition at line 191 of file db_test.cc.

last_options_

Options leveldb::DBTest::last_options_

Definition at line 208 of file db_test.cc.

option_config_

int leveldb::DBTest::option_config_

private

Definition at line 201 of file db_test.cc.

---

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

• db/db_test.cc