Home
last modified time | relevance | path

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

12

/rocksdb-6.9/util/
Dxxh3p.h442 XXH_ASSERT(input != NULL); in XXH3p_len_1to3_64b()
458 XXH_ASSERT(input != NULL); in XXH3p_len_4to8_64b()
473 XXH_ASSERT(input != NULL); in XXH3p_len_9to16_64b()
1110 XXH_ASSERT(input != NULL); in XXH3p_len_1to3_128b()
1131 XXH_ASSERT(input != NULL); in XXH3p_len_4to8_128b()
1152 XXH_ASSERT(input != NULL); in XXH3p_len_9to16_128b()
1249 acc = XXH128_mix32B(acc, input+(32*i), input+(32*i)+16, secret+(32*i), seed); in XXH3p_len_129to240_128b()
1283 acc = XXH128_mix32B(acc, input+48, input+len-64, secret+96, seed); in XXH3p_len_17to128_128b()
1285 acc = XXH128_mix32B(acc, input+32, input+len-48, secret+64, seed); in XXH3p_len_17to128_128b()
1287 acc = XXH128_mix32B(acc, input+16, input+len-32, secret+32, seed); in XXH3p_len_17to128_128b()
[all …]
Dcoding.h346 *value = DecodeFixed64(input->data()); in GetFixed64()
355 *value = DecodeFixed32(input->data()); in GetFixed32()
364 *value = DecodeFixed16(input->data()); in GetFixed16()
370 const char* p = input->data(); in GetVarint32()
371 const char* limit = p + input->size(); in GetVarint32()
382 const char* p = input->data(); in GetVarint64()
383 const char* limit = p + input->size(); in GetVarint64()
394 const char* p = input->data(); in GetVarsignedint64()
395 const char* limit = p + input->size(); in GetVarsignedint64()
418 if (GetVarint32(input, &len) && input->size() >= len) { in GetLengthPrefixedSlice()
[all …]
Dxxhash.cc475 if (input==NULL) { in XXH32_endian_align()
489 v1 = XXH32_round(v1, XXH_get32bits(input)); input += 4; in XXH32_endian_align()
490 v2 = XXH32_round(v2, XXH_get32bits(input)); input += 4; in XXH32_endian_align()
491 v3 = XXH32_round(v3, XXH_get32bits(input)); input += 4; in XXH32_endian_align()
492 v4 = XXH32_round(v4, XXH_get32bits(input)); input += 4; in XXH32_endian_align()
563 if (input==NULL) in XXH32_update()
973 v1 = XXH64_round(v1, XXH_get64bits(input)); input+=8; in XXH64_endian_align()
974 v2 = XXH64_round(v2, XXH_get64bits(input)); input+=8; in XXH64_endian_align()
975 v3 = XXH64_round(v3, XXH_get64bits(input)); input+=8; in XXH64_endian_align()
976 v4 = XXH64_round(v4, XXH_get64bits(input)); input+=8; in XXH64_endian_align()
[all …]
Dcoding_test.cc154 std::string input("\x81\x82\x83\x84\x85\x11"); in TEST() local
155 ASSERT_TRUE(GetVarint32Ptr(input.data(), input.data() + input.size(), &result) in TEST()
174 std::string input("\x81\x82\x83\x84\x85\x81\x82\x83\x84\x85\x11"); in TEST() local
175 ASSERT_TRUE(GetVarint64Ptr(input.data(), input.data() + input.size(), &result) in TEST()
199 Slice input(s); in TEST() local
201 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
203 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
205 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
207 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
209 ASSERT_EQ("", input.ToString()); in TEST()
Dcompression.h615 (void)input; in Snappy_Compress()
627 (void)input; in Snappy_GetUncompressedLength()
636 return snappy::RawUncompress(input, length, output); in Snappy_Uncompress()
638 (void)input; in Snappy_Uncompress()
723 _stream.next_in = (Bytef*)input; in Zlib_Compress()
745 (void)input; in Zlib_Compress()
890 _stream.next_in = (char*)input; in BZip2_Compress()
911 (void)input; in BZip2_Compress()
1063 (void)input; in LZ4_Compress()
1212 (void)input; in LZ4HC_Compress()
[all …]
Dhash_test.cc131 char input[4]; in TEST() local
135 EncodeFixed32(input, i); in TEST()
136 uint64_t here = Hash64(input, len, kSeed); in TEST()
223 std::string input; in Hash64TestDescriptor() local
224 while (input.size() < limit) { in Hash64TestDescriptor()
225 input.append(repeat); in Hash64TestDescriptor()
229 uint64_t h = GetSliceHash64(Slice(input.data(), i)); in Hash64TestDescriptor()
Dxxhash.h209 XXH_PUBLIC_API XXH32_hash_t XXH32 (const void* input, size_t length, XXH32_hash_t seed);
240 XXH_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t lengt…
284 XXH_PUBLIC_API XXH64_hash_t XXH64 (const void* input, size_t length, XXH64_hash_t seed);
293 XXH_PUBLIC_API XXH_errorcode XXH64_update (XXH64_state_t* statePtr, const void* input, size_t lengt…
518 XXH_PUBLIC_API XXH_errorcode XXH3p_64bits_update (XXH3p_state_t* statePtr, const void* input, size_…
556 XXH_PUBLIC_API XXH_errorcode XXH3p_128bits_update (XXH3p_state_t* statePtr, const void* input, size…
/rocksdb-6.9/db/
Dversion_edit.cc324 if (GetVarint32(input, &v)) { in GetLevel()
344 if (GetLevel(input, &level, &msg) && GetVarint64(input, &number) && in DecodeNewFile4From()
345 GetVarint64(input, &file_size) && GetInternalKey(input, &f.smallest) && in DecodeNewFile4From()
346 GetInternalKey(input, &f.largest) && in DecodeNewFile4From()
426 Slice input = src; in DecodeFrom() local
517 if (GetLevel(&input, &level, &msg) && GetVarint64(&input, &number)) { in DecodeFrom()
530 if (GetLevel(&input, &level, &msg) && GetVarint64(&input, &number) && in DecodeFrom()
548 if (GetLevel(&input, &level, &msg) && GetVarint64(&input, &number) && in DecodeFrom()
571 if (GetLevel(&input, &level, &msg) && GetVarint64(&input, &number) && in DecodeFrom()
572 GetVarint32(&input, &path_id) && GetVarint64(&input, &file_size) && in DecodeFrom()
[all …]
Dwrite_batch.cc382 assert(input != nullptr && key != nullptr); in ReadKeyFromWriteBatchEntry()
384 input->remove_prefix(1); in ReadKeyFromWriteBatchEntry()
389 if (!GetVarint32(input, &cf)) { in ReadKeyFromWriteBatchEntry()
395 return GetLengthPrefixedSlice(input, key); in ReadKeyFromWriteBatchEntry()
418 *tag = (*input)[0]; in ReadRecordFromWriteBatch()
419 input->remove_prefix(1); in ReadRecordFromWriteBatch()
423 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
435 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
446 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
458 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
[all …]
/rocksdb-6.9/table/
Dformat.cc58 if (GetVarint64(input, &offset_) && GetVarint64(input, &size_)) { in DecodeFrom()
69 if (GetVarint64(input, &size_)) { in DecodeSizeFrom()
113 if (!GetVarsignedint64(input, &delta)) { in DecodeFrom()
120 Status s = handle.DecodeFrom(input); in DecodeFrom()
207 Status Footer::DecodeFrom(Slice* input) { in DecodeFrom() argument
209 assert(input != nullptr); in DecodeFrom()
213 input->data() + input->size() - kMagicNumberLengthByte; in DecodeFrom()
229 input->remove_prefix(input->size() - kVersion0EncodedLength); in DecodeFrom()
240 input->remove_prefix(input->size() - kNewVersionsEncodedLength); in DecodeFrom()
243 if (!GetVarint32(input, &chksum)) { in DecodeFrom()
[all …]
Dformat.h53 Status DecodeFrom(Slice* input);
54 Status DecodeSizeFrom(uint64_t offset, Slice* input);
98 Status DecodeFrom(Slice* input, bool have_first_key,
163 Status DecodeFrom(Slice* input);
/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc168 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
169 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
181 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
200 ASSERT_EQ(66U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
201 ASSERT_EQ(6U, compaction->input(1, 0)->fd.GetNumber()); in TEST_F()
202 ASSERT_EQ(7U, compaction->input(1, 1)->fd.GetNumber()); in TEST_F()
230 ASSERT_EQ(7U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
277 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
278 ASSERT_EQ(2U, compaction->input(0, 1)->fd.GetNumber()); in TEST_F()
301 ASSERT_EQ(1U, compaction->input(0, 0)->fd.GetNumber()); in TEST_F()
[all …]
Dcompaction_iterator.h63 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper,
78 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper,
Dcompaction_iterator.cc34 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper, in CompactionIterator() argument
46 input, cmp, merge_helper, last_sequence, snapshots, in CompactionIterator()
55 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper, in CompactionIterator() argument
67 : input_(input), in CompactionIterator()
Dcompaction_job.cc842 std::unique_ptr<InternalIterator> input(versions_->MakeInputIterator( in ProcessKeyValueCompaction() local
887 input->Seek(start_iter.GetInternalKey()); in ProcessKeyValueCompaction()
889 input->SeekToFirst(); in ProcessKeyValueCompaction()
894 input.get(), cfd->user_comparator(), &merge, versions_->LastSequence(), in ProcessKeyValueCompaction()
961 input_status = input->status(); in ProcessKeyValueCompaction()
980 input_status = input->status(); in ProcessKeyValueCompaction()
1029 status = input->status(); in ProcessKeyValueCompaction()
1075 input.reset(); in ProcessKeyValueCompaction()
1642 const auto* file_meta = compaction->input(input_level, i); in UpdateCompactionInputStatsHelper()
/rocksdb-6.9/db/blob/
Dblob_file_addition.cc50 Status BlobFileAddition::DecodeFrom(Slice* input) { in DecodeFrom() argument
53 if (!GetVarint64(input, &blob_file_number_)) { in DecodeFrom()
57 if (!GetVarint64(input, &total_blob_count_)) { in DecodeFrom()
61 if (!GetVarint64(input, &total_blob_bytes_)) { in DecodeFrom()
66 if (!GetLengthPrefixedSlice(input, &checksum_method)) { in DecodeFrom()
72 if (!GetLengthPrefixedSlice(input, &checksum_value)) { in DecodeFrom()
79 if (!GetVarint32(input, &custom_field_tag)) { in DecodeFrom()
93 if (!GetLengthPrefixedSlice(input, &custom_field_value)) { in DecodeFrom()
Dblob_file_garbage.cc48 Status BlobFileGarbage::DecodeFrom(Slice* input) { in DecodeFrom() argument
51 if (!GetVarint64(input, &blob_file_number_)) { in DecodeFrom()
55 if (!GetVarint64(input, &garbage_blob_count_)) { in DecodeFrom()
59 if (!GetVarint64(input, &garbage_blob_bytes_)) { in DecodeFrom()
65 if (!GetVarint32(input, &custom_field_tag)) { in DecodeFrom()
79 if (!GetLengthPrefixedSlice(input, &custom_field_value)) { in DecodeFrom()
Dblob_file_garbage_test.cc25 Slice input(encoded); in TestEncodeDecode() local
26 ASSERT_OK(decoded.DecodeFrom(&input)); in TestEncodeDecode()
158 Slice input(encoded); in TEST_F() local
159 const Status s = decoded_blob_file_addition.DecodeFrom(&input); in TEST_F()
Dblob_file_addition_test.cc25 Slice input(encoded); in TestEncodeDecode() local
26 ASSERT_OK(decoded.DecodeFrom(&input)); in TestEncodeDecode()
191 Slice input(encoded); in TEST_F() local
192 const Status s = decoded_blob_file_addition.DecodeFrom(&input); in TEST_F()
/rocksdb-6.9/port/win/
Dxpress_win.cc44 bool Compress(const char* input, size_t length, std::string* output) { in Compress() argument
46 assert(input != nullptr); in Compress()
79 const_cast<char*>(input), // Input buffer in Compress()
109 const_cast<char*>(input), // Input buffer in Compress()
/rocksdb-6.9/docs/_sass/
D_search.scss1 input[type="search"] {
66 input#search_input {
99 input#search_input_react {
/rocksdb-6.9/port/
Dport_example.h81 extern bool Snappy_Compress(const char* input, size_t input_length,
87 extern bool Snappy_GetUncompressedLength(const char* input, size_t length,
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc501 const auto& input = *iit; in ProcessCompactionJobInfo() local
504 if (input.file_number == output.file_number) { in ProcessCompactionJobInfo()
507 } else if (input.file_number < output.file_number) { in ProcessCompactionJobInfo()
508 if (input.oldest_blob_file_number != kInvalidBlobFileNumber) { in ProcessCompactionJobInfo()
509 UnlinkSstFromBlobFile(input.file_number, input.oldest_blob_file_number); in ProcessCompactionJobInfo()
514 assert(output.file_number < input.file_number); in ProcessCompactionJobInfo()
525 const auto& input = *iit; in ProcessCompactionJobInfo() local
527 if (input.oldest_blob_file_number != kInvalidBlobFileNumber) { in ProcessCompactionJobInfo()
528 UnlinkSstFromBlobFile(input.file_number, input.oldest_blob_file_number); in ProcessCompactionJobInfo()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc578 Slice input(write_batch.Data()); in ReBuildIndex() local
579 input.remove_prefix(offset); in ReBuildIndex()
583 while (s.ok() && !input.empty()) { in ReBuildIndex()
589 last_entry_offset = input.data() - write_batch.Data().data(); in ReBuildIndex()
591 s = ReadRecordFromWriteBatch(&input, &tag, &column_family_id, &key, in ReBuildIndex()
Dwrite_batch_with_index_internal.cc42 Slice input = Slice(rep_.data() + data_offset, rep_.size() - data_offset); in GetEntryFromDataOffset() local
45 Status s = ReadRecordFromWriteBatch(&input, &tag, &column_family, Key, value, in GetEntryFromDataOffset()

12