leveldb::VersionEdit Class Reference

#include <version_edit.h>

Public Member Functions
	VersionEdit ()
	~VersionEdit ()
void	Clear ()
void	SetComparatorName (const Slice &name)
void	SetLogNumber (uint64_t num)
void	SetPrevLogNumber (uint64_t num)
void	SetNextFile (uint64_t num)
void	SetLastSequence (SequenceNumber seq)
void	SetCompactPointer (int level, const InternalKey &key)
void	AddFile (int level, uint64_t file, uint64_t file_size, const InternalKey &smallest, const InternalKey &largest)
void	DeleteFile (int level, uint64_t file)
void	EncodeTo (std::string *dst) const
Status	DecodeFrom (const Slice &src)
std::string	DebugString () const

Private Types
typedef std::set< std::pair< int, uint64_t > >	DeletedFileSet

Private Attributes
std::string	comparator_
uint64_t	log_number_
uint64_t	prev_log_number_
uint64_t	next_file_number_
SequenceNumber	last_sequence_
bool	has_comparator_
bool	has_log_number_
bool	has_prev_log_number_
bool	has_next_file_number_
bool	has_last_sequence_
std::vector< std::pair< int, InternalKey > >	compact_pointers_
DeletedFileSet	deleted_files_
std::vector< std::pair< int, FileMetaData > >	new_files_

Friends
class	VersionSet

Detailed Description

Definition at line 28 of file version_edit.h.

Member Typedef Documentation

DeletedFileSet

typedef std::set< std::pair<int, uint64_t> > leveldb::VersionEdit::DeletedFileSet

private

Definition at line 87 of file version_edit.h.

Constructor & Destructor Documentation

VersionEdit()

leveldb::VersionEdit::VersionEdit ( )

inline

Definition at line 30 of file version_edit.h.

{ Clear(); }

~VersionEdit()

leveldb::VersionEdit::~VersionEdit ( )

inline

Definition at line 31 of file version_edit.h.

{ }

Member Function Documentation

AddFile()

void leveldb::VersionEdit::AddFile ( int  level, uint64_t  file, uint64_t  file_size, const InternalKey &  smallest, const InternalKey &  largest  )

inline

Definition at line 62 of file version_edit.h.

                                           {
    FileMetaData f;
    f.number = file;
    f.file_size = file_size;
    f.smallest = smallest;
    f.largest = largest;
    new_files_.push_back(std::make_pair(level, f));
  }

Here is the caller graph for this function:

Clear()

void leveldb::VersionEdit::Clear

(

)

Definition at line 26 of file version_edit.cc.

                        {
  comparator_.clear();
  log_number_ = 0;
  prev_log_number_ = 0;
  last_sequence_ = 0;
  next_file_number_ = 0;
  has_comparator_ = false;
  has_log_number_ = false;
  has_prev_log_number_ = false;
  has_next_file_number_ = false;
  has_last_sequence_ = false;
  deleted_files_.clear();
  new_files_.clear();
}

Here is the caller graph for this function:

DebugString()

std::string leveldb::VersionEdit::DebugString

(

)

const

Definition at line 212 of file version_edit.cc.

                                         {
  std::string r;
  r.append("VersionEdit {");
  if (has_comparator_) {
    r.append("\n  Comparator: ");
    r.append(comparator_);
  }
  if (has_log_number_) {
    r.append("\n  LogNumber: ");
    AppendNumberTo(&r, log_number_);
  }
  if (has_prev_log_number_) {
    r.append("\n  PrevLogNumber: ");
    AppendNumberTo(&r, prev_log_number_);
  }
  if (has_next_file_number_) {
    r.append("\n  NextFile: ");
    AppendNumberTo(&r, next_file_number_);
  }
  if (has_last_sequence_) {
    r.append("\n  LastSeq: ");
    AppendNumberTo(&r, last_sequence_);
  }
  for (size_t i = 0; i < compact_pointers_.size(); i++) {
    r.append("\n  CompactPointer: ");
    AppendNumberTo(&r, compact_pointers_[i].first);
    r.append(" ");
    r.append(compact_pointers_[i].second.DebugString());
  }
  for (DeletedFileSet::const_iterator iter = deleted_files_.begin();
       iter != deleted_files_.end();
       ++iter) {
    r.append("\n  DeleteFile: ");
    AppendNumberTo(&r, iter->first);
    r.append(" ");
    AppendNumberTo(&r, iter->second);
  }
  for (size_t i = 0; i < new_files_.size(); i++) {
    const FileMetaData& f = new_files_[i].second;
    r.append("\n  AddFile: ");
    AppendNumberTo(&r, new_files_[i].first);
    r.append(" ");
    AppendNumberTo(&r, f.number);
    r.append(" ");
    AppendNumberTo(&r, f.file_size);
    r.append(" ");
    r.append(f.smallest.DebugString());
    r.append(" .. ");
    r.append(f.largest.DebugString());
  }
  r.append("\n}\n");
  return r;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DecodeFrom()

Status leveldb::VersionEdit::DecodeFrom

(

const Slice &

src

)

Definition at line 109 of file version_edit.cc.

                                               {
  Clear();
  Slice input = src;
  const char* msg = NULL;
  uint32_t tag;

  // Temporary storage for parsing
  int level;
  uint64_t number;
  FileMetaData f;
  Slice str;
  InternalKey key;

  while (msg == NULL && GetVarint32(&input, &tag)) {
    switch (tag) {
      case kComparator:
        if (GetLengthPrefixedSlice(&input, &str)) {
          comparator_ = str.ToString();
          has_comparator_ = true;
        } else {
          msg = "comparator name";
        }
        break;

      case kLogNumber:
        if (GetVarint64(&input, &log_number_)) {
          has_log_number_ = true;
        } else {
          msg = "log number";
        }
        break;

      case kPrevLogNumber:
        if (GetVarint64(&input, &prev_log_number_)) {
          has_prev_log_number_ = true;
        } else {
          msg = "previous log number";
        }
        break;

      case kNextFileNumber:
        if (GetVarint64(&input, &next_file_number_)) {
          has_next_file_number_ = true;
        } else {
          msg = "next file number";
        }
        break;

      case kLastSequence:
        if (GetVarint64(&input, &last_sequence_)) {
          has_last_sequence_ = true;
        } else {
          msg = "last sequence number";
        }
        break;

      case kCompactPointer:
        if (GetLevel(&input, &level) &&
            GetInternalKey(&input, &key)) {
          compact_pointers_.push_back(std::make_pair(level, key));
        } else {
          msg = "compaction pointer";
        }
        break;

      case kDeletedFile:
        if (GetLevel(&input, &level) &&
            GetVarint64(&input, &number)) {
          deleted_files_.insert(std::make_pair(level, number));
        } else {
          msg = "deleted file";
        }
        break;

      case kNewFile:
        if (GetLevel(&input, &level) &&
            GetVarint64(&input, &f.number) &&
            GetVarint64(&input, &f.file_size) &&
            GetInternalKey(&input, &f.smallest) &&
            GetInternalKey(&input, &f.largest)) {
          new_files_.push_back(std::make_pair(level, f));
        } else {
          msg = "new-file entry";
        }
        break;

      default:
        msg = "unknown tag";
        break;
    }
  }

  if (msg == NULL && !input.empty()) {
    msg = "invalid tag";
  }

  Status result;
  if (msg != NULL) {
    result = Status::Corruption("VersionEdit", msg);
  }
  return result;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DeleteFile()

void leveldb::VersionEdit::DeleteFile ( int  level, uint64_t  file  )

inline

Definition at line 75 of file version_edit.h.

                                            {
    deleted_files_.insert(std::make_pair(level, file));
  }

Here is the caller graph for this function:

EncodeTo()

void leveldb::VersionEdit::EncodeTo

(

std::string *

dst

)

const

Definition at line 41 of file version_edit.cc.

                                               {
  if (has_comparator_) {
    PutVarint32(dst, kComparator);
    PutLengthPrefixedSlice(dst, comparator_);
  }
  if (has_log_number_) {
    PutVarint32(dst, kLogNumber);
    PutVarint64(dst, log_number_);
  }
  if (has_prev_log_number_) {
    PutVarint32(dst, kPrevLogNumber);
    PutVarint64(dst, prev_log_number_);
  }
  if (has_next_file_number_) {
    PutVarint32(dst, kNextFileNumber);
    PutVarint64(dst, next_file_number_);
  }
  if (has_last_sequence_) {
    PutVarint32(dst, kLastSequence);
    PutVarint64(dst, last_sequence_);
  }

  for (size_t i = 0; i < compact_pointers_.size(); i++) {
    PutVarint32(dst, kCompactPointer);
    PutVarint32(dst, compact_pointers_[i].first);  // level
    PutLengthPrefixedSlice(dst, compact_pointers_[i].second.Encode());
  }

  for (DeletedFileSet::const_iterator iter = deleted_files_.begin();
       iter != deleted_files_.end();
       ++iter) {
    PutVarint32(dst, kDeletedFile);
    PutVarint32(dst, iter->first);   // level
    PutVarint64(dst, iter->second);  // file number
  }

  for (size_t i = 0; i < new_files_.size(); i++) {
    const FileMetaData& f = new_files_[i].second;
    PutVarint32(dst, kNewFile);
    PutVarint32(dst, new_files_[i].first);  // level
    PutVarint64(dst, f.number);
    PutVarint64(dst, f.file_size);
    PutLengthPrefixedSlice(dst, f.smallest.Encode());
    PutLengthPrefixedSlice(dst, f.largest.Encode());
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

SetCompactPointer()

void leveldb::VersionEdit::SetCompactPointer ( int  level, const InternalKey &  key  )

inline

Definition at line 55 of file version_edit.h.

                                                            {
    compact_pointers_.push_back(std::make_pair(level, key));
  }

Here is the caller graph for this function:

SetComparatorName()

void leveldb::VersionEdit::SetComparatorName ( const Slice &  name )

inline

Definition at line 35 of file version_edit.h.

                                            {
    has_comparator_ = true;
    comparator_ = name.ToString();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

SetLastSequence()

void leveldb::VersionEdit::SetLastSequence ( SequenceNumber  seq )

inline

Definition at line 51 of file version_edit.h.

                                           {
    has_last_sequence_ = true;
    last_sequence_ = seq;
  }

Here is the caller graph for this function:

SetLogNumber()

void leveldb::VersionEdit::SetLogNumber ( uint64_t  num )

inline

Definition at line 39 of file version_edit.h.

                                  {
    has_log_number_ = true;
    log_number_ = num;
  }

Here is the caller graph for this function:

SetNextFile()

void leveldb::VersionEdit::SetNextFile ( uint64_t  num )

inline

Definition at line 47 of file version_edit.h.

                                 {
    has_next_file_number_ = true;
    next_file_number_ = num;
  }

Here is the caller graph for this function:

SetPrevLogNumber()

void leveldb::VersionEdit::SetPrevLogNumber ( uint64_t  num )

inline

Definition at line 43 of file version_edit.h.

                                      {
    has_prev_log_number_ = true;
    prev_log_number_ = num;
  }

Here is the caller graph for this function:

Friends And Related Function Documentation

VersionSet

friend class VersionSet

friend

Definition at line 85 of file version_edit.h.

Member Data Documentation

compact_pointers_

std::vector< std::pair<int, InternalKey> > leveldb::VersionEdit::compact_pointers_

private

Definition at line 100 of file version_edit.h.

comparator_

std::string leveldb::VersionEdit::comparator_

private

Definition at line 89 of file version_edit.h.

deleted_files_

DeletedFileSet leveldb::VersionEdit::deleted_files_

private

Definition at line 101 of file version_edit.h.

has_comparator_

bool leveldb::VersionEdit::has_comparator_

private

Definition at line 94 of file version_edit.h.

has_last_sequence_

bool leveldb::VersionEdit::has_last_sequence_

private

Definition at line 98 of file version_edit.h.

has_log_number_

bool leveldb::VersionEdit::has_log_number_

private

Definition at line 95 of file version_edit.h.

has_next_file_number_

bool leveldb::VersionEdit::has_next_file_number_

private

Definition at line 97 of file version_edit.h.

has_prev_log_number_

bool leveldb::VersionEdit::has_prev_log_number_

private

Definition at line 96 of file version_edit.h.

last_sequence_

SequenceNumber leveldb::VersionEdit::last_sequence_

private

Definition at line 93 of file version_edit.h.

log_number_

uint64_t leveldb::VersionEdit::log_number_

private

Definition at line 90 of file version_edit.h.

new_files_

std::vector< std::pair<int, FileMetaData> > leveldb::VersionEdit::new_files_

private

Definition at line 102 of file version_edit.h.

next_file_number_

uint64_t leveldb::VersionEdit::next_file_number_

private

Definition at line 92 of file version_edit.h.

prev_log_number_

uint64_t leveldb::VersionEdit::prev_log_number_

private

Definition at line 91 of file version_edit.h.

---

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

• db/version_edit.h
• db/version_edit.cc