| /rocksdb-6.9/include/rocksdb/ |
| D | slice.h | 80 size_ = 0; in clear()
87 size_ -= n; in remove_prefix()
92 size_ -= n; in remove_suffix()
121 return ((size_ >= x.size_) && (memcmp(data_, x.data_, x.size_) == 0)); in starts_with()
125 return ((size_ >= x.size_) && in ends_with()
126 (memcmp(data_ + size_ - x.size_, x.data_, x.size_) == 0)); in ends_with()
215 size_ = 0; in Reset()
249 const size_t min_len = (size_ < b.size_) ? size_ : b.size_; in compare()
252 if (size_ < b.size_) in compare()
254 else if (size_ > b.size_) in compare()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file_buffer.h | 24 explicit CacheWriteBuffer(const size_t size) : size_(size), pos_(0) { in CacheWriteBuffer()
25 buf_.reset(new char[size_]); in CacheWriteBuffer()
27 assert(size_); in CacheWriteBuffer()
33 assert(pos_ + size <= size_); in Append()
36 assert(pos_ <= size_); in Append()
40 assert(pos_ <= size_); in FillTrailingZeros()
41 memset(buf_.get() + pos_, '0', size_ - pos_); in FillTrailingZeros()
42 pos_ = size_; in FillTrailingZeros()
46 size_t Free() const { return size_ - pos_; } in Free()
47 size_t Capacity() const { return size_; } in Capacity()
[all …]
|
| D | volatile_tier_impl.cc | 48 size_ += size; in Insert()
51 while (size_ > max_size_) { in Insert()
55 assert(size_ >= size); in Insert()
56 size_ -= size; in Insert()
61 assert(size_ >= size); in Insert()
71 assert(size_ >= size); in Insert()
72 size_ -= size; in Insert()
130 size_ -= edata->value.size(); in Evict()
|
| D | block_cache_tier.cc | 29 assert(!size_); in Open()
290 std::unique_ptr<char[]> scratch(new char[lba.size_]); in Lookup()
358 assert(size_ <= opt_.cache_size); in Reserve()
360 if (size + size_ <= opt_.cache_size) { in Reserve()
362 size_ += size; in Reserve()
366 assert(size + size_ >= opt_.cache_size); in Reserve()
371 while (size + size_ > opt_.cache_size * retain_fac) { in Reserve()
384 assert(file_size <= size_); in Reserve()
385 size_ -= file_size; in Reserve()
388 size_ += size; in Reserve()
[all …]
|
| D | persistent_cache_util.h | 32 size_ + t.Size() >= max_size_) { in Push()
37 size_ += t.Size(); in Push()
49 size_ -= t.Size(); in Pop()
56 return size_; in Size()
63 size_t size_ = 0; variable
|
| D | block_cache_tier_file.cc | 238 Status s = freader_->Read(lba.off_, lba.size_, &result, scratch, nullptr); in Read()
252 Slice data(scratch, lba.size_); in ParseRec()
336 lba->size_ = rec_size; in Append()
379 size_ += static_cast<uint32_t>(buf->Free()); in ExpandBuffer()
473 size_t pending_nbytes = lba.size_; in ReadBuffer()
502 assert(tmp == data + lba.size_); in ReadBuffer()
509 assert(size_ >= max_size_); in Close()
515 Info(log_, "Closing file %s. size=%d written=%d", Path().c_str(), size_, in Close()
|
| D | block_cache_tier_file.h | 61 : cache_id_(cache_id), off_(off), size_(size) {} in LogicalBlockAddress()
65 uint32_t size_ = 0; member
242 uint32_t size_ = 0; // Size of the file variable
|
| D | volatile_tier_impl.h | 136 std::atomic<uint64_t> size_{0}; // Size of the cache
|
| D | block_cache_tier.h | 150 std::atomic<uint64_t> size_{0}; // Size of the cache
|
| /rocksdb-6.9/table/block_based/ |
| D | block.cc | 828 assert(size_ >= 2 * sizeof(uint32_t)); in NumRestarts()
850 assert(size_ >= 2 * sizeof(uint32_t)); in IndexType()
872 size_(contents_.data.size()), in Block()
876 if (size_ < sizeof(uint32_t)) { in Block()
877 size_ = 0; // Error marker in Block()
888 size_ = 0; in Block()
894 size_ = 0; in Block()
911 size_ = 0; in Block()
916 size_ = 0; // Error marker in Block()
936 if (size_ < 2 * sizeof(uint32_t)) { in NewDataIterator()
[all …]
|
| D | block.h | 162 size_t size() const { return size_; } in size()
224 size_t size_; // contents_.data.size() variable
|
| /rocksdb-6.9/util/ |
| D | file_reader_writer_test.cc | 30 size_ += data.size(); in TEST_F()
35 EXPECT_GE(size_, last_synced_ + kMb); in TEST_F()
36 EXPECT_LT(size_, last_synced_ + 2 * kMb); in TEST_F()
38 EXPECT_GT(size_, 10 * kMb); in TEST_F()
65 EXPECT_GE(size_, last_synced_ + kMb); in TEST_F()
66 if (size_ > 2 * kMb) { in TEST_F()
67 EXPECT_LT(size_, last_synced_ + 2 * kMb); in TEST_F()
72 uint64_t size_; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::FakeWF
109 size_ += data.size(); in TEST_F()
117 size_ += data.size(); in TEST_F()
[all …]
|
| D | slice.cc | 153 size_ = buf->size(); in Slice()
160 result.reserve(2 * size_); in ToString()
161 for (size_t i = 0; i < size_; ++i) { in ToString()
168 result.assign(data_, size_); in ToString()
175 std::string::size_type len = size_; in DecodeHex()
220 size_ = other.size_; in operator =()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | BackupInfo.java | 26 size_ = size; in BackupInfo()
52 return size_; in size()
73 private long size_; field in BackupInfo
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 30 size_(0), in MemFile()
79 uint64_t Size() const { return size_; } in Size()
83 if (size < size_) { in Truncate()
85 size_ = size; in Truncate()
90 if (fsynced_bytes_ >= size_) { in CorruptBuffer()
93 uint64_t buffered_bytes = size_ - fsynced_bytes_; in CorruptBuffer()
96 uint64_t end = std::min(start + 512, size_.load()); in CorruptBuffer()
130 size_ = data_.size(); in Write()
138 size_ = data_.size(); in Append()
144 fsynced_bytes_ = size_.load(); in Fsync()
[all …]
|
| /rocksdb-6.9/table/ |
| D | format.h | 49 uint64_t size() const { return size_; } in size()
50 void set_size(uint64_t _size) { size_ = _size; } in set_size()
61 bool IsNull() const { return offset_ == 0 && size_ == 0; } in IsNull()
70 uint64_t size_; variable
342 : offset_(_offset), size_(_size) {} in BlockHandle()
|
| D | format.cc | 53 assert(size_ != ~static_cast<uint64_t>(0)); in EncodeTo()
54 PutVarint64Varint64(dst, offset_, size_); in EncodeTo()
58 if (GetVarint64(input, &offset_) && GetVarint64(input, &size_)) { in DecodeFrom()
63 size_ = 0; in DecodeFrom()
69 if (GetVarint64(input, &size_)) { in DecodeSizeFrom()
75 size_ = 0; in DecodeSizeFrom()
|
| /rocksdb-6.9/db/blob/ |
| D | blob_index.h | 83 return size_; in size()
105 GetVarint64(&slice, &size_) && slice.size() == 1) { in DecodeFrom()
121 << " size:" << size_; in DebugString()
174 uint64_t size_ = 0; variable
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 163 size_(0), in BackupMeta()
181 return size_; in GetSize()
226 AppendHumanBytes(size_, human_size, sizeof(human_size)); in GetInfoString()
242 uint64_t size_; member in ROCKSDB_NAMESPACE::BackupEngineImpl::BackupMeta
1730 size_ += file_info->size; in AddFile()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.h | 141 trimmed_value.size_ -= DBWithTTLImpl::kTSLength; in value()
|
| /rocksdb-6.9/db/ |
| D | db_test2.cc | 1786 if (size_ > max_size_) { in Insert()
1787 size_ -= data_.begin()->second.size(); in Insert()
1792 size_ += size; in Insert()
1820 size_t size_ = 0; member in ROCKSDB_NAMESPACE::MockPersistentCache
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 1513 size_(size) {} in FixedDistribution()
1516 return size_; in Get()
1521 unsigned int size_; member in ROCKSDB_NAMESPACE::FixedDistribution
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest.h | 9033 (this->*rhs.clone_)(rhs.array_, rhs.size_);
9042 size_t size() const { return size_; }
9044 const_iterator end() const { return array_ + size_; }
9061 size_ = a_size;
9068 size_ = a_size;
9073 size_t size_;
|