Home
last modified time | relevance | path

Searched defs:data (Results 1 – 25 of 96) sorted by relevance

1234

/rocksdb-6.9/monitoring/
Dthread_status_updater.cc47 auto* data = Get(); in SetColumnFamilyInfoKey() local
59 auto* data = GetLocalThreadStatus(); in GetColumnFamilyInfoKey() local
68 auto* data = GetLocalThreadStatus(); in SetThreadOperation() local
86 auto* data = GetLocalThreadStatus(); in SetThreadOperationProperty() local
95 auto* data = GetLocalThreadStatus(); in IncreaseThreadOperationProperty() local
103 auto* data = GetLocalThreadStatus(); in SetOperationStartTime() local
111 auto* data = GetLocalThreadStatus(); in ClearThreadOperation() local
123 auto* data = GetLocalThreadStatus(); in ClearThreadOperationProperties() local
134 auto* data = GetLocalThreadStatus(); in SetThreadOperationStage() local
142 auto* data = GetLocalThreadStatus(); in SetThreadState() local
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DDirectSlice.java65 public DirectSlice(final ByteBuffer data, final int length) { in DirectSlice()
77 public DirectSlice(final ByteBuffer data) { in DirectSlice()
82 private static ByteBuffer ensureDirect(final ByteBuffer data) { in ensureDirect()
122 private native static long createNewDirectSlice0(final ByteBuffer data, in createNewDirectSlice0()
124 private native static long createNewDirectSlice1(final ByteBuffer data); in createNewDirectSlice1()
DSlice.java83 public Slice(final byte[] data, final int offset) { in Slice()
93 public Slice(final byte[] data) { in Slice()
128 private native static long createNewSlice0(final byte[] data, in createNewSlice0()
130 private native static long createNewSlice1(final byte[] data); in createNewSlice1()
DTraceWriter.java21 void write(final Slice data) throws RocksDBException; in write()
/rocksdb-6.9/util/
Dhash.cc18 uint32_t Hash(const char* data, size_t n, uint32_t seed) { in Hash()
74 uint64_t Hash64(const char* data, size_t n, uint64_t seed) { in Hash64()
78 uint64_t Hash64(const char* data, size_t n) { in Hash64()
Dcrc32c_ppc.c29 static uint32_t crc32_vpmsum(uint32_t crc, unsigned char const *data, in crc32_vpmsum()
70 uint32_t crc32c_ppc(uint32_t crc, unsigned char const *data, unsigned len) { in crc32c_ppc()
90 uint32_t crc32c_ppc(uint32_t crc, unsigned char const *data, unsigned len) { in crc32c_ppc()
Dmurmurhash.cc38 const uint64_t * data = (const uint64_t *)key; in MurmurHash64A() local
103 const unsigned char * data = (const unsigned char *)key; in MurmurHash2() local
154 const unsigned char * data = (const unsigned char *)key; in MurmurHashNeutral2() local
Dbloom_impl.h195 int num_probes, char *data) { in AddHash()
211 const char *data, in PrepareHash()
220 int num_probes, const char *data) { in HashMayMatch()
359 char *data) { in AddHash()
369 int num_probes, const char *data) { in HashMayMatch()
427 char *data, int log2_cache_line_bytes) { in AddHash()
445 const char *data, in PrepareHashMayMatch()
456 int num_probes, const char *data, in HashMayMatch()
Dhash.h38 inline uint64_t NPHash64(const char* data, size_t n, uint32_t seed) { in NPHash64()
44 inline uint64_t NPHash64(const char* data, size_t n) { in NPHash64()
Dcrc32c.h28 inline uint32_t Value(const char* data, size_t n) { in Value()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc314 std::map<std::string, std::string> data; in TEST_F() local
331 std::map<std::string, std::string> data; in TEST_F() local
357 std::map<std::string, std::string> data; in TEST_F() local
379 std::map<std::string, std::string> data; in TEST_F() local
451 std::map<std::string, std::string> data; in TEST_F() local
468 std::map<std::string, std::string> data; in TEST_F() local
502 std::map<std::string, std::string> data; in TEST_F() local
521 std::map<std::string, std::string> data; in TEST_F() local
543 std::map<std::string, std::string> data; in TEST_F() local
575 std::map<std::string, std::string> data; in TEST_F() local
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dvolatile_tier_impl.cc14 void VolatileCacheTier::DeleteCacheData(VolatileCacheTier::CacheData* data) { in DeleteCacheData()
41 Status VolatileCacheTier::Insert(const Slice& page_key, const char* data, in Insert()
Dpersistent_cache_tier.cc136 Status PersistentTieredCache::Insert(const Slice& page_key, const char* data, in Insert()
143 std::unique_ptr<char[]>* data, in Lookup()
Dblock_cache_tier_file.cc137 const char* data, const size_t data_size) { in Append()
167 bool CacheRecord::Deserialize(const Slice& data) { in Deserialize()
252 Slice data(scratch, lba.size_); in ParseRec() local
463 bool WriteableCacheFile::ReadBuffer(const LBA& lba, char* data) { in ReadBuffer()
593 Slice data(io.buf_->Data() + written, io_size_); in DispatchIO() local
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index.cc75 void DataBlockHashIndex::Initialize(const char* data, uint16_t size, in Initialize()
85 uint8_t DataBlockHashIndex::Lookup(const char* data, uint32_t map_offset, in Lookup()
Dfilter_policy.cc53 char* data = new char[len_with_metadata]; in Finish() local
101 void AddAllEntries(char* data, uint32_t len) { in AddAllEntries()
159 FastLocalBloomBitsReader(const char* data, int num_probes, uint32_t len_bytes) in FastLocalBloomBitsReader()
268 char* data = in Finish() local
350 char* data = new char[sz]; in ReserveSpace() local
370 inline void LegacyBloomBitsBuilder::AddHash(uint32_t h, char* data, in AddHash()
384 LegacyBloomBitsReader(const char* data, int num_probes, uint32_t num_lines, in LegacyBloomBitsReader()
Dblock.h163 const char* data() const { return data_; } in data() function
234 void InitializeBase(const Comparator* comparator, const char* data, in InitializeBase()
365 const char* data, uint32_t restarts, uint32_t num_restarts, in DataBlockIter()
375 const Comparator* user_comparator, const char* data, in Initialize()
495 const Comparator* user_comparator, const char* data, in Initialize()
/rocksdb-6.9/file/
Dwritable_file_writer.cc24 IOStatus WritableFileWriter::Append(const Slice& data) { in Append()
292 IOStatus WritableFileWriter::WriteBuffered(const char* data, size_t size) { in WriteBuffered()
347 void WritableFileWriter::CalculateFileChecksum(const Slice& data) { in CalculateFileChecksum()
/rocksdb-6.9/db/
Ddb_encryption_test.cc54 Slice data; in TEST_F() local
105 Slice data; in TEST_F() local
/rocksdb-6.9/table/
Dpersistent_cache_helper.cc14 const char* data, const size_t size) { in InsertRawPage()
93 std::unique_ptr<char[]> data; in LookupUncompressedPage() local
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc34 Status FileTraceReader::Read(std::string* data) { in Read()
85 Status FileTraceWriter::Write(const Slice& data) { in Write()
/rocksdb-6.9/java/rocksjni/
Dslice.cc133 jbyteArray data, jint offset) { in Java_org_rocksdb_Slice_createNewSlice0()
156 jbyteArray data) { in Java_org_rocksdb_Slice_createNewSlice1()
186 const jbyteArray data = env->NewByteArray(len); in Java_org_rocksdb_Slice_data0() local
255 jobject data, in Java_org_rocksdb_DirectSlice_createNewDirectSlice0()
280 jobject data) { in Java_org_rocksdb_DirectSlice_createNewDirectSlice1()
/rocksdb-6.9/env/
Denv_encryption.cc198 Status Append(const Slice& data) override { in Append()
224 Status PositionedAppend(const Slice& data, uint64_t offset) override { in PositionedAppend()
329 Status Write(uint64_t offset, const Slice& data) override { in Write()
693 Status BlockAccessCipherStream::Encrypt(uint64_t fileOffset, char *data, size_t dataSize) { in Encrypt()
738 Status BlockAccessCipherStream::Decrypt(uint64_t fileOffset, char *data, size_t dataSize) { in Decrypt()
791 Status ROT13BlockCipher::Encrypt(char *data) { in Encrypt()
800 Status ROT13BlockCipher::Decrypt(char *data) { in Decrypt()
812 Status CTRCipherStream::EncryptBlock(uint64_t blockIndex, char *data, char* scratch) { in EncryptBlock()
834 Status CTRCipherStream::DecryptBlock(uint64_t blockIndex, char *data, char* scratch) { in DecryptBlock()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTypes.java21 public static int byteToInt(final byte data[]) { in byteToInt()
/rocksdb-6.9/third-party/folly/folly/synchronization/
DParkingLot.h176 ParkResult park(const Key key, D&& data, ToPark&& toPark, PreWait&& preWait) { in park()
208 D&& data, in park_for()
245 D&& data, in park_until()

1234