leveldb::log::LogTest Class Reference

Collaboration diagram for leveldb::log::LogTest:

Classes
class	ReportCollector
class	StringDest
class	StringSource

Public Member Functions
	LogTest ()
	~LogTest ()
void	ReopenForAppend ()
void	Write (const std::string &msg)
size_t	WrittenBytes () const
std::string	Read ()
void	IncrementByte (int offset, int delta)
void	SetByte (int offset, char new_byte)
void	ShrinkSize (int bytes)
void	FixChecksum (int header_offset, int len)
void	ForceError ()
size_t	DroppedBytes () const
std::string	ReportMessage () const
std::string	MatchError (const std::string &msg) const
void	WriteInitialOffsetLog ()
void	StartReadingAt (uint64_t initial_offset)
void	CheckOffsetPastEndReturnsNoRecords (uint64_t offset_past_end)
void	CheckInitialOffsetRecord (uint64_t initial_offset, int expected_record_offset)

Private Attributes
StringDest	dest_
StringSource	source_
ReportCollector	report_
bool	reading_
Writer *	writer_
Reader *	reader_

Static Private Attributes
static size_t	initial_offset_record_sizes_ []
static uint64_t	initial_offset_last_record_offsets_ []
static int	num_initial_offset_records_

Detailed Description

Definition at line 39 of file log_test.cc.

Constructor & Destructor Documentation

LogTest()

leveldb::log::LogTest::LogTest ( )

inline

Definition at line 116 of file log_test.cc.

            : reading_(false),
              writer_(new Writer(&dest_)),
              reader_(new Reader(&source_, &report_, true/*checksum*/,
                      0/*initial_offset*/)) {
  }

~LogTest()

leveldb::log::LogTest::~LogTest ( )

inline

Definition at line 122 of file log_test.cc.

             {
    delete writer_;
    delete reader_;
  }

Member Function Documentation

CheckInitialOffsetRecord()

void leveldb::log::LogTest::CheckInitialOffsetRecord ( uint64_t  initial_offset, int  expected_record_offset  )

inline

Definition at line 220 of file log_test.cc.

                                                            {
    WriteInitialOffsetLog();
    reading_ = true;
    source_.contents_ = Slice(dest_.contents_);
    Reader* offset_reader = new Reader(&source_, &report_, true/*checksum*/,
                                       initial_offset);

    // Read all records from expected_record_offset through the last one.
    ASSERT_LT(expected_record_offset, num_initial_offset_records_);
    for (; expected_record_offset < num_initial_offset_records_;
         ++expected_record_offset) {
      Slice record;
      std::string scratch;
      ASSERT_TRUE(offset_reader->ReadRecord(&record, &scratch));
      ASSERT_EQ(initial_offset_record_sizes_[expected_record_offset],
                record.size());
      ASSERT_EQ(initial_offset_last_record_offsets_[expected_record_offset],
                offset_reader->LastRecordOffset());
      ASSERT_EQ((char)('a' + expected_record_offset), record.data()[0]);
    }
    delete offset_reader;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

CheckOffsetPastEndReturnsNoRecords()

void leveldb::log::LogTest::CheckOffsetPastEndReturnsNoRecords ( uint64_t  offset_past_end )

inline

Definition at line 208 of file log_test.cc.

                                                                    {
    WriteInitialOffsetLog();
    reading_ = true;
    source_.contents_ = Slice(dest_.contents_);
    Reader* offset_reader = new Reader(&source_, &report_, true/*checksum*/,
                                       WrittenBytes() + offset_past_end);
    Slice record;
    std::string scratch;
    ASSERT_TRUE(!offset_reader->ReadRecord(&record, &scratch));
    delete offset_reader;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

DroppedBytes()

size_t leveldb::log::LogTest::DroppedBytes ( ) const

inline

Definition at line 178 of file log_test.cc.

                              {
    return report_.dropped_bytes_;
  }

Here is the caller graph for this function:

FixChecksum()

void leveldb::log::LogTest::FixChecksum ( int  header_offset, int  len  )

inline

Definition at line 167 of file log_test.cc.

                                               {
    // Compute crc of type/len/data
    uint32_t crc = crc32c::Value(&dest_.contents_[header_offset+6], 1 + len);
    crc = crc32c::Mask(crc);
    EncodeFixed32(&dest_.contents_[header_offset], crc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

ForceError()

void leveldb::log::LogTest::ForceError ( )

inline

Definition at line 174 of file log_test.cc.

                    {
    source_.force_error_ = true;
  }

Here is the caller graph for this function:

IncrementByte()

void leveldb::log::LogTest::IncrementByte ( int  offset, int  delta  )

inline

Definition at line 155 of file log_test.cc.

                                            {
    dest_.contents_[offset] += delta;
  }

Here is the caller graph for this function:

MatchError()

std::string leveldb::log::LogTest::MatchError ( const std::string &  msg ) const

inline

Definition at line 187 of file log_test.cc.

                                                   {
    if (report_.message_.find(msg) == std::string::npos) {
      return report_.message_;
    } else {
      return "OK";
    }
  }

Here is the caller graph for this function:

Read()

std::string leveldb::log::LogTest::Read ( )

inline

Definition at line 141 of file log_test.cc.

                   {
    if (!reading_) {
      reading_ = true;
      source_.contents_ = Slice(dest_.contents_);
    }
    std::string scratch;
    Slice record;
    if (reader_->ReadRecord(&record, &scratch)) {
      return record.ToString();
    } else {
      return "EOF";
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

ReopenForAppend()

void leveldb::log::LogTest::ReopenForAppend ( )

inline

Definition at line 127 of file log_test.cc.

                         {
    delete writer_;
    writer_ = new Writer(&dest_, dest_.contents_.size());
  }

Here is the caller graph for this function:

ReportMessage()

std::string leveldb::log::LogTest::ReportMessage ( ) const

inline

Definition at line 182 of file log_test.cc.

                                  {
    return report_.message_;
  }

Here is the caller graph for this function:

SetByte()

void leveldb::log::LogTest::SetByte ( int  offset, char  new_byte  )

inline

Definition at line 159 of file log_test.cc.

                                          {
    dest_.contents_[offset] = new_byte;
  }

Here is the caller graph for this function:

ShrinkSize()

void leveldb::log::LogTest::ShrinkSize ( int  bytes )

inline

Definition at line 163 of file log_test.cc.

                             {
    dest_.contents_.resize(dest_.contents_.size() - bytes);
  }

Here is the caller graph for this function:

StartReadingAt()

void leveldb::log::LogTest::StartReadingAt ( uint64_t  initial_offset )

inline

Definition at line 203 of file log_test.cc.

                                               {
    delete reader_;
    reader_ = new Reader(&source_, &report_, true/*checksum*/, initial_offset);
  }

Here is the caller graph for this function:

Write()

void leveldb::log::LogTest::Write ( const std::string &  msg )

inline

Definition at line 132 of file log_test.cc.

                                   {
    ASSERT_TRUE(!reading_) << "Write() after starting to read";
    writer_->AddRecord(Slice(msg));
  }

Here is the call graph for this function:

Here is the caller graph for this function:

WriteInitialOffsetLog()

void leveldb::log::LogTest::WriteInitialOffsetLog ( )

inline

Definition at line 195 of file log_test.cc.

                               {
    for (int i = 0; i < num_initial_offset_records_; i++) {
      std::string record(initial_offset_record_sizes_[i],
                         static_cast<char>('a' + i));
      Write(record);
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

WrittenBytes()

size_t leveldb::log::LogTest::WrittenBytes ( ) const

inline

Definition at line 137 of file log_test.cc.

                              {
    return dest_.contents_.size();
  }

Here is the caller graph for this function:

Member Data Documentation

dest_

StringDest leveldb::log::LogTest::dest_

private

Definition at line 103 of file log_test.cc.

initial_offset_last_record_offsets_

uint64_t leveldb::log::LogTest::initial_offset_last_record_offsets_

staticprivate

Initial value:

=
    {0,
     kHeaderSize + 10000,
     2 * (kHeaderSize + 10000),
     2 * (kHeaderSize + 10000) +
         (2 * log::kBlockSize - 1000) + 3 * kHeaderSize,
     2 * (kHeaderSize + 10000) +
         (2 * log::kBlockSize - 1000) + 3 * kHeaderSize
         + kHeaderSize + 1,
     3 * log::kBlockSize,
    }

Definition at line 112 of file log_test.cc.

initial_offset_record_sizes_

size_t leveldb::log::LogTest::initial_offset_record_sizes_

staticprivate

Initial value:

=
    {10000,  
     10000,
     2 * log::kBlockSize - 1000,  
     1,
     13716,  
     log::kBlockSize - kHeaderSize, 
    }

Definition at line 111 of file log_test.cc.

num_initial_offset_records_

int leveldb::log::LogTest::num_initial_offset_records_

staticprivate

Initial value:

=
    sizeof(LogTest::initial_offset_last_record_offsets_)/sizeof(uint64_t)

Definition at line 113 of file log_test.cc.

reader_

Reader* leveldb::log::LogTest::reader_

private

Definition at line 108 of file log_test.cc.

reading_

bool leveldb::log::LogTest::reading_

private

Definition at line 106 of file log_test.cc.

report_

ReportCollector leveldb::log::LogTest::report_

private

Definition at line 105 of file log_test.cc.

source_

StringSource leveldb::log::LogTest::source_

private

Definition at line 104 of file log_test.cc.

writer_

Writer* leveldb::log::LogTest::writer_

private

Definition at line 107 of file log_test.cc.

---

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

• db/log_test.cc