Searched refs:kBlockSize (Results 1 – 7 of 7) sorted by relevance
| /leveldb-1.20/db/ |
| H A D | log_test.cc | 263 3 * log::kBlockSize,
381 ASSERT_EQ(kBlockSize, DroppedBytes()); in TEST()
411 ASSERT_EQ(kBlockSize, DroppedBytes()); in TEST()
472 Write(BigString("bar", kBlockSize)); in TEST()
481 Write(BigString("bar", kBlockSize)); in TEST()
495 Write(BigString("foo", 3*kBlockSize)); in TEST()
497 StartReadingAt(kBlockSize); in TEST()
512 Write(BigString("foo", kBlockSize)); in TEST()
513 Write(BigString("bar", kBlockSize)); in TEST()
517 for (int offset = kBlockSize; offset < 2*kBlockSize; offset++) { in TEST()
[all …]
|
| H A D | log_writer.cc | 29 : dest_(dest), block_offset_(dest_length % kBlockSize) { in Writer()
46 const int leftover = kBlockSize - block_offset_; in AddRecord()
59 assert(kBlockSize - block_offset_ - kHeaderSize >= 0); in AddRecord()
61 const size_t avail = kBlockSize - block_offset_ - kHeaderSize; in AddRecord()
86 assert(block_offset_ + kHeaderSize + n <= kBlockSize); in EmitPhysicalRecord()
|
| H A D | log_reader.cc | 23 backing_store_(new char[kBlockSize]), in Reader()
37 size_t offset_in_block = initial_offset_ % kBlockSize; in SkipToInitialBlock()
41 if (offset_in_block > kBlockSize - 6) { in SkipToInitialBlock()
43 block_start_location += kBlockSize; in SkipToInitialBlock()
205 Status status = file_->Read(kBlockSize, &buffer_, backing_store_); in ReadPhysicalRecord()
209 ReportDrop(kBlockSize, status); in ReadPhysicalRecord()
212 } else if (buffer_.size() < kBlockSize) { in ReadPhysicalRecord()
|
| H A D | log_format.h | 27 static const int kBlockSize = 32768; variable
|
| H A D | corruption_test.cc | 206 Corrupt(kLogFile, log::kBlockSize + 1000, 1); // Somewhere in second block in TEST()
|
| /leveldb-1.20/util/ |
| H A D | arena.cc | 10 static const int kBlockSize = 4096; variable
24 if (bytes > kBlockSize / 4) { in AllocateFallback()
32 alloc_ptr_ = AllocateNewBlock(kBlockSize); in AllocateFallback()
33 alloc_bytes_remaining_ = kBlockSize; in AllocateFallback()
|
| /leveldb-1.20/helpers/memenv/ |
| H A D | memenv.cc | 65 assert(offset / kBlockSize <= SIZE_MAX); in Read()
66 size_t block = static_cast<size_t>(offset / kBlockSize); in Read()
67 size_t block_offset = offset % kBlockSize; in Read()
69 if (n <= kBlockSize - block_offset) { in Read()
79 size_t avail = kBlockSize - block_offset; in Read()
101 size_t offset = size_ % kBlockSize; in Append()
105 avail = kBlockSize - offset; in Append()
108 blocks_.push_back(new char[kBlockSize]); in Append()
109 avail = kBlockSize; in Append()
146 enum { kBlockSize = 8 * 1024 }; enumerator
|