| /rocksdb-6.9/db/ |
| D | db_iter_stress_test.cc | 68 Data* data; member
123 data->hidden.size() > data->entries.size() * target_hidden_fraction in MaybeMutate()
158 data->hidden[hi] = data->hidden.back(); in MaybeMutate()
166 while (iter < (int)data->entries.size() && !data->entries[iter].visible) { in SkipForward()
200 data->entries.begin(), data->entries.end(), in Seek()
212 data->entries.begin(), data->entries.end(), in SeekForPrev()
251 Data* data; member
271 auto it = std::partition_point(data->entries.begin(), data->entries.end(), in FindNextKey()
300 auto it = std::partition_point(data->entries.begin(), data->entries.end(), in FindValueForCurrentKey()
456 Data data; in TEST_F() local
[all …]
|
| D | db_encryption_test.cc | 54 Slice data; in TEST_F() local
55 status = seqFile->Read(fileSize, &data, (char*)scratch.data()); in TEST_F()
58 if (data.ToString().find("foo567") != std::string::npos) { in TEST_F()
62 if (data.ToString().find("v1.fetdq") != std::string::npos) { in TEST_F()
66 if (data.ToString().find("bar123") != std::string::npos) { in TEST_F()
70 if (data.ToString().find("v2.dfgkjdfghsd") != std::string::npos) { in TEST_F()
74 if (data.ToString().find("dfgk") != std::string::npos) { in TEST_F()
105 Slice data; in TEST_F() local
108 status = seqFile->Read(16, &data, (char*)scratch.data()); in TEST_F()
111 ASSERT_TRUE(data.empty()); in TEST_F()
|
| D | db_merge_operand_test.cc | 63 values.data(), &merge_operands_info, in TEST_F()
71 values.data(), &merge_operands_info, in TEST_F()
82 values.data(), &merge_operands_info, in TEST_F()
105 values.data(), &merge_operands_info, in TEST_F()
118 values.data(), &merge_operands_info, in TEST_F()
132 values.data(), &merge_operands_info, in TEST_F()
143 values.data(), &merge_operands_info, in TEST_F()
161 values.data(), &merge_operands_info, in TEST_F()
177 values.data(), &merge_operands_info, in TEST_F()
192 values.data(), &merge_operands_info, in TEST_F()
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_updater.cc | 47 auto* data = Get(); in SetColumnFamilyInfoKey() local
48 if (data == nullptr) { in SetColumnFamilyInfoKey()
60 if (data == nullptr) { in GetColumnFamilyInfoKey()
69 if (data == nullptr) { in SetThreadOperation()
87 if (data == nullptr) { in SetThreadOperationProperty()
96 if (data == nullptr) { in IncreaseThreadOperationProperty()
104 if (data == nullptr) { in SetOperationStartTime()
112 if (data == nullptr) { in ClearThreadOperation()
124 if (data == nullptr) { in ClearThreadOperationProperties()
135 if (data == nullptr) { in SetThreadOperationStage()
[all …]
|
| D | histogram_test.cc | 34 HistogramData data; in BasicOperation() local
35 histogram.Data(&data); in BasicOperation()
38 ASSERT_LE(fabs(data.percentile99 - 108.9), kIota); // 99 * 110 / 100 in BasicOperation()
39 ASSERT_LE(fabs(data.percentile95 - 104.5), kIota); // 95 * 110 / 100 in BasicOperation()
40 ASSERT_LE(fabs(data.median - 55.0), kIota); // 50 * 110 / 100 in BasicOperation()
41 ASSERT_EQ(data.average, 55.5); // (1 + 110) / 2 in BasicOperation()
49 HistogramData data; in MergeHistogram() local
50 histogram.Data(&data); in MergeHistogram()
53 ASSERT_LE(fabs(data.percentile99 - 247.5), kIota); // 99 * 250 / 100 in MergeHistogram()
55 ASSERT_LE(fabs(data.median - 125.0), kIota); // 50 * 250 / 100 in MergeHistogram()
[all …]
|
| /rocksdb-6.9/util/ |
| D | murmurhash.cc | 39 const uint64_t * end = data + (len/8); in MurmurHash64A()
41 while(data != end) in MurmurHash64A()
43 uint64_t k = *data++; in MurmurHash64A()
116 data += 4; in MurmurHash2()
126 case 1: h ^= data[0]; in MurmurHash2()
160 k = data[0]; in MurmurHashNeutral2()
161 k |= data[1] << 8; in MurmurHashNeutral2()
162 k |= data[2] << 16; in MurmurHashNeutral2()
163 k |= data[3] << 24; in MurmurHashNeutral2()
172 data += 4; in MurmurHashNeutral2()
[all …]
|
| D | hash.cc | 18 uint32_t Hash(const char* data, size_t n, uint32_t seed) { in Hash() argument
24 const char* limit = data + n; in Hash()
28 while (data + 4 <= limit) { in Hash()
29 uint32_t w = DecodeFixed32(data); in Hash()
30 data += 4; in Hash()
37 switch (limit - data) { in Hash()
52 h += static_cast<uint32_t>(static_cast<int8_t>(data[0])); in Hash()
74 uint64_t Hash64(const char* data, size_t n, uint64_t seed) { in Hash64() argument
75 return XXH3p_64bits_withSeed(data, n, seed); in Hash64()
78 uint64_t Hash64(const char* data, size_t n) { in Hash64() argument
[all …]
|
| D | crc32c_ppc.c | 29 static uint32_t crc32_vpmsum(uint32_t crc, unsigned char const *data, in crc32_vpmsum() argument
39 crc = crc32_align(crc, data, (unsigned long)len); in crc32_vpmsum()
43 if ((unsigned long)data & VMX_ALIGN_MASK) { in crc32_vpmsum()
44 prealign = VMX_ALIGN - ((unsigned long)data & VMX_ALIGN_MASK); in crc32_vpmsum()
45 crc = crc32_align(crc, data, prealign); in crc32_vpmsum()
47 data += prealign; in crc32_vpmsum()
50 crc = __crc32_vpmsum(crc, data, (unsigned long)len & ~VMX_ALIGN_MASK); in crc32_vpmsum()
54 data += len & ~VMX_ALIGN_MASK; in crc32_vpmsum()
55 crc = crc32_align(crc, data, tail); in crc32_vpmsum()
73 if (!data) { in crc32c_ppc()
[all …]
|
| D | coding_test.cc | 23 const char* p = s.data(); in TEST()
37 const char* p = s.data(); in TEST()
54 const char* p = s.data(); in TEST()
102 const char* p = s.data(); in TEST()
137 const char* p = s.data(); in TEST()
155 ASSERT_TRUE(GetVarint32Ptr(input.data(), input.data() + input.size(), &result) in TEST()
165 ASSERT_TRUE(GetVarint32Ptr(s.data(), s.data() + len, &result) == nullptr); in TEST()
168 GetVarint32Ptr(s.data(), s.data() + s.size(), &result) != nullptr); in TEST()
175 ASSERT_TRUE(GetVarint64Ptr(input.data(), input.data() + input.size(), &result) in TEST()
185 ASSERT_TRUE(GetVarint64Ptr(s.data(), s.data() + len, &result) == nullptr); in TEST()
[all …]
|
| D | bloom_impl.h | 195 int num_probes, char *data) { in AddHash() argument
197 AddHashPrepared(h2, num_probes, data + bytes_to_cache_line); in AddHash()
211 const char *data, in PrepareHash() argument
220 int num_probes, const char *data) { in HashMayMatch() argument
359 char *data) { in AddHash() argument
363 data[bitpos / 8] |= (1 << (bitpos % 8)); in AddHash()
373 if ((data[bitpos / 8] & (1 << (bitpos % 8))) == 0) { in HashMayMatch()
431 data + (GetLine(h, num_lines) << log2_cache_line_bytes); in AddHash()
445 const char *data, in PrepareHashMayMatch() argument
449 PREFETCH(data + b, 0 /* rw */, 1 /* locality */); in PrepareHashMayMatch()
[all …]
|
| D | hash.h | 30 extern uint64_t Hash64(const char* data, size_t n, uint64_t seed);
33 extern uint64_t Hash64(const char* data, size_t n);
38 inline uint64_t NPHash64(const char* data, size_t n, uint32_t seed) { in NPHash64() argument
40 return Hash64(data, n, seed); in NPHash64()
44 inline uint64_t NPHash64(const char* data, size_t n) { in NPHash64() argument
46 return Hash64(data, n); in NPHash64()
52 extern uint32_t Hash(const char* data, size_t n, uint32_t seed);
56 return Hash(key.data(), key.size(), 0xbc9f1d34); in BloomHash()
60 return Hash64(key.data(), key.size()); in GetSliceHash64()
64 return NPHash64(s.data(), s.size()); in GetSliceNPHash64()
[all …]
|
| /rocksdb-6.9/env/ |
| D | env_encryption.cc | 209 memmove(buf.BufferStart(), data.data(), data.size()); in Append()
233 memmove(buf.BufferStart(), data.data(), data.size()); in PositionedAppend()
338 memmove(buf.BufferStart(), data.data(), data.size()); in Write()
705 char *block = data; in Encrypt()
722 if (block != data) { in Encrypt()
730 data += n; in Encrypt()
750 char *block = data; in Decrypt()
783 data += n; in Decrypt()
793 data[i] += 13; in Encrypt()
801 return Encrypt(data); in Decrypt()
[all …]
|
| /rocksdb-6.9/table/block_based/ |
| D | filter_policy.cc | 56 assert(data); in Finish()
61 AddAllEntries(data, len); in Finish()
66 data[len] = static_cast<char>(-1); in Finish()
73 const char* const_data = data; in Finish()
268 char* data = in Finish() local
270 assert(data); in Finish()
305 const char* const_data = data; in Finish()
350 char* data = new char[sz]; in ReserveSpace() local
351 memset(data, 0, sz); in ReserveSpace()
352 return data; in ReserveSpace()
[all …]
|
| D | block_based_filter_block.cc | 97 entries_.append(key.data(), key.size()); in AddKey()
148 const char* base = entries_.data() + start_[i]; in GenerateFilter()
223 assert(data); in ParseFieldsFromBlock()
228 const size_t n = contents.data.size(); in ParseFieldsFromBlock()
233 const uint32_t last_word = DecodeFixed32(contents.data.data() + n - 5); in ParseFieldsFromBlock()
238 *data = contents.data.data(); in ParseFieldsFromBlock()
239 *offset = (*data) + last_word; in ParseFieldsFromBlock()
241 *base_lg = contents.data[n - 1]; in ParseFieldsFromBlock()
259 const char* data = nullptr; in MayMatch() local
317 const char* data = nullptr; in ToString() local
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_test.cc | 318 VerifyDB(data); in TEST_F()
344 VerifyDB(data); in TEST_F()
370 VerifyDB(data); in TEST_F()
459 VerifyDB(data); in TEST_F()
475 VerifyDB(data); in TEST_F()
510 VerifyDB(data); in TEST_F()
533 VerifyDB(data); in TEST_F()
547 VerifyDB(data); in TEST_F()
550 VerifyDB(data); in TEST_F()
580 VerifyDB(data); in TEST_F()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | slice.cc | 134 const jsize dataSize = env->GetArrayLength(data); in Java_org_rocksdb_Slice_createNewSlice0()
140 env->GetByteArrayRegion(data, offset, len, buf); in Java_org_rocksdb_Slice_createNewSlice0()
162 const int len = env->GetArrayLength(data) + 1; in Java_org_rocksdb_Slice_createNewSlice1()
186 const jbyteArray data = env->NewByteArray(len); in Java_org_rocksdb_Slice_data0() local
187 if (data == nullptr) { in Java_org_rocksdb_Slice_data0()
193 data, 0, len, in Java_org_rocksdb_Slice_data0()
197 env->DeleteLocalRef(data); in Java_org_rocksdb_Slice_data0()
201 return data; in Java_org_rocksdb_Slice_data0()
257 assert(data != nullptr); in Java_org_rocksdb_DirectSlice_createNewDirectSlice0()
258 void* data_addr = env->GetDirectBufferAddress(data); in Java_org_rocksdb_DirectSlice_createNewDirectSlice0()
[all …]
|
| D | statistics.cc | 191 ROCKSDB_NAMESPACE::HistogramData data; in Java_org_rocksdb_Statistics_getHistogramData() local
196 static_cast<ROCKSDB_NAMESPACE::Histograms>(histogram), &data); in Java_org_rocksdb_Statistics_getHistogramData()
211 return env->NewObject(jclazz, mid, data.median, data.percentile95, in Java_org_rocksdb_Statistics_getHistogramData()
212 data.percentile99, data.average, in Java_org_rocksdb_Statistics_getHistogramData()
213 data.standard_deviation, data.max, data.count, in Java_org_rocksdb_Statistics_getHistogramData()
214 data.sum, data.min); in Java_org_rocksdb_Statistics_getHistogramData()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | DirectSliceTest.java | 37 final byte[] data = "Some text".getBytes(); in directSliceWithByteBuffer()
38 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length + 1); in directSliceWithByteBuffer()
39 buffer.put(data); in directSliceWithByteBuffer()
40 buffer.put(data.length, (byte)0); in directSliceWithByteBuffer()
49 final byte[] data = "Some text".getBytes(); in directSliceWithByteBufferAndLength()
50 final ByteBuffer buffer = ByteBuffer.allocateDirect(data.length); in directSliceWithByteBufferAndLength()
51 buffer.put(data); in directSliceWithByteBufferAndLength()
59 final byte[] data = "Some text".getBytes(); in directSliceInitWithoutDirectAllocation()
60 final ByteBuffer buffer = ByteBuffer.wrap(data); in directSliceInitWithoutDirectAllocation()
68 final byte[] data = "Some text".getBytes(); in directSlicePrefixInitWithoutDirectAllocation()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file.cc | 104 const char* data, const size_t size);
140 const char* p = data; in Append()
167 bool CacheRecord::Deserialize(const Slice& data) { in Deserialize() argument
169 if (data.size() < sizeof(CacheRecordHeader)) { in Deserialize()
173 memcpy(&hdr_, data.data(), sizeof(hdr_)); in Deserialize()
245 assert(result.data() == scratch); in Read()
252 Slice data(scratch, lba.size_); in ParseRec() local
255 if (!rec.Deserialize(data)) { in ParseRec()
472 char* tmp = data; in ReadBuffer()
502 assert(tmp == data + lba.size_); in ReadBuffer()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | DirectSlice.java | 65 public DirectSlice(final ByteBuffer data, final int length) { in DirectSlice() argument
66 super(createNewDirectSlice0(ensureDirect(data), length)); in DirectSlice()
77 public DirectSlice(final ByteBuffer data) { in DirectSlice() argument
78 super(createNewDirectSlice1(ensureDirect(data))); in DirectSlice()
82 private static ByteBuffer ensureDirect(final ByteBuffer data) { in ensureDirect() argument
83 if(!data.isDirect()) { in ensureDirect()
86 return data; in ensureDirect()
122 private native static long createNewDirectSlice0(final ByteBuffer data, in createNewDirectSlice0() argument
124 private native static long createNewDirectSlice1(final ByteBuffer data); in createNewDirectSlice1() argument
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_reader.cc | 87 user_key_len->second.data()); in CuckooTableReader()
95 value_length->second.data()); in CuckooTableReader()
105 hash_table_size->second.data()); in CuckooTableReader()
121 identity_as_first_hash->second.data()); in CuckooTableReader()
130 use_module_hash->second.data()); in CuckooTableReader()
138 cuckoo_block_size->second.data()); in CuckooTableReader()
154 const char* bucket = &file_data_.data()[offset]; in Get()
230 (first == kInvalidIndex) ? target_.data() : in operator ()()
233 (second == kInvalidIndex) ? target_.data() : in operator ()()
276 const char* bucket = reader_->file_data_.data(); in InitIfNeeded()
[all …]
|
| /rocksdb-6.9/table/ |
| D | format.h | 232 Slice data; // Actual contents of data member
244 BlockContents(const Slice& _data) : data(_data) {} in BlockContents()
248 : data(_data.get(), _size), allocation(std::move(_data)) {} in BlockContents()
252 : data(_data.get(), _size) { in BlockContents()
264 return get_block_compression_type(data.data(), data.size()); in get_compression_type()
272 return allocator->UsableSize(allocation.get(), data.size()); in usable_size()
277 return data.size(); in usable_size()
293 data = std::move(other.data);
319 const char* data, size_t n,
329 const UncompressionInfo& info, const char* data, size_t n,
|
| D | block_fetcher.cc | 35 const char* data = slice_.data(); // Pointer to where Read put the data in CheckBlockChecksum() local
37 uint32_t value = DecodeFixed32(data + block_size_ + 1); in CheckBlockChecksum()
44 actual = crc32c::Value(data, block_size_ + 1); in CheckBlockChecksum()
47 actual = XXH32(data, static_cast<int>(block_size_) + 1, 0); in CheckBlockChecksum()
51 XXH64(data, static_cast<int>(block_size_) + 1, 0) & in CheckBlockChecksum()
102 used_buf_ = const_cast<char*>(slice_.data()); in TryGetFromPrefetchBuffer()
174 if (slice_.data() != used_buf_) { in GetBlockContents()
176 *contents_ = BlockContents(Slice(slice_.data(), block_size_)); in GetBlockContents()
265 compression_type_ = get_block_compression_type(slice_.data(), block_size_); in ReadBlockContents()
271 status_ = UncompressBlockContents(info, slice_.data(), block_size_, in ReadBlockContents()
|
| /rocksdb-6.9/port/win/ |
| D | io_win.cc | 76 size_t num_bytes = data.size(); in pwrite()
93 if (FALSE == WriteFile(file_data->GetFileHandle(), data.data(), static_cast<DWORD>(num_bytes), in pwrite()
385 const char* src = data.data(); in Append()
386 size_t left = data.size(); in Append()
780 if (!IsSectorAligned(data.size()) || in AppendImpl()
781 !IsAligned(static_cast<size_t>(GetAlignement()), data.data())) { in AppendImpl()
790 if (!WriteFile(file_data_->GetFileHandle(), data.data(), in AppendImpl()
802 if (bytes_written == data.size()) { in AppendImpl()
822 !IsAligned(static_cast<size_t>(GetAlignement()), data.data())) { in PositionedAppendImpl()
832 if (bytes_written == data.size()) { in PositionedAppendImpl()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env_encryption.h | 34 virtual Status Encrypt(uint64_t fileOffset, char* data, size_t dataSize);
38 virtual Status Decrypt(uint64_t fileOffset, char* data, size_t dataSize);
46 virtual Status EncryptBlock(uint64_t blockIndex, char* data,
51 virtual Status DecryptBlock(uint64_t blockIndex, char* data,
65 virtual Status Encrypt(char* data) = 0;
69 virtual Status Decrypt(char* data) = 0;
89 virtual Status Encrypt(char* data) override;
93 virtual Status Decrypt(char* data) override;
122 virtual Status EncryptBlock(uint64_t blockIndex, char* data,
127 virtual Status DecryptBlock(uint64_t blockIndex, char* data,
|