| /rocksdb-6.9/include/rocksdb/ |
| D | c.h | 254 size_t keylen, const char* val, size_t vallen, char** errptr);
259 size_t keylen, const char* val, size_t vallen, char** errptr);
273 size_t start_key_len, const char* end_key, size_t end_key_len,
278 size_t keylen, const char* val, size_t vallen, char** errptr);
283 size_t keylen, const char* val, size_t vallen, char** errptr);
293 size_t keylen, size_t* vallen, char** errptr);
298 size_t keylen, size_t* vallen, char** errptr);
468 const char* key, size_t klen, const char* val, size_t vlen);
485 const char* key, size_t klen, const char* val, size_t vlen);
556 const char* key, size_t klen, const char* val, size_t vlen);
[all …]
|
| D | file_system.h | 569 virtual IOStatus InvalidateCache(size_t /*offset*/, size_t /*length*/) { in InvalidateCache() argument
592 size_t len;
667 virtual size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const { in GetUniqueId() argument
818 virtual size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const { in GetUniqueId() argument
970 virtual size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const { in GetUniqueId() argument
1215 IOStatus InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
1246 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
1254 IOStatus InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
1320 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
1324 IOStatus InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
[all …]
|
| D | env.h | 622 size_t len;
691 virtual size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const { in GetUniqueId() argument
836 virtual size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const { in GetUniqueId() argument
866 virtual void PrepareWrite(size_t offset, size_t len) { in PrepareWrite()
1417 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
1444 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
1452 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
1506 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
1510 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
1518 void PrepareWrite(size_t offset, size_t len) override { in PrepareWrite()
[all …]
|
| /rocksdb-6.9/util/ |
| D | aligned_buffer.h | 23 inline size_t TruncateToPageBoundary(size_t page_size, size_t s) { in TruncateToPageBoundary()
33 inline size_t Roundup(size_t x, size_t y) { in Roundup()
41 inline size_t Rounddown(size_t x, size_t y) { return (x / y) * y; } in Rounddown()
58 size_t alignment_;
60 size_t capacity_;
61 size_t cursize_;
93 static bool isAligned(size_t n, size_t alignment) { in isAligned()
186 size_t Append(const char* src, size_t append_size) { in Append()
203 size_t Read(char* dest, size_t offset, size_t read_size) const { in Read()
206 size_t to_read = 0; in Read()
[all …]
|
| D | autovector_test.cc | 38 autovector<size_t, kSize> vec; in TEST_F()
55 size_t size = vec.size(); in TEST_F()
90 autovector<size_t, kSize> vec; in TEST_F()
113 const autovector<size_t, kSize>& a, const autovector<size_t, kSize>& b) { in AssertEqual() argument
128 autovector<size_t, kSize> vec; in TEST_F()
158 size_t index = 0; in TEST_F()
199 size_t diff = static_cast<size_t>(pos - vec.begin()); in TEST_F()
219 std::string name, size_t ops, size_t item_size, in BenchmarkVectorCreationAndInsertion()
239 size_t BenchmarkSequenceAccess(std::string name, size_t ops, size_t elem_size) { in BenchmarkSequenceAccess()
248 size_t total = 0; in BenchmarkSequenceAccess()
[all …]
|
| D | file_reader_writer_test.cc | 48 size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const override { in TEST_F()
51 Status InvalidateCache(size_t /*offset*/, size_t /*length*/) override { in TEST_F() argument
133 size_t GetUniqueId(char* /*id*/, size_t /*max_size*/) const override { in TEST_F()
136 Status InvalidateCache(size_t /*offset*/, size_t /*length*/) override { in TEST_F() argument
144 size_t size_ = 0; in TEST_F()
263 size_t readahead_size_;
312 size_t n = in TEST_P()
344 std::string Read(size_t n) { in Read()
359 size_t readahead_size_;
389 size_t offset = 0; in TEST_P()
[all …]
|
| /rocksdb-6.9/memory/ |
| D | arena.h | 35 static const size_t kMinBlockSize;
36 static const size_t kMaxBlockSize;
45 char* Allocate(size_t bytes) override;
59 char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,
87 const size_t kBlockSize;
94 size_t length_;
99 size_t irregular_block_num = 0;
109 size_t alloc_bytes_remaining_ = 0;
112 size_t hugetlb_size_ = 0;
119 size_t blocks_memory_ = 0;
[all …]
|
| D | concurrent_arena.h | 50 char* Allocate(size_t bytes) override { in Allocate()
55 char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,
66 size_t ApproximateMemoryUsage() const { in ApproximateMemoryUsage()
72 size_t MemoryAllocatedBytes() const { in MemoryAllocatedBytes()
76 size_t AllocatedAndUnused() const { in AllocatedAndUnused()
81 size_t IrregularBlockNum() const { in IrregularBlockNum()
98 static __thread size_t tls_cpuid;
105 size_t shard_block_size_;
119 size_t ShardAllocatedAndUnused() const { in ShardAllocatedAndUnused()
120 size_t total = 0; in ShardAllocatedAndUnused()
[all …]
|
| D | arena.cc | 25 const size_t Arena::kInlineSize;
28 const size_t Arena::kMinBlockSize = 4096;
32 size_t OptimizeBlockSize(size_t block_size) { in OptimizeBlockSize()
45 Arena::Arena(size_t block_size, AllocTracker* tracker, size_t huge_page_size) in Arena()
98 size_t size = 0; in AllocateFallback()
156 char* Arena::AllocateAligned(size_t bytes, size_t huge_page_size, in AllocateAligned()
165 size_t reserved_size = in AllocateAligned()
184 size_t current_mod = in AllocateAligned()
187 size_t needed = bytes + slop; in AllocateAligned()
213 size_t allocated_size; in AllocateNewBlock()
[all …]
|
| D | arena_test.cc | 17 const size_t kHugePageSize = 2 * 1024 * 1024;
24 bool CheckMemoryAllocated(size_t allocated, size_t expected) { in CheckMemoryAllocated()
34 size_t req_sz; // requested size in MemoryAllocatedBytesTest()
35 size_t bsz = 32 * 1024; // block size in MemoryAllocatedBytesTest()
36 size_t expected_memory_allocated; in MemoryAllocatedBytesTest()
87 const size_t kBlockSize = 4096; in ApproximateMemoryUsageTest()
88 const size_t kEntrySize = kBlockSize / 8; in ApproximateMemoryUsageTest()
89 const size_t kZero = 0; in ApproximateMemoryUsageTest()
141 size_t bytes = 0; in SimpleTest()
144 size_t s; in SimpleTest()
[all …]
|
| /rocksdb-6.9/port/win/ |
| D | io_win.h | 58 size_t GetUniqueIdFromFile(HANDLE hFile, char* id, size_t max_size);
119 virtual Status InvalidateCache(size_t offset, size_t length) override;
144 virtual Status InvalidateCache(size_t offset, size_t length) override;
146 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
160 const size_t
224 virtual Status InvalidateCache(size_t offset, size_t length) override;
228 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
271 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
275 virtual Status InvalidateCache(size_t offset, size_t length) override;
377 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
[all …]
|
| D | io_win.cc | 232 size_t WinMmapReadableFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId()
278 size_t minDiskSize = static_cast<size_t>(file_offset_) + view_size_; in MapNewRegion()
412 size_t bytesToPad = Roundup(size_t(dst_), page_size_) - size_t(dst_); in Append()
531 Status WinMmapFile::InvalidateCache(size_t offset, size_t length) { in InvalidateCache()
556 size_t WinMmapFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId()
573 size_t r = 0; in Read()
660 size_t numBytes, in PositionedReadInternal()
668 size_t alignment, in WinRandomAccessImpl()
907 …size_t spaceToReserve = Roundup(static_cast<size_t>(offset + len), static_cast<size_t>(alignment_)… in AllocateImpl()
984 size_t WinWritableFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId()
[all …]
|
| /rocksdb-6.9/env/ |
| D | io_posix.h | 46 static size_t GetUniqueIdFromFile(int fd, char* id, size_t max_size);
111 size_t size;
145 virtual IOStatus InvalidateCache(size_t offset, size_t length) override;
205 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
208 virtual IOStatus InvalidateCache(size_t offset, size_t length) override;
256 virtual IOStatus InvalidateCache(size_t offset, size_t length) override;
269 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
279 size_t length_;
295 size_t page_size_;
308 static size_t Roundup(size_t x, size_t y) { return ((x + y - 1) / y) * y; } in Roundup()
[all …]
|
| D | io_posix.cc | 102 size_t left = nbyte; in PosixWrite()
124 size_t left = nbyte; in PosixPositionedWrite()
195 bool IsSectorAligned(const size_t off, size_t sector_size) { in IsSectorAligned()
235 size_t r = 0; in Read()
266 size_t left = n; in PositionedRead()
519 size_t size = 0; in GetLogicalBlockSizeOfFd()
523 size_t len = 0; in GetLogicalBlockSizeOfFd()
577 size_t left = n; in Read()
695 size_t bytes_read = static_cast<size_t>(cqe->res); in MultiRead()
1195 size_t block_size; in Close()
[all …]
|
| D | env_encryption.cc | 29 size_t prefixLength_;
86 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
111 size_t prefixLength_;
160 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
179 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
191 size_t prefixLength_;
277 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
296 void PrepareWrite(size_t offset, size_t len) override { in PrepareWrite()
311 size_t prefixLength_;
792 for (size_t i = 0; i < blockSize_; ++i) { in Encrypt()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | hash_table_bench.cc | 59 const size_t sec = 10, in HashTableBenchmark()
101 size_t k = insert_key_++; in RunWrite()
113 size_t k = rgen.Next() % max_prepop_key; in RunRead()
123 size_t k = erase_key_++; in RunErase()
134 for (size_t i = 0; i < n; ++i) { in StartThreads()
141 for (size_t i = 0; i < max_prepop_key; ++i) { in Prepop()
148 for (size_t i = 0; i < 10 * max_prepop_key; ++i) { in Prepop()
198 bool Erase(const size_t& key) override { in Erase()
219 std::unordered_map<size_t, string> map_;
233 bool Erase(const size_t& key) override { in Erase()
[all …]
|
| D | persistent_cache_test.h | 72 void Insert(const size_t nthreads, const size_t max_keys) { in Insert()
98 std::string PaddedNumber(const size_t data, const size_t pad_size) { in PaddedNumber()
102 size_t count = 0; in PaddedNumber()
103 size_t t = data; in PaddedNumber()
127 size_t i = key_++; in InsertImpl()
151 size_t i = key_++;
161 size_t block_size;
179 void RunInsertTest(const size_t nthreads, const size_t max_keys) { in RunInsertTest()
190 void RunNegativeInsertTest(const size_t nthreads, const size_t max_keys) { in RunNegativeInsertTest()
216 size_t max_keys_ = 0;
[all …]
|
| /rocksdb-6.9/port/ |
| D | jemalloc_helper.h | 43 extern "C" void* mallocx(size_t, int) __attribute__((__weak__));
44 extern "C" void* rallocx(void*, size_t, int) __attribute__((__weak__));
45 extern "C" size_t xallocx(void*, size_t, size_t, int) __attribute__((__weak__));
46 extern "C" size_t sallocx(const void*, int) __attribute__((__weak__));
48 extern "C" void sdallocx(void*, size_t, int) __attribute__((__weak__));
49 extern "C" size_t nallocx(size_t, int) __attribute__((__weak__));
50 extern "C" int mallctl(const char*, void*, size_t*, void*, size_t)
52 extern "C" int mallctlnametomib(const char*, size_t*, size_t*)
54 extern "C" int mallctlbymib(const size_t*, size_t, void*, size_t*, void*,
55 size_t) __attribute__((__weak__));
[all …]
|
| /rocksdb-6.9/db/ |
| D | c.cc | 306 size_t len; in CreateFilter()
440 size_t len; in Transform()
765 size_t* lencfs, in rocksdb_list_column_families()
896 size_t* vallen, in rocksdb_get()
918 size_t* vallen, in rocksdb_get_cf()
1069 size_t size, in rocksdb_create_iterators()
1859 size_t* vallen, in rocksdb_writebatch_wi_get_from_batch()
3689 size_t* size) { in rocksdb_livefiles_smallestkey()
3697 size_t* size) { in rocksdb_livefiles_largestkey()
4036 size_t* vlen, in rocksdb_transactiondb_get()
[all …]
|
| D | db_block_cache_test.cc | 19 size_t miss_count_ = 0;
20 size_t hit_count_ = 0;
21 size_t insert_count_ = 0;
22 size_t failure_count_ = 0;
32 const size_t kNumBlocks = 10;
33 const size_t kValueSize = 100;
86 size_t expected_hits, size_t expected_inserts, in CheckCacheCounters()
91 size_t new_failure_count = in CheckCacheCounters()
130 size_t new_miss_count = in CheckCompressedCacheCounters()
132 size_t new_hit_count = in CheckCompressedCacheCounters()
[all …]
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.cc | 39 size_t aligned_offset = in Read()
41 size_t offset_advance = static_cast<size_t>(offset) - aligned_offset; in Read()
42 size_t read_size = in Read()
48 size_t allowed; in Read()
81 size_t res_len = 0; in Read()
94 size_t pos = 0; in Read()
97 size_t allowed; in Read()
177 size_t dest_offset = static_cast<size_t>(dest->offset); in TryMerge()
178 size_t src_offset = static_cast<size_t>(src.offset); in TryMerge()
222 size_t total_len = 0; in MultiRead()
[all …]
|
| D | readahead_raf.cc | 23 size_t readahead_size) in ReadaheadRandomAccessFile()
38 Status Read(uint64_t offset, size_t n, Slice* result, in Read()
47 size_t cached_len = 0; in Read()
58 size_t advanced_offset = static_cast<size_t>(offset + cached_len); in Read()
66 size_t remaining_len; in Read()
83 size_t offset_ = static_cast<size_t>(offset); in Prefetch()
92 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId()
98 Status InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
111 bool TryReadFromCache(uint64_t offset, size_t n, size_t* cached_len, in TryReadFromCache()
145 const size_t alignment_;
[all …]
|
| D | sequence_file_reader.cc | 29 size_t offset = offset_.fetch_add(n); in Read()
32 size_t offset_advance = offset - aligned_offset; in Read()
34 size_t r = 0; in Read()
58 offset_ += static_cast<size_t>(n); in Skip()
73 size_t readahead_size) in ReadaheadSequentialFile()
92 size_t cached_len = 0; in Read()
120 size_t remaining_len; in Read()
160 IOStatus InvalidateCache(size_t offset, size_t length) override { in InvalidateCache()
173 bool TryReadFromCache(size_t n, size_t* cached_len, char* scratch) { in TryReadFromCache()
207 const size_t alignment_;
[all …]
|
| /rocksdb-6.9/cache/ |
| D | clock_cache.cc | 183 size_t charge;
210 Slice key, size_t charge, in CalcTotalCharge()
212 size_t meta_charge = 0; in CalcTotalCharge()
225 inline size_t CalcTotalCharge( in CalcTotalCharge()
285 size_t GetUsage() const override;
362 size_t head_;
368 std::atomic<size_t> capacity_;
371 std::atomic<size_t> usage_;
374 std::atomic<size_t> pinned_usage_;
529 size_t new_head = head_; in EvictFromCache()
[all …]
|
| /rocksdb-6.9/logging/ |
| D | auto_roll_logger_test.cc | 213 size_t time = 2; in TEST_F()
214 size_t log_size = 1024 * 5; in TEST_F()
254 size_t kZero = 0; in TEST_F()
255 size_t log_size = 1024; in TEST_F()
405 size_t log_num = 8; in TEST_F()
414 size_t log_num = 5; in TEST_F()
425 size_t log_num = 7; in TEST_F()
484 size_t log_size = 8192; in TEST_F()
485 size_t log_lines = 0; in TEST_F()
525 size_t log_size = 8192; in TEST_F()
[all …]
|