| /leveldb-1.20/db/ |
| H A D | version_edit.cc | 90 if (GetLengthPrefixedSlice(input, &str)) { in GetInternalKey()
98 static bool GetLevel(Slice* input, int* level) { in GetLevel() argument
100 if (GetVarint32(input, &v) && in GetLevel()
111 Slice input = src; in DecodeFrom() local
166 if (GetLevel(&input, &level) && in DecodeFrom()
167 GetInternalKey(&input, &key)) { in DecodeFrom()
175 if (GetLevel(&input, &level) && in DecodeFrom()
176 GetVarint64(&input, &number)) { in DecodeFrom()
184 if (GetLevel(&input, &level) && in DecodeFrom()
185 GetVarint64(&input, &f.number) && in DecodeFrom()
[all …]
|
| H A D | write_batch.cc | 43 Slice input(rep_); in Iterate() local
44 if (input.size() < kHeader) { in Iterate()
48 input.remove_prefix(kHeader); in Iterate()
51 while (!input.empty()) { in Iterate()
53 char tag = input[0]; in Iterate()
54 input.remove_prefix(1); in Iterate()
57 if (GetLengthPrefixedSlice(&input, &key) && in Iterate()
58 GetLengthPrefixedSlice(&input, &value)) { in Iterate()
65 if (GetLengthPrefixedSlice(&input, &key)) { in Iterate()
|
| H A D | db_impl.cc | 720 FileMetaData* f = c->input(0, 0); in BackgroundCompaction()
823 Status s = input->status(); in FinishCompactionOutputFile()
910 input->SeekToFirst(); in DoCompactionWork()
929 Slice key = input->key(); in DoCompactionWork()
932 status = FinishCompactionOutputFile(compact, input); in DoCompactionWork()
995 compact->builder->Add(key, input->value()); in DoCompactionWork()
1007 input->Next(); in DoCompactionWork()
1014 status = FinishCompactionOutputFile(compact, input); in DoCompactionWork()
1017 status = input->status(); in DoCompactionWork()
1019 delete input; in DoCompactionWork()
[all …]
|
| H A D | db_bench.cc | 664 Slice input = gen.Generate(Options().block_size); in SnappyCompress() local
670 ok = port::Snappy_Compress(input.data(), input.size(), &compressed); in SnappyCompress()
672 bytes += input.size(); in SnappyCompress()
689 Slice input = gen.Generate(Options().block_size); in SnappyUncompress() local
691 bool ok = port::Snappy_Compress(input.data(), input.size(), &compressed); in SnappyUncompress()
693 char* uncompressed = new char[input.size()]; in SnappyUncompress()
697 bytes += input.size(); in SnappyUncompress()
|
| H A D | db_impl.h | 117 Status FinishCompactionOutputFile(CompactionState* compact, Iterator* input);
|
| H A D | version_set.h | 340 FileMetaData* input(int which, int i) const { return inputs_[which][i]; } in input() function
|
| /leveldb-1.20/util/ |
| H A D | coding.cc | 131 bool GetVarint32(Slice* input, uint32_t* value) { in GetVarint32() argument
132 const char* p = input->data(); in GetVarint32()
133 const char* limit = p + input->size(); in GetVarint32()
138 *input = Slice(q, limit - q); in GetVarint32()
161 const char* p = input->data(); in GetVarint64()
162 const char* limit = p + input->size(); in GetVarint64()
167 *input = Slice(q, limit - q); in GetVarint64()
184 if (GetVarint32(input, &len) && in GetLengthPrefixedSlice()
185 input->size() >= len) { in GetLengthPrefixedSlice()
186 *result = Slice(input->data(), len); in GetLengthPrefixedSlice()
[all …]
|
| H A D | coding_test.cc | 136 std::string input("\x81\x82\x83\x84\x85\x11"); in TEST() local
137 ASSERT_TRUE(GetVarint32Ptr(input.data(), input.data() + input.size(), &result) in TEST()
155 std::string input("\x81\x82\x83\x84\x85\x81\x82\x83\x84\x85\x11"); in TEST() local
156 ASSERT_TRUE(GetVarint64Ptr(input.data(), input.data() + input.size(), &result) in TEST()
179 Slice input(s); in TEST() local
181 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
183 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
185 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
187 ASSERT_TRUE(GetLengthPrefixedSlice(&input, &v)); in TEST()
189 ASSERT_EQ("", input.ToString()); in TEST()
|
| H A D | coding.h | 30 extern bool GetVarint32(Slice* input, uint32_t* value);
31 extern bool GetVarint64(Slice* input, uint64_t* value);
32 extern bool GetLengthPrefixedSlice(Slice* input, Slice* result);
|
| /leveldb-1.20/table/ |
| H A D | format.cc | 23 Status BlockHandle::DecodeFrom(Slice* input) { in DecodeFrom() argument
24 if (GetVarint64(input, &offset_) && in DecodeFrom()
25 GetVarint64(input, &size_)) { in DecodeFrom()
43 Status Footer::DecodeFrom(Slice* input) { in DecodeFrom() argument
44 const char* magic_ptr = input->data() + kEncodedLength - 8; in DecodeFrom()
53 Status result = metaindex_handle_.DecodeFrom(input); in DecodeFrom()
55 result = index_handle_.DecodeFrom(input); in DecodeFrom()
60 *input = Slice(end, input->data() + input->size() - end); in DecodeFrom()
|
| H A D | format.h | 35 Status DecodeFrom(Slice* input);
64 Status DecodeFrom(Slice* input);
|
| H A D | table.cc | 173 Slice input = index_value; in BlockReader() local
174 Status s = handle.DecodeFrom(&input); in BlockReader()
265 Slice input = index_iter->value(); in ApproximateOffsetOf() local
266 Status s = handle.DecodeFrom(&input); in ApproximateOffsetOf()
|
| /leveldb-1.20/port/ |
| H A D | port_posix.h | 116 inline bool Snappy_Compress(const char* input, size_t length, in Snappy_Compress() argument
121 snappy::RawCompress(input, length, &(*output)[0], &outlen); in Snappy_Compress()
129 inline bool Snappy_GetUncompressedLength(const char* input, size_t length, in Snappy_GetUncompressedLength() argument
132 return snappy::GetUncompressedLength(input, length, result); in Snappy_GetUncompressedLength()
138 inline bool Snappy_Uncompress(const char* input, size_t length, in Snappy_Uncompress() argument
141 return snappy::RawUncompress(input, length, output); in Snappy_Uncompress()
|
| H A D | port_example.h | 106 extern bool Snappy_Compress(const char* input, size_t input_length,
112 extern bool Snappy_GetUncompressedLength(const char* input, size_t length,
|
| /leveldb-1.20/doc/ |
| H A D | impl.md | 80 level-(L+1) file, the entire file at level-(L+1) is used as an input to the
|