| /leveldb-1.20/util/ |
| H A D | hash.cc | 18 uint32_t Hash(const char* data, size_t n, uint32_t seed) { in Hash() argument 22 const char* limit = data + n; in Hash() 26 while (data + 4 <= limit) { in Hash() 27 uint32_t w = DecodeFixed32(data); in Hash() 28 data += 4; in Hash() 35 switch (limit - data) { in Hash() 37 h += static_cast<unsigned char>(data[2]) << 16; in Hash() 40 h += static_cast<unsigned char>(data[1]) << 8; in Hash() 43 h += static_cast<unsigned char>(data[0]); in Hash()
|
| H A D | env.cc | 40 static Status DoWriteStringToFile(Env* env, const Slice& data, in DoWriteStringToFile() argument 48 s = file->Append(data); in DoWriteStringToFile() 62 Status WriteStringToFile(Env* env, const Slice& data, in WriteStringToFile() argument 64 return DoWriteStringToFile(env, data, fname, false); in WriteStringToFile() 67 Status WriteStringToFileSync(Env* env, const Slice& data, in WriteStringToFileSync() argument 69 return DoWriteStringToFile(env, data, fname, true); in WriteStringToFileSync() 72 Status ReadFileToString(Env* env, const std::string& fname, std::string* data) { in ReadFileToString() argument 73 data->clear(); in ReadFileToString() 87 data->append(fragment.data(), fragment.size()); in ReadFileToString()
|
| H A D | coding_test.cc | 19 const char* p = s.data(); in TEST() 36 const char* p = s.data(); in TEST() 84 const char* p = s.data(); in TEST() 95 ASSERT_EQ(p, s.data() + s.size()); in TEST() 119 const char* p = s.data(); in TEST() 137 ASSERT_TRUE(GetVarint32Ptr(input.data(), input.data() + input.size(), &result) in TEST() 147 ASSERT_TRUE(GetVarint32Ptr(s.data(), s.data() + len, &result) == NULL); in TEST() 149 ASSERT_TRUE(GetVarint32Ptr(s.data(), s.data() + s.size(), &result) != NULL); in TEST() 156 ASSERT_TRUE(GetVarint64Ptr(input.data(), input.data() + input.size(), &result) in TEST() 166 ASSERT_TRUE(GetVarint64Ptr(s.data(), s.data() + len, &result) == NULL); in TEST() [all …]
|
| H A D | crc32c.h | 17 extern uint32_t Extend(uint32_t init_crc, const char* data, size_t n); 20 inline uint32_t Value(const char* data, size_t n) { in Value() argument 21 return Extend(0, data, n); in Value()
|
| H A D | crc32c_test.cc | 33 unsigned char data[48] = { in TEST() local 47 ASSERT_EQ(0xd9963a56, Value(reinterpret_cast<char*>(data), sizeof(data))); in TEST()
|
| H A D | status.cc | 27 memcpy(result + 5, msg.data(), len1); in Status() 31 memcpy(result + 7 + len1, msg2.data(), len2); in Status()
|
| H A D | coding.cc | 100 dst->append(value.data(), value.size()); in PutLengthPrefixedSlice() 132 const char* p = input->data(); in GetVarint32() 161 const char* p = input->data(); in GetVarint64() 186 *result = Slice(input->data(), len); in GetLengthPrefixedSlice()
|
| /leveldb-1.20/table/ |
| H A D | format.cc | 44 const char* magic_ptr = input->data() + kEncodedLength - 8; in DecodeFrom() 60 *input = Slice(end, input->data() + input->size() - end); in DecodeFrom() 69 result->data = Slice(); in ReadBlock() 89 const char* data = contents.data(); // Pointer to where Read put the data in ReadBlock() local 92 const uint32_t actual = crc32c::Value(data, n + 1); in ReadBlock() 100 switch (data[n]) { in ReadBlock() 102 if (data != buf) { in ReadBlock() 107 result->data = Slice(data, n); in ReadBlock() 111 result->data = Slice(buf, n); in ReadBlock() 125 if (!port::Snappy_Uncompress(data, n, ubuf)) { in ReadBlock() [all …]
|
| H A D | table_test.cc | 101 contents_.append(data.data(), data.size()); in Append() 196 it != data.end(); in FinishImpl() 203 contents.data = data_; in FinishImpl() 236 it != data.end(); in FinishImpl() 333 it != data.end(); in FinishImpl() 365 it != data.end(); in FinishImpl() 479 KVMap data; in Test() local 588 if (it == data.end()) { in ToString() 597 if (it == data.rend()) { in ToString() 661 memset(data, 0, sizeof(data)); in TEST() [all …]
|
| H A D | block.cc | 24 : data_(contents.data.data()), in Block() 25 size_(contents.data.size()), in Block() 96 return (value_.data() + value_.size()) - data_; in NextEntryOffset() 116 const char* data, in Iter() argument 120 data_(data), in Iter()
|
| H A D | filter_block.cc | 33 keys_.append(k.data(), k.size()); in AddKey() 64 const char* base = keys_.data() + start_[i]; in GenerateFilter() 88 uint32_t last_word = DecodeFixed32(contents.data() + n - 5); in FilterBlockReader() 90 data_ = contents.data(); in FilterBlockReader()
|
| H A D | block_builder.cc | 99 buffer_.append(key.data() + shared, non_shared); in Add() 100 buffer_.append(value.data(), value.size()); in Add() 104 last_key_.append(key.data() + shared, non_shared); in Add()
|
| H A D | filter_block_test.cc | 25 uint32_t h = Hash(keys[i].data(), keys[i].size(), 1); in CreateFilter() 31 uint32_t h = Hash(key.data(), key.size(), 1); in KeyMayMatch() 33 if (h == DecodeFixed32(filter.data() + i)) { in KeyMayMatch()
|
| /leveldb-1.20/db/ |
| H A D | memtable.cc | 14 static Slice GetLengthPrefixedSlice(const char* data) { in GetLengthPrefixedSlice() argument 16 const char* p = data; in GetLengthPrefixedSlice() 47 scratch->append(target.data(), target.size()); in EncodeKey() 48 return scratch->data(); in EncodeKey() 64 return GetLengthPrefixedSlice(key_slice.data() + key_slice.size()); in value() 98 memcpy(p, key.data(), key_size); in Add() 103 memcpy(p, value.data(), val_size); in Add() 111 iter.Seek(memkey.data()); in Get() 133 value->assign(v.data(), v.size()); in Get()
|
| H A D | filename_test.cc | 83 ASSERT_EQ("foo/", std::string(fname.data(), 4)); in TEST() 89 ASSERT_EQ("foo/", std::string(fname.data(), 4)); in TEST() 95 ASSERT_EQ("foo/", std::string(fname.data(), 4)); in TEST() 101 ASSERT_EQ("bar/", std::string(fname.data(), 4)); in TEST() 107 ASSERT_EQ("bar/", std::string(fname.data(), 4)); in TEST() 113 ASSERT_EQ("tmp/", std::string(fname.data(), 4)); in TEST()
|
| H A D | leveldbutil.cc | 15 virtual Status Append(const Slice& data) { in Append() argument 16 fwrite(data.data(), 1, data.size(), stdout); in Append()
|
| H A D | dbformat.cc | 19 result->append(key.user_key.data(), key.user_key.size()); in AppendInternalKey() 57 const uint64_t anum = DecodeFixed64(akey.data() + akey.size() - 8); in Compare() 58 const uint64_t bnum = DecodeFixed64(bkey.data() + bkey.size() - 8); in Compare() 74 std::string tmp(user_start.data(), user_start.size()); in FindShortestSeparator() 89 std::string tmp(user_key.data(), user_key.size()); in FindShortSuccessor() 133 memcpy(dst, user_key.data(), usize); in LookupKey()
|
| H A D | dbformat.h | 100 return Slice(internal_key.data(), internal_key.size() - 8); in ExtractUserKey() 106 uint64_t num = DecodeFixed64(internal_key.data() + n - 8); in ExtractValueType() 153 void DecodeFrom(const Slice& s) { rep_.assign(s.data(), s.size()); } in DecodeFrom() 180 uint64_t num = DecodeFixed64(internal_key.data() + n - 8); in ParseInternalKey() 184 result->user_key = Slice(internal_key.data(), n - 8); in ParseInternalKey()
|
| H A D | write_batch.cc | 83 return DecodeFixed32(b->rep_.data() + 8); in Count() 91 return SequenceNumber(DecodeFixed64(b->rep_.data())); in Sequence() 138 b->rep_.assign(contents.data(), contents.size()); in SetContents() 144 dst->rep_.append(src->rep_.data() + kHeader, src->rep_.size() - kHeader); in Append()
|
| H A D | c.cc | 74 return (*compare_)(state_, a.data(), a.size(), b.data(), b.size()); in Compare() 112 key_pointers[i] = keys[i].data(); in CreateFilter() 122 return (*key_match_)(state_, key.data(), key.size(), in KeyMayMatch() 123 filter.data(), filter.size()); in KeyMayMatch() 148 memcpy(result, str.data(), sizeof(char) * str.size()); in CopyString() 324 return s.data(); in leveldb_iter_key() 330 return s.data(); in leveldb_iter_value() 373 (*put_)(state_, key.data(), key.size(), value.data(), value.size()); in leveldb_writebatch_iterate() 376 (*deleted_)(state_, key.data(), key.size()); in leveldb_writebatch_iterate()
|
| H A D | log_reader.cc | 127 scratch->assign(fragment.data(), fragment.size()); in ReadRecord() 136 scratch->append(fragment.data(), fragment.size()); in ReadRecord() 145 scratch->append(fragment.data(), fragment.size()); in ReadRecord() 227 const char* header = buffer_.data(); in ReadPhysicalRecord()
|
| /leveldb-1.20/doc/ |
| H A D | table_format.md | 5 [data block 1] 6 [data block 2] 8 [data block N] 27 order and partitioned into a sequence of data blocks. These blocks 32 2. After the data blocks we store a bunch of meta blocks. The 41 4. An "index" block. This block contains one entry per data block, 43 the first key in the successive data block. The value is the 44 BlockHandle for the data block. 93 mapping from a data block offset to the corresponding filter. 102 data size [all …]
|
| H A D | log_format.md | 10 checksum: uint32 // crc32c of type and data[] ; little-endian 13 data: uint8[length] 21 bytes of user data) to fill up the trailing seven bytes of the block and then 22 emit all of the user data in subsequent blocks. 25 do not understand, others may report that some data was skipped.
|
| /leveldb-1.20/include/leveldb/ |
| H A D | slice.h | 34 Slice(const std::string& s) : data_(s.data()), size_(s.size()) { } in Slice() 40 const char* data() const { return data_; } in data() function 89 (memcmp(x.data(), y.data(), x.size()) == 0));
|
| /leveldb-1.20/helpers/memenv/ |
| H A D | memenv.cc | 95 Status Append(const Slice& data) { in Append() argument 96 const char* src = data.data(); in Append() 97 size_t src_len = data.size(); in Append() 213 virtual Status Append(const Slice& data) { in Append() argument 214 return file_->Append(data); in Append()
|