| /rocksdb-6.9/java/rocksjni/ |
| D | slice.cc | 47 return reinterpret_cast<jlong>(slice); in Java_org_rocksdb_AbstractSlice_createNewSliceFromString() 58 return static_cast<jint>(slice->size()); in Java_org_rocksdb_AbstractSlice_size0() 69 return slice->empty(); in Java_org_rocksdb_AbstractSlice_empty0() 94 return slice->compare(*otherSlice); in Java_org_rocksdb_AbstractSlice_compare0() 147 return reinterpret_cast<jlong>(slice); in Java_org_rocksdb_Slice_createNewSlice0() 174 return reinterpret_cast<jlong>(slice); in Java_org_rocksdb_Slice_createNewSlice1() 217 slice->clear(); in Java_org_rocksdb_Slice_clear0() 228 slice->remove_prefix(length); in Java_org_rocksdb_Slice_removePrefix0() 316 return (*slice)[offset]; in Java_org_rocksdb_DirectSlice_get0() 332 slice->clear(); in Java_org_rocksdb_DirectSlice_clear0() [all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | SliceTest.java | 19 public void slice() { in slice() method in SliceTest 21 assertThat(slice.empty()).isFalse(); in slice() 22 assertThat(slice.size()).isEqualTo(9); in slice() 37 try (final Slice slice = new Slice("abc")) { in sliceClear() argument 39 slice.clear(); in sliceClear() 40 assertThat(slice.toString()).isEmpty(); in sliceClear() 47 try (final Slice slice = new Slice("abc")) { in sliceRemovePrefix() argument 49 slice.removePrefix(1); in sliceRemovePrefix() 50 assertThat(slice.toString()).isEqualTo("bc"); in sliceRemovePrefix() 56 try (final Slice slice = new Slice("abc"); in sliceEquals() argument [all …]
|
| /rocksdb-6.9/db/blob/ |
| D | blob_index.h | 86 Status DecodeFrom(Slice slice) { in DecodeFrom() argument 88 assert(slice.size() > 0); in DecodeFrom() 89 type_ = static_cast<Type>(*slice.data()); in DecodeFrom() 95 slice = Slice(slice.data() + 1, slice.size() - 1); in DecodeFrom() 97 if (!GetVarint64(&slice, &expiration_)) { in DecodeFrom() 102 value_ = slice; in DecodeFrom() 104 if (GetVarint64(&slice, &file_number_) && GetVarint64(&slice, &offset_) && in DecodeFrom() 105 GetVarint64(&slice, &size_) && slice.size() == 1) { in DecodeFrom() 106 compression_ = static_cast<CompressionType>(*slice.data()); in DecodeFrom()
|
| D | blob_file_addition_test.cc | 66 Slice slice(str); in TEST_F() local 71 const Status s = blob_file_addition.DecodeFrom(&slice); in TEST_F() 78 slice = str; in TEST_F() 81 const Status s = blob_file_addition.DecodeFrom(&slice); in TEST_F() 88 slice = str; in TEST_F() 91 const Status s = blob_file_addition.DecodeFrom(&slice); in TEST_F() 98 slice = str; in TEST_F() 101 const Status s = blob_file_addition.DecodeFrom(&slice); in TEST_F() 108 slice = str; in TEST_F() 118 slice = str; in TEST_F() [all …]
|
| D | blob_file_garbage_test.cc | 59 Slice slice(str); in TEST_F() local 64 const Status s = blob_file_garbage.DecodeFrom(&slice); in TEST_F() 71 slice = str; in TEST_F() 74 const Status s = blob_file_garbage.DecodeFrom(&slice); in TEST_F() 81 slice = str; in TEST_F() 84 const Status s = blob_file_garbage.DecodeFrom(&slice); in TEST_F() 91 slice = str; in TEST_F() 94 const Status s = blob_file_garbage.DecodeFrom(&slice); in TEST_F() 101 slice = str; in TEST_F() 104 const Status s = blob_file_garbage.DecodeFrom(&slice); in TEST_F()
|
| /rocksdb-6.9/tools/dump/ |
| D | db_dump_tool.cc | 139 ROCKSDB_NAMESPACE::Slice slice; in Run() local 155 status = dumpfile->Read(8, &slice, scratch8); in Run() 156 if (!status.ok() || slice.size() != 8 || in Run() 157 memcmp(slice.data(), magicstr, 8) != 0) { in Run() 163 status = dumpfile->Read(8, &slice, scratch8); in Run() 164 if (!status.ok() || slice.size() != 8 || in Run() 165 memcmp(slice.data(), versionstr, 8) != 0) { in Run() 171 status = dumpfile->Read(4, &slice, scratch8); in Run() 172 if (!status.ok() || slice.size() != 4) { in Run() 203 status = dumpfile->Read(4, &slice, scratch8); in Run() [all …]
|
| /rocksdb-6.9/utilities/merge_operators/ |
| D | sortlist.cc | 19 for (Slice slice : merge_in.operand_list) { in FullMergeV2() local 21 MakeVector(right, slice); in FullMergeV2() 57 void SortList::MakeVector(std::vector<int>& operand, Slice slice) const { in MakeVector() 59 const char* begin = slice.data_; in MakeVector() 60 while (*slice.data_ != ',' && *slice.data_) slice.data_++; in MakeVector() 61 operand.push_back(std::stoi(std::string(begin, slice.data_))); in MakeVector() 62 } while (0 != *slice.data_++); in MakeVector()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_dump_tool.cc | 116 Slice slice; in DumpBlobLogHeader() local 117 Status s = Read(0, BlobLogHeader::kSize, &slice); in DumpBlobLogHeader() 122 s = header.DecodeFrom(slice); in DumpBlobLogHeader() 154 Slice slice; in DumpBlobLogFooter() local 156 Status s = Read(*footer_offset, BlobLogFooter::kSize, &slice); in DumpBlobLogFooter() 161 s = footer.DecodeFrom(slice); in DumpBlobLogFooter() 183 Slice slice; in DumpRecord() local 184 Status s = Read(*offset, BlobLogRecord::kHeaderSize, &slice); in DumpRecord() 189 s = record.DecodeHeaderFrom(slice); in DumpRecord() 201 s = Read(*offset, static_cast<size_t>(key_size + value_size), &slice); in DumpRecord() [all …]
|
| D | blob_log_reader.cc | 27 Status Reader::ReadSlice(uint64_t size, Slice* slice, char* buf) { in ReadSlice() argument 30 file_->Read(next_byte_, static_cast<size_t>(size), slice, buf, nullptr); in ReadSlice() 35 RecordTick(statistics_, BLOB_DB_BLOB_FILE_BYTES_READ, slice->size()); in ReadSlice() 36 if (slice->size() != size) { in ReadSlice()
|
| D | blob_log_format.h | 62 Status DecodeFrom(Slice slice); 86 Status DecodeFrom(Slice slice);
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_filter_block_test.cc | 59 Slice slice(builder.Finish()); in TEST_F() local 60 ASSERT_EQ("\\x00\\x00\\x00\\x00\\x0b", EscapeString(slice)); in TEST_F() 63 new BlockContents(slice), nullptr /* cache */, nullptr /* cache_handle */, in TEST_F() 89 Slice slice(builder.Finish()); in TEST_F() local 92 new BlockContents(slice), nullptr /* cache */, nullptr /* cache_handle */, in TEST_F() 151 Slice slice(builder.Finish()); in TEST_F() local 154 new BlockContents(slice), nullptr /* cache */, nullptr /* cache_handle */, in TEST_F() 249 Slice slice(builder->Finish()); in TEST_F() local 250 ASSERT_EQ("\\x00\\x00\\x00\\x00\\x0b", EscapeString(slice)); in TEST_F() 282 Slice slice(builder->Finish()); in TEST_F() local [all …]
|
| D | full_filter_block_test.cc | 114 Slice slice = builder.Finish(); in TEST_F() local 115 ASSERT_EQ("", EscapeString(slice)); in TEST_F() 119 BlockContents(slice)), in TEST_F() 138 Slice slice = builder.Finish(); in TEST_F() local 142 BlockContents(slice)), in TEST_F() 190 Slice slice = builder.Finish(); in TEST_F() local 191 ASSERT_EQ("", EscapeString(slice)); in TEST_F() 195 BlockContents(slice)), in TEST_F() 285 Slice slice = builder.Finish(); in TEST_F() local 289 BlockContents(slice)), in TEST_F()
|
| D | partitioned_filter_block_test.cc | 103 BlockHandle Write(const Slice& slice) { in Write() argument 104 BlockHandle bh(last_offset + 1, slice.size()); in Write() 105 blooms[bh.offset()] = slice.ToString(); in Write() 139 Slice slice; in NewReader() local 141 slice = builder->Finish(bh, &status); in NewReader() 142 bh = Write(slice); in NewReader() 152 BlockContents contents(slice); in NewReader() 276 Slice slice = Slice(next_key.data(), next_key.size()); in CutABlock() local 277 builder->AddIndexEntry(&key, &slice, dont_care_block_handle); in CutABlock()
|
| D | partitioned_filter_block.h | 102 const Slice& slice, const SliceTransform* prefix_extractor, 106 bool MayMatch(const Slice& slice, const SliceTransform* prefix_extractor,
|
| /rocksdb-6.9/util/ |
| D | slice.cc.d | 1 util/slice.cc.d util/slice.o: util/slice.cc \ 3 include/rocksdb/slice.h include/rocksdb/cleanable.h util/string_util.h
|
| D | murmurhash.h | 38 size_t operator()(const Slice& slice) const { in operator() 39 return MurmurHash(slice.data(), static_cast<int>(slice.size()), 0); in operator()
|
| D | coding.h | 68 extern Slice GetSliceUntil(Slice* slice, char delimiter); 435 inline Slice GetSliceUntil(Slice* slice, char delimiter) { in GetSliceUntil() argument 437 for (len = 0; len < slice->size() && slice->data()[len] != delimiter; ++len) { in GetSliceUntil() 441 Slice ret(slice->data(), len); in GetSliceUntil() 442 slice->remove_prefix(len + ((len < slice->size()) ? 1 : 0)); in GetSliceUntil()
|
| D | slice_test.cc | 24 const PinnableSlice& slice) { in AssertSameData() argument 26 got.assign(slice.data(), slice.size()); in AssertSameData()
|
| /rocksdb-6.9/file/ |
| D | file_util.cc | 52 Slice slice; in CopyFile() local 55 s = src_reader->Read(bytes_to_read, &slice, buffer); in CopyFile() 59 if (slice.size() == 0) { in CopyFile() 62 s = dest_writer->Append(slice); in CopyFile() 66 size -= slice.size(); in CopyFile()
|
| /rocksdb-6.9/table/ |
| D | cleanable_test.cc | 224 Slice slice(const_str); in TEST_F() local 225 value.PinSlice(slice, Multiplier, &res, &n2); in TEST_F() 236 Slice slice(const_str); in TEST_F() local 240 value.PinSlice(slice, &c1); in TEST_F() 253 Slice slice(const_str); in TEST_F() local 254 value.PinSelf(slice); in TEST_F()
|
| /rocksdb-6.9/memtable/ |
| D | hash_skiplist_rep.cc | 67 inline size_t GetHash(const Slice& slice) const { in GetHash() 68 return MurmurHash(slice.data(), static_cast<int>(slice.size()), 0) % in GetHash() 74 inline Bucket* GetBucket(const Slice& slice) const { in GetBucket() 75 return GetBucket(GetHash(slice)); in GetBucket()
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 230 virtual Status Append(const Slice& slice) override { in Append() argument 231 contents_.append(slice.data(), slice.size()); in Append() 314 virtual Status Append(const Slice& slice) override { in Append() argument 315 contents_.append(slice.data(), slice.size()); in Append() 579 virtual Status Append(const Slice& slice) override { in Append() argument 580 contents_->append(slice.data(), slice.size()); in Append()
|
| /rocksdb-6.9/db/ |
| D | log_writer.cc | 51 IOStatus Writer::AddRecord(const Slice& slice) { in AddRecord() argument 52 const char* ptr = slice.data(); in AddRecord() 53 size_t left = slice.size(); in AddRecord()
|
| D | merge_test.cc | 140 Slice slice(buf, sizeof(value)); in set() local 141 auto s = db_->Put(put_option_, key, slice); in set() 231 Slice slice(encoded, sizeof(uint64_t)); in add() local 232 auto s = db_->Merge(merge_option_, key, slice); in add()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | slice.h | 176 inline void PinSelf(const Slice& slice) { in PinSelf() argument 178 buf_->assign(slice.data(), slice.size()); in PinSelf()
|