Home
last modified time | relevance | path

Searched refs:bytes (Results 1 – 25 of 49) sorted by relevance

12

/rocksdb-6.9/memory/
Darena.cc90 if (bytes > kBlockSize / 4) { in AllocateFallback()
94 return AllocateNewBlock(bytes); in AllocateFallback()
110 alloc_bytes_remaining_ = size - bytes; in AllocateFallback()
113 aligned_alloc_ptr_ = block_head + bytes; in AllocateFallback()
144 huge_blocks_.back() = MmapInfo(addr, bytes); in AllocateFromHugePage()
145 blocks_memory_ += bytes; in AllocateFromHugePage()
147 tracker_->Allocate(bytes); in AllocateFromHugePage()
151 (void)bytes; in AllocateFromHugePage()
162 if (huge_page_size > 0 && bytes > 0) { in AllocateAligned()
167 assert(reserved_size >= bytes); in AllocateAligned()
[all …]
Dconcurrent_arena.h50 char* Allocate(size_t bytes) override { in Allocate() argument
51 return AllocateImpl(bytes, false /*force_arena*/, in Allocate()
55 char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,
57 size_t rounded_up = ((bytes - 1) | (sizeof(void*) - 1)) + 1;
58 assert(rounded_up >= bytes && rounded_up < bytes + sizeof(void*) &&
137 if (bytes > shard_block_size_ / 4 || force_arena || in AllocateImpl()
159 if (avail < bytes) { in AllocateImpl()
168 if (exact >= bytes && arena_.IsInInlineBlock()) { in AllocateImpl()
191 if ((bytes % sizeof(void*)) == 0) { in AllocateImpl()
194 s->free_begin_ += bytes; in AllocateImpl()
[all …]
Darena.h45 char* Allocate(size_t bytes) override;
59 char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,
114 char* AllocateFromHugePage(size_t bytes);
115 char* AllocateFallback(size_t bytes, bool aligned);
123 inline char* Arena::Allocate(size_t bytes) { in Allocate() argument
127 assert(bytes > 0); in Allocate()
128 if (bytes <= alloc_bytes_remaining_) { in Allocate()
129 unaligned_alloc_ptr_ -= bytes; in Allocate()
130 alloc_bytes_remaining_ -= bytes; in Allocate()
133 return AllocateFallback(bytes, false /* unaligned */); in Allocate()
Dallocator.h26 virtual char* Allocate(size_t bytes) = 0;
27 virtual char* AllocateAligned(size_t bytes, size_t huge_page_size = 0,
41 void Allocate(size_t bytes);
Darena_test.cc141 size_t bytes = 0; in SimpleTest() local
167 bytes += s; in SimpleTest()
169 ASSERT_GE(arena.ApproximateMemoryUsage(), bytes); in SimpleTest()
171 ASSERT_LE(arena.ApproximateMemoryUsage(), bytes * 1.10); in SimpleTest()
/rocksdb-6.9/util/
Drate_limiter.cc19 size_t RateLimiter::RequestToken(size_t bytes, size_t alignment, in RequestToken() argument
23 bytes = std::min(bytes, static_cast<size_t>(GetSingleBurstBytes())); in RequestToken()
29 bytes = std::max(alignment, TruncateToPageBoundary(alignment, bytes)); in RequestToken()
31 Request(bytes, io_priority, stats, op_type); in RequestToken()
33 return bytes; in RequestToken()
41 int64_t bytes; member
124 if (available_bytes_ >= bytes) { in Request()
128 available_bytes_ -= bytes; in Request()
129 total_bytes_through_[pri] += bytes; in Request()
134 Req r(bytes, &request_mutex_); in Request()
[all …]
Dstring_util.cc67 int AppendHumanBytes(uint64_t bytes, char* output, int len) { in AppendHumanBytes() argument
69 if (bytes >= ull10 << 40) { in AppendHumanBytes()
70 return snprintf(output, len, "%" PRIu64 "TB", bytes >> 40); in AppendHumanBytes()
71 } else if (bytes >= ull10 << 30) { in AppendHumanBytes()
72 return snprintf(output, len, "%" PRIu64 "GB", bytes >> 30); in AppendHumanBytes()
73 } else if (bytes >= ull10 << 20) { in AppendHumanBytes()
74 return snprintf(output, len, "%" PRIu64 "MB", bytes >> 20); in AppendHumanBytes()
75 } else if (bytes >= ull10 << 10) { in AppendHumanBytes()
78 return snprintf(output, len, "%" PRIu64 "B", bytes); in AppendHumanBytes()
123 std::string BytesToHumanString(uint64_t bytes) { in BytesToHumanString() argument
[all …]
Dbloom_impl.h142 static double EstimatedFpRate(size_t keys, size_t bytes, int num_probes, in EstimatedFpRate() argument
145 BloomMath::CacheLocalFpRate(8.0 * bytes / keys, num_probes, in EstimatedFpRate()
408 static double EstimatedFpRate(size_t keys, size_t bytes, int num_probes) { in EstimatedFpRate() argument
409 double bits_per_key = 8.0 * bytes / keys; in EstimatedFpRate()
Dstring_util.h53 extern std::string BytesToHumanString(uint64_t bytes);
64 int AppendHumanBytes(uint64_t bytes, char* output, int len);
/rocksdb-6.9/tools/advisor/test/input_files/
Dtriggered_rules.ini10 suggestions=inc-max-subcompactions:inc-max-bg-compactions:inc-write-buffer-size:dec-max-bytes-for-l…
25 [Rule "stall-too-many-compaction-bytes"]
26 …ons:inc-write-buffer-size:inc-hard-pending-compaction-bytes-limit:inc-soft-pending-compaction-byte… argument
27 conditions=stall-too-many-compaction-bytes argument
29 [Condition "stall-too-many-compaction-bytes"]
31 regex=Stalling writes because of estimated pending compaction bytes \d+ argument
53 [Suggestion "dec-max-bytes-for-level-base"]
65 [Suggestion "inc-hard-pending-compaction-bytes-limit"]
69 [Suggestion "inc-soft-pending-compaction-bytes-limit"]
DLOG-111 …8351 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 3] Level-0 flush table #10: 1890434 bytes OK
16 …210 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 10] Level-0 flush table #23: 1893200 bytes OK
17 …umn_family.cc:764] [default] Stopping writes because of estimated pending compaction bytes 14410584
21 …233 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 44] Level-0 flush table #84: 1890780 bytes OK
DLOG-011 …8351 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 3] Level-0 flush table #10: 1890434 bytes OK
16 …210 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 10] Level-0 flush table #23: 1893200 bytes OK
17 …umn_family.cc:764] [default] Stalling writes because of estimated pending compaction bytes 14410584
21 …233 7f82ba72e700 [db/flush_job.cc:371] [default] [JOB 44] Level-0 flush table #84: 1890780 bytes OK
/rocksdb-6.9/tools/advisor/advisor/
Drules.ini53 [Rule "stall-too-many-compaction-bytes"]
54 …ons:inc-write-buffer-size:inc-hard-pending-compaction-bytes-limit:inc-soft-pending-compaction-byte… argument
55 conditions=stall-too-many-compaction-bytes argument
57 [Condition "stall-too-many-compaction-bytes"]
83 [Suggestion "dec-max-bytes-for-level-base"]
95 [Suggestion "inc-hard-pending-compaction-bytes-limit"]
105 suggestions=inc-base-max-bytes
112 [Suggestion "inc-base-max-bytes"]
118 suggestions=bytes-per-sync-non0:wal-bytes-per-sync-non0:set-rate-limiter
141 [Suggestion "bytes-per-sync-non0"]
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWalFilterTest.java19 import static org.rocksdb.util.ByteUtil.bytes;
36 bytes("key1"), in walFilter()
37 bytes("key2") in walFilter()
40 bytes("key3"), in walFilter()
41 bytes("key4") in walFilter()
44 bytes("key5"), in walFilter()
45 bytes("key6") in walFilter()
52 new ColumnFamilyDescriptor(bytes("pikachu")) in walFilter()
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorTest.java21 import static org.rocksdb.util.ByteUtil.bytes;
242 db.put(writeOptions, bytes(key), bytes(key)); in doRandomIterationTest()
249 db.delete(writeOptions, bytes(key)); in doRandomIterationTest()
283 iter.seek(bytes(key)); in doRandomIterationTest()
284 result_iter.seek(bytes(key)); in doRandomIterationTest()
291 iter.seekForPrev(bytes(key)); in doRandomIterationTest()
292 result_iter.seekForPrev(bytes(key)); in doRandomIterationTest()
317 final byte[] result = db.get(readOptions, bytes(key)); in doRandomIterationTest()
321 assertArrayEquals(bytes(map.get(key)), result); in doRandomIterationTest()
381 bufS1.put(bytes(s1)); in toJavaComparator()
[all …]
/rocksdb-6.9/table/block_based/
Dfilter_policy.cc80 int CalculateNumEntry(const uint32_t bytes) override { in CalculateNumEntry() argument
81 uint32_t bytes_no_meta = bytes >= 5u ? bytes - 5u : 0; in CalculateNumEntry()
95 double EstimatedFpRate(size_t keys, size_t bytes) override { in EstimatedFpRate() argument
214 int CalculateNumEntry(const uint32_t bytes) override;
222 double EstimatedFpRate(size_t keys, size_t bytes) override { in EstimatedFpRate() argument
357 assert(bytes > 0); in CalculateNumEntry()
358 int high = static_cast<int>(bytes * 8 / bits_per_key_ + 1); in CalculateNumEntry()
362 if (CalculateSpace(n) <= bytes) { in CalculateNumEntry()
498 uint32_t bytes = (bits + 7) / 8; in CreateFilter() local
499 bits = bytes * 8; in CreateFilter()
[all …]
/rocksdb-6.9/include/rocksdb/
Drate_limiter.h55 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() argument
59 Request(bytes, pri); in Request()
66 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() argument
69 Request(bytes, pri, stats); in Request()
77 virtual size_t RequestToken(size_t bytes, size_t alignment,
/rocksdb-6.9/memtable/
Dalloc_tracker.cc25 void AllocTracker::Allocate(size_t bytes) { in Allocate() argument
29 bytes_allocated_.fetch_add(bytes, std::memory_order_relaxed); in Allocate()
30 write_buffer_manager_->ReserveMem(bytes); in Allocate()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRateLimiter.java180 public void request(final long bytes) { in request() argument
182 request(nativeHandle_, bytes); in request()
223 private native void request(final long handle, final long bytes); in request() argument
/rocksdb-6.9/tools/
Ddb_bench_tool.cc3411 int64_t bytes = 0; in Crc32c() local
3416 bytes += size; in Crc32c()
3430 int64_t bytes = 0; in xxHash() local
3435 bytes += size; in xxHash()
3463 int64_t bytes = 0; in Compress() local
3508 int64_t bytes = 0; in Uncompress() local
4373 int64_t bytes = 0; in DoWrite() local
4849 int64_t bytes = 0; in ReadSequential() local
4874 int64_t bytes = 0; in ReadToRowCache() local
4943 int64_t bytes = 0; in ReadReverse() local
[all …]
/rocksdb-6.9/db/
Dlog_reader.h40 virtual void Corruption(size_t bytes, const Status& status) = 0;
155 void ReportCorruption(size_t bytes, const char* reason);
156 void ReportDrop(size_t bytes, const Status& reason);
Dlog_reader.cc269 void Reader::ReportCorruption(size_t bytes, const char* reason) { in ReportCorruption() argument
270 ReportDrop(bytes, Status::Corruption(reason)); in ReportCorruption()
273 void Reader::ReportDrop(size_t bytes, const Status& reason) { in ReportDrop() argument
275 reporter_->Corruption(bytes, reason); in ReportDrop()
/rocksdb-6.9/env/
Dmock_env.cc265 auto bytes = RequestToken(data.size() - bytes_written); in Append() local
266 Status s = file_->Append(Slice(data.data() + bytes_written, bytes)); in Append()
270 bytes_written += bytes; in Append()
287 inline size_t RequestToken(size_t bytes) { in RequestToken() argument
289 bytes = std::min( in RequestToken()
290 bytes, static_cast<size_t>(rate_limiter_->GetSingleBurstBytes())); in RequestToken()
291 rate_limiter_->Request(bytes, io_priority_); in RequestToken()
293 return bytes; in RequestToken()
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/util/
DKVUtils.java38 public static String str(final byte[] bytes) { in str() argument
39 return new String(bytes, UTF_8); in str()
/rocksdb-6.9/table/plain/
Dplain_table_key_coding.cc247 Slice bytes; in ReadVarint32NonMmap() local
248 if (!Read(offset, bytes_to_read, &bytes)) { in ReadVarint32NonMmap()
251 start = bytes.data(); in ReadVarint32NonMmap()
252 limit = bytes.data() + bytes.size(); in ReadVarint32NonMmap()

12