Home
last modified time | relevance | path

Searched refs:buffer (Results 1 – 25 of 72) sorted by relevance

123

/rocksdb-6.9/table/block_based/
Dblock_based_table_factory.cc301 ret.append(buffer); in GetPrintableTableOptions()
304 ret.append(buffer); in GetPrintableTableOptions()
308 ret.append(buffer); in GetPrintableTableOptions()
312 ret.append(buffer); in GetPrintableTableOptions()
315 ret.append(buffer); in GetPrintableTableOptions()
318 ret.append(buffer); in GetPrintableTableOptions()
321 ret.append(buffer); in GetPrintableTableOptions()
324 ret.append(buffer); in GetPrintableTableOptions()
327 ret.append(buffer); in GetPrintableTableOptions()
330 ret.append(buffer); in GetPrintableTableOptions()
[all …]
Ddata_block_hash_index_test.cc91 std::string buffer("fake"), buffer2; in TEST() local
92 size_t original_size = buffer.size(); in TEST()
94 builder.Finish(buffer); in TEST()
131 size_t original_size = buffer.size(); in TEST()
133 builder.Finish(buffer); in TEST()
135 ASSERT_EQ(buffer.size(), estimated_size); in TEST()
168 size_t original_size = buffer.size(); in TEST()
170 builder.Finish(buffer); in TEST()
172 ASSERT_EQ(buffer.size(), estimated_size); in TEST()
209 size_t original_size = buffer.size(); in TEST()
[all …]
Ddata_block_hash_index.cc29 void DataBlockHashIndexBuilder::Finish(std::string& buffer) { in Finish() argument
58 buffer.append( in Finish()
64 PutFixed16(&buffer, num_buckets); in Finish()
66 assert(buffer.size() <= kMaxBlockSizeSupportedByHashIndex); in Finish()
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_tier.cc23 ret.append(buffer); in ToString()
26 ret.append(buffer); in ToString()
29 ret.append(buffer); in ToString()
31 ret.append(buffer); in ToString()
34 ret.append(buffer); in ToString()
37 ret.append(buffer); in ToString()
39 ret.append(buffer); in ToString()
43 ret.append(buffer); in ToString()
46 ret.append(buffer); in ToString()
49 ret.append(buffer); in ToString()
[all …]
/rocksdb-6.9/util/
Dbloom_test.cc148 char buffer[sizeof(int)]; in TEST_F() local
157 Add(Key(i, buffer)); in TEST_F()
189 char buffer[sizeof(int)]; in TEST_F() local
193 Add(Key(key, buffer)); in TEST_F()
200 Add(Key(key, buffer)); in TEST_F()
207 Add(Key(key, buffer)); in TEST_F()
214 Add(Key(key, buffer)); in TEST_F()
221 Add(Key(key, buffer)); in TEST_F()
228 Add(Key(key, buffer)); in TEST_F()
237 Add(Key(key, buffer)); in TEST_F()
[all …]
Dcrc32c_arm64.h20 #define PREF4X64L1(buffer, PREF_OFFSET, ITR) \ argument
21 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
23 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
25 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
27 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
30 #define PREF1KL1(buffer, PREF_OFFSET) \ argument
31 PREF4X64L1(buffer, (PREF_OFFSET), 0) \
32 PREF4X64L1(buffer, (PREF_OFFSET), 4) \
33 PREF4X64L1(buffer, (PREF_OFFSET), 8) \
34 PREF4X64L1(buffer, (PREF_OFFSET), 12)
Dcrc32c_test.cc22 char buffer[BUFFER_SIZE]; variable
107 uint32_t result = Value(buffer + expected.offset, expected.length); in TEST()
114 uint32_t partialChecksum = Value(buffer + expected.offset, partialLength); in TEST()
116 buffer + expected.offset + partialLength, in TEST()
165 const uint8_t* src = (uint8_t*)ROCKSDB_NAMESPACE::crc32c::buffer; in main()
166 uint64_t* dst = (uint64_t*)ROCKSDB_NAMESPACE::crc32c::buffer; in main()
168 (const uint64_t*)(ROCKSDB_NAMESPACE::crc32c::buffer + in main()
/rocksdb-6.9/table/plain/
Dplain_table_factory.cc56 char buffer[kBufferSize]; in GetPrintableTableOptions() local
58 snprintf(buffer, kBufferSize, " user_key_len: %u\n", in GetPrintableTableOptions()
60 ret.append(buffer); in GetPrintableTableOptions()
63 ret.append(buffer); in GetPrintableTableOptions()
66 ret.append(buffer); in GetPrintableTableOptions()
69 ret.append(buffer); in GetPrintableTableOptions()
72 ret.append(buffer); in GetPrintableTableOptions()
73 snprintf(buffer, kBufferSize, " encoding_type: %d\n", in GetPrintableTableOptions()
75 ret.append(buffer); in GetPrintableTableOptions()
78 ret.append(buffer); in GetPrintableTableOptions()
[all …]
Dplain_table_key_coding.cc171 Slice PlainTableFileReader::GetFromBuffer(Buffer* buffer, uint32_t file_offset, in GetFromBuffer() argument
174 return Slice(buffer->buf.get() + (file_offset - buffer->buf_start_offset), in GetFromBuffer()
184 Buffer* buffer = buffers_[num_buf_ - 1 - i].get(); in ReadNonMmap() local
185 if (file_offset >= buffer->buf_start_offset && in ReadNonMmap()
186 file_offset + len <= buffer->buf_start_offset + buffer->buf_len) { in ReadNonMmap()
187 *out = GetFromBuffer(buffer, file_offset, len); in ReadNonMmap()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DDirectSliceTest.java38 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length + 1); in directSliceWithByteBuffer() local
39 buffer.put(data); in directSliceWithByteBuffer()
40 buffer.put(data.length, (byte)0); in directSliceWithByteBuffer()
42 try(final DirectSlice directSlice = new DirectSlice(buffer)) { in directSliceWithByteBuffer()
50 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length); in directSliceWithByteBufferAndLength() local
51 buffer.put(data); in directSliceWithByteBufferAndLength()
52 try(final DirectSlice directSlice = new DirectSlice(buffer, 4)) { in directSliceWithByteBufferAndLength()
60 final ByteBuffer buffer = ByteBuffer.wrap(data); in directSliceInitWithoutDirectAllocation() local
61 try(final DirectSlice directSlice = new DirectSlice(buffer)) { in directSliceInitWithoutDirectAllocation()
69 final ByteBuffer buffer = ByteBuffer.wrap(data); in directSlicePrefixInitWithoutDirectAllocation() local
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_factory.cc50 char buffer[kBufferSize]; in GetPrintableTableOptions() local
52 snprintf(buffer, kBufferSize, " hash_table_ratio: %lf\n", in GetPrintableTableOptions()
54 ret.append(buffer); in GetPrintableTableOptions()
55 snprintf(buffer, kBufferSize, " max_search_depth: %u\n", in GetPrintableTableOptions()
57 ret.append(buffer); in GetPrintableTableOptions()
58 snprintf(buffer, kBufferSize, " cuckoo_block_size: %u\n", in GetPrintableTableOptions()
60 ret.append(buffer); in GetPrintableTableOptions()
61 snprintf(buffer, kBufferSize, " identity_as_first_hash: %d\n", in GetPrintableTableOptions()
63 ret.append(buffer); in GetPrintableTableOptions()
/rocksdb-6.9/table/adaptive/
Dadaptive_table_factory.cc82 char buffer[kBufferSize]; in GetPrintableTableOptions() local
85 snprintf(buffer, kBufferSize, " write factory (%s) options:\n%s\n", in GetPrintableTableOptions()
89 ret.append(buffer); in GetPrintableTableOptions()
92 snprintf(buffer, kBufferSize, " %s options:\n%s\n", in GetPrintableTableOptions()
95 ret.append(buffer); in GetPrintableTableOptions()
99 buffer, kBufferSize, " %s options:\n%s\n", in GetPrintableTableOptions()
103 ret.append(buffer); in GetPrintableTableOptions()
106 snprintf(buffer, kBufferSize, " %s options:\n%s\n", in GetPrintableTableOptions()
109 ret.append(buffer); in GetPrintableTableOptions()
/rocksdb-6.9/options/
Doptions_parser.cc335 char buffer[kBufferSize]; in ParseVersionNumber() local
339 snprintf(buffer, sizeof(buffer) - 1, in ParseVersionNumber()
345 snprintf(buffer, sizeof(buffer) - 1, in ParseVersionNumber()
358 snprintf(buffer, sizeof(buffer) - 1, in ParseVersionNumber()
366 snprintf(buffer, sizeof(buffer) - 1, in ParseVersionNumber()
753 char buffer[kBufferSize]; in VerifyDBOptions() local
762 snprintf(buffer, sizeof(buffer), in VerifyDBOptions()
768 return Status::InvalidArgument(Slice(buffer, strlen(buffer))); in VerifyDBOptions()
791 char buffer[kBufferSize]; in VerifyCFOptions() local
800 snprintf(buffer, sizeof(buffer), in VerifyCFOptions()
[all …]
/rocksdb-6.9/cache/
Dsharded_cache.cc131 char buffer[kBufferSize]; in GetPrintableOptions() local
134 snprintf(buffer, kBufferSize, " capacity : %" ROCKSDB_PRIszt "\n", in GetPrintableOptions()
136 ret.append(buffer); in GetPrintableOptions()
137 snprintf(buffer, kBufferSize, " num_shard_bits : %d\n", num_shard_bits_); in GetPrintableOptions()
138 ret.append(buffer); in GetPrintableOptions()
139 snprintf(buffer, kBufferSize, " strict_capacity_limit : %d\n", in GetPrintableOptions()
141 ret.append(buffer); in GetPrintableOptions()
143 snprintf(buffer, kBufferSize, " memory_allocator : %s\n", in GetPrintableOptions()
145 ret.append(buffer); in GetPrintableOptions()
/rocksdb-6.9/docs/_posts/
D2017-08-25-flushwal.markdown8 …ksDB automatically flushes the WAL from the application memory to the OS buffer after each `::Put`…
16 …buffer. The buffer in the next step is "flushed" to OS buffer by calling fwrite syscall. The OS bu…
20 … the WAL by setting `DBOptions::manual_wal_flush`. In that case, the WAL buffer is flushed when it…
24 …s explaiend above, by default incures the latency of flushing the WAL new appends to the OS buffer.
/rocksdb-6.9/tools/advisor/test/input_files/
Dtriggered_rules.ini2 suggestions=inc-bg-flush:inc-write-buffer
10 suggestions=inc-max-subcompactions:inc-max-bg-compactions:inc-write-buffer-size:dec-max-bytes-for-l…
18 suggestions=inc-max-bg-compactions:inc-write-buffer-size:inc-l0-stop-writes-trigger
26 suggestions=inc-max-bg-compactions:inc-write-buffer-size:inc-hard-pending-compaction-bytes-limit:in…
37 [Suggestion "inc-write-buffer"]
49 [Suggestion "inc-write-buffer-size"]
Dtest_rules.ini2 suggestions=inc-bg-flush:inc-write-buffer
6 suggestions=inc-write-buffer
42 [Suggestion "inc-write-buffer"]
/rocksdb-6.9/db/compaction/
Dcompaction.cc412 snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, " + "); in InputLevelSummary()
413 len = std::min(len, static_cast<int>(sizeof(scratch->buffer))); in InputLevelSummary()
417 len += snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, in InputLevelSummary()
420 len = std::min(len, static_cast<int>(sizeof(scratch->buffer))); in InputLevelSummary()
422 snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, in InputLevelSummary()
425 return scratch->buffer; in InputLevelSummary()
/rocksdb-6.9/file/
Dfilename.cc212 char buffer[256]; in OptionsFileName() local
213 snprintf(buffer, sizeof(buffer), "%s%06" PRIu64, in OptionsFileName()
215 return dbname + "/" + buffer; in OptionsFileName()
219 char buffer[256]; in TempOptionsFileName() local
220 snprintf(buffer, sizeof(buffer), "%s%06" PRIu64 ".%s", in TempOptionsFileName()
223 return dbname + "/" + buffer; in TempOptionsFileName()
/rocksdb-6.9/monitoring/
Dstatistics.cc361 char buffer[kTmpStrBufferSize]; in ToString() local
362 snprintf(buffer, kTmpStrBufferSize, "%s COUNT : %" PRIu64 "\n", in ToString()
364 res.append(buffer); in ToString()
368 char buffer[kTmpStrBufferSize]; in ToString() local
374 snprintf(buffer, kTmpStrBufferSize, in ToString()
383 res.append(buffer); in ToString()
/rocksdb-6.9/logging/
Dposix_logger.h92 char buffer[500]; in Logv() local
97 bufsize = sizeof(buffer); in Logv()
98 base = buffer; in Logv()
176 if (base != buffer) { in Logv()
Denv_logger.h88 char buffer[500]; in Logv() local
93 bufsize = sizeof(buffer); in Logv()
94 base = buffer; in Logv()
144 if (base != buffer) { in Logv()
/rocksdb-6.9/tools/advisor/advisor/
Drules.ini30 suggestions=inc-bg-flush:inc-write-buffer
38 suggestions=inc-max-subcompactions:inc-max-bg-compactions:inc-write-buffer-size:dec-max-bytes-for-l…
46 suggestions=inc-max-bg-compactions:inc-write-buffer-size:inc-l0-stop-writes-trigger
54 suggestions=inc-max-bg-compactions:inc-write-buffer-size:inc-hard-pending-compaction-bytes-limit:in…
66 [Suggestion "inc-write-buffer"]
79 [Suggestion "inc-write-buffer-size"]
185 suggestions=dec-max-bytes-for-level-base:inc-write-buffer-size
/rocksdb-6.9/env/
Denv_hdfs.cc90 char* buffer = scratch; in Read() local
97 bytes_read = hdfsRead(fileSys_, hfile_, buffer, remaining_bytes); in Read()
105 buffer += bytes_read; in Read()
320 char buffer[500]; in Logv() local
325 bufsize = sizeof(buffer); in Logv()
326 base = buffer; in Logv()
375 if (base != buffer) { in Logv()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DAbstractMutableOptions.java42 final StringBuilder buffer = new StringBuilder(); in toString() local
44 buffer in toString()
50 buffer.append(KEY_VALUE_PAIR_SEPARATOR); in toString()
53 return buffer.toString(); in toString()

123