Home
last modified time | relevance | path

Searched refs:OpType (Results 1 – 10 of 10) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSstFileWriterTest.java36 KeyValueWithOp(String key, String value, OpType opType) { in KeyValueWithOp()
50 OpType getOpType() { in getOpType()
56 private OpType opType;
144 keyValues.add(new KeyValueWithOp("key1", "value1", OpType.PUT)); in generateSstFileWithJavaComparator()
145 keyValues.add(new KeyValueWithOp("key2", "value2", OpType.PUT)); in generateSstFileWithJavaComparator()
148 keyValues.add(new KeyValueWithOp("key5", "", OpType.DELETE)); in generateSstFileWithJavaComparator()
157 keyValues.add(new KeyValueWithOp("key1", "value1", OpType.PUT)); in generateSstFileWithNativeComparator()
161 keyValues.add(new KeyValueWithOp("key5", "", OpType.DELETE)); in generateSstFileWithNativeComparator()
174 keyValues.add(new KeyValueWithOp("key6", "", OpType.DELETE)); in ingestSstFile()
175 keyValues.add(new KeyValueWithOp("key7", "", OpType.DELETE)); in ingestSstFile()
[all …]
DSstFileReaderTest.java26 KeyValueWithOp(String key, String value, OpType opType) { in KeyValueWithOp()
40 OpType getOpType() { in getOpType()
46 private OpType opType;
51 enum OpType { PUT, PUT_BYTES, MERGE, MERGE_BYTES, DELETE, DELETE_BYTES } enum in SstFileReaderTest
107 keyValues.add(new KeyValueWithOp("key1", "value1", OpType.PUT)); in readSstFile()
/rocksdb-6.9/include/rocksdb/
Drate_limiter.h19 enum class OpType { enum
67 Statistics* stats, OpType op_type) { in Request()
79 RateLimiter::OpType op_type);
94 virtual bool IsRateLimited(OpType op_type) { in IsRateLimited()
96 op_type == RateLimiter::OpType::kRead) || in IsRateLimited()
98 op_type == RateLimiter::OpType::kWrite)) { in IsRateLimited()
/rocksdb-6.9/util/
Drate_limiter_test.cc45 RateLimiter::OpType::kRead); in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
86 RateLimiter::OpType::kWrite); in TEST_F()
89 nullptr /* stats */, RateLimiter::OpType::kWrite); in TEST_F()
144 RateLimiter::OpType::kWrite); in TEST_F()
208 RateLimiter::OpType::kWrite); in TEST_F()
212 RateLimiter::OpType::kWrite); in TEST_F()
225 RateLimiter::OpType::kWrite); in TEST_F()
Drate_limiter.cc21 RateLimiter::OpType op_type) { in RequestToken()
/rocksdb-6.9/file/
Drandom_access_file_reader.cc52 Env::IOPriority::IO_LOW, stats_, RateLimiter::OpType::kRead); in Read()
99 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()
104 RateLimiter::OpType::kRead); in Read()
105 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()
Dwritable_file_writer.cc303 RateLimiter::OpType::kWrite); in WriteBuffered()
390 stats_, RateLimiter::OpType::kWrite); in WriteDirect()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4484 nullptr /* stats */, RateLimiter::OpType::kWrite); in DoWrite()
4859 RateLimiter::OpType::kRead); in ReadSequential()
4911 256, Env::IO_HIGH, nullptr /* stats */, RateLimiter::OpType::kRead); in ReadToRowCache()
4952 RateLimiter::OpType::kRead); in ReadReverse()
5180 RateLimiter::OpType::kRead); in MultiReadRandom()
5537 RateLimiter::OpType::kRead); in MixGraph()
5561 RateLimiter::OpType::kWrite); in MixGraph()
5872 nullptr /* stats */, RateLimiter::OpType::kWrite); in BGWriter()
6158 RateLimiter::OpType::kWrite); in UpdateRandom()
6746 1, Env::IO_HIGH, nullptr /* stats */, RateLimiter::OpType::kRead); in TimeSeriesReadOrDelete()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1499 RateLimiter::OpType::kWrite); in ThrottleLowPriWritesIfNeeded()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc1368 RateLimiter::OpType::kWrite); in CopyOrCreateFile()