Home
last modified time | relevance | path

Searched refs:value (Results 1 – 25 of 436) sorted by relevance

12345678910>>...18

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DMutableOptionValue.java21 this.value = value; in MutableOptionValueObject()
25 return value; in asObject()
60 super(value); in MutableOptionStringValue()
98 this.value = value; in MutableOptionDoubleValue()
113 if(value > Integer.MAX_VALUE || value < Integer.MIN_VALUE) { in asInt()
128 if(value > Integer.MAX_VALUE || value < Integer.MIN_VALUE) { in asIntArray()
151 this.value = value; in MutableOptionLongValue()
156 if(value > Double.MAX_VALUE || value < Double.MIN_VALUE) { in asDouble()
208 this.value = value; in MutableOptionIntValue()
213 if(value > Double.MAX_VALUE || value < Double.MIN_VALUE) { in asDouble()
[all …]
DAbstractMutableOptions.java109 if(value == null) { in getDouble()
112 return value.asDouble(); in getDouble()
128 if(value == null) { in getLong()
131 return value.asLong(); in getLong()
147 if(value == null) { in getInt()
150 return value.asInt(); in getInt()
166 if(value == null) { in getBoolean()
169 return value.asBoolean(); in getBoolean()
185 if(value == null) { in getIntArray()
188 return value.asIntArray(); in getIntArray()
[all …]
DSstFileWriter.java74 public void add(final Slice key, final Slice value) in add() argument
133 assert key.isDirect() && value.isDirect(); in put()
134 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
135 value.remaining()); in put()
137 value.position(value.limit()); in put()
150 put(nativeHandle_, key, value); in put()
163 public void merge(final Slice key, final Slice value) in merge() argument
178 public void merge(final byte[] key, final byte[] value) in merge() argument
180 merge(nativeHandle_, key, value); in merge()
268 final byte[] value) throws RocksDBException; in put() argument
[all …]
DAbstractWriteBatch.java24 put(nativeHandle_, key, key.length, value, value.length); in put()
29 byte[] value) throws RocksDBException { in put() argument
30 put(nativeHandle_, key, key.length, value, value.length, in put()
36 merge(nativeHandle_, key, key.length, value, value.length); in merge()
41 byte[] value) throws RocksDBException { in merge() argument
42 merge(nativeHandle_, key, key.length, value, value.length, in merge()
61 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
62 value.remaining(), 0); in put()
64 value.position(value.limit()); in put()
71 putDirect(nativeHandle_, key, key.position(), key.remaining(), value, value.position(), in put()
[all …]
DStatus.java75 private final byte value; field in Status.Code
77 Code(final byte value) { in Code() argument
78 this.value = value; in Code()
81 public static Code getCode(final byte value) { in getCode() argument
83 if (code.value == value){ in getCode()
97 return value; in getValue()
113 private final byte value; field in Status.SubCode
115 SubCode(final byte value) { in SubCode() argument
116 this.value = value; in SubCode()
121 if (subCode.value == value){ in getSubCode()
[all …]
DTransaction.java673 put(nativeHandle_, key, key.length, value, value.length, in put()
705 put(nativeHandle_, key, key.length, value, value.length, in put()
734 put(nativeHandle_, key, key.length, value, value.length); in put()
836 merge(nativeHandle_, key, key.length, value, value.length, in merge()
868 merge(nativeHandle_, key, key.length, value, value.length, in merge()
897 merge(nativeHandle_, key, key.length, value, value.length); in merge()
1233 putUntracked(nativeHandle_, key, key.length, value, value.length, in putUntracked()
1259 putUntracked(nativeHandle_, key, key.length, value, value.length); in putUntracked()
1324 mergeUntracked(nativeHandle_, key, key.length, value, value.length, in mergeUntracked()
1805 this.value = value; in TransactionState()
[all …]
DRocksDB.java706 key, 0, key.length, value, 0, value.length); in put()
785 value.position(value.limit()); in put()
807 value.position(), value.remaining(), 0); in put()
809 value.position(value.limit()); in put()
1097 value, value.position(), value.remaining(), 0); in get()
1099 value.limit(Math.min(value.limit(), value.position() + result)); in get()
1130 value, value.position(), value.remaining(), columnFamilyHandle.nativeHandle_); in get()
1132 value.limit(Math.min(value.limit(), value.position() + result)); in get()
1449 key, 0, key.length, value, 0, value.length); in merge()
1538 key, 0, key.length, value, 0, value.length, in merge()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DCompactRangeOptionsTest.java22 boolean value = false; in exclusiveManualCompaction()
25 value = true; in exclusiveManualCompaction()
47 boolean value = false; in changeLevel()
50 value = true; in changeLevel()
58 int value = 2; in targetLevel() local
61 value = 3; in targetLevel()
69 int value = 2; in targetPathId() local
72 value = 3; in targetPathId()
83 value = true; in allowWriteStall()
91 int value = 2; in maxSubcompactions() local
[all …]
DBackupableDBOptionsTest.java63 isEqualTo(value); in shareTableFiles()
93 backupableDBOptions.setSync(value); in sync()
105 isEqualTo(value); in destroyOldData()
116 isEqualTo(value); in backupLogFiles()
127 isEqualTo(value); in backupRateLimit()
158 isEqualTo(value); in restoreRateLimit()
186 boolean value = rand.nextBoolean(); in shareFilesWithChecksum()
189 isEqualTo(value); in shareFilesWithChecksum()
197 final int value = rand.nextInt(); in maxBackgroundOperations() local
200 isEqualTo(value); in maxBackgroundOperations()
[all …]
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java254 batch.put(key, value); in runTask()
1004 return value; in parseValue()
1235 return value; in parseValue()
1314 return value; in parseValue()
1435 return value; in parseValue()
1473 return value; in parseValue()
1522 if (value.equals("1")) { in parseBoolean()
1569 pos += value.length; in RandomGenerator()
1586 System.arraycopy(value, 0, value, pos, in compressibleBytes()
1597 position_ += value.length; in generate()
[all …]
/rocksdb-6.9/util/
Dcoding.h89 *value = zigzagToI64(u); in GetVarsignedint64Ptr()
160 *value = result; in GetVarint32Ptr()
170 memcpy(buf, &value, sizeof(value)); in EncodeFixed16()
172 buf[0] = value & 0xff; in EncodeFixed16()
179 memcpy(buf, &value, sizeof(value)); in EncodeFixed32()
190 memcpy(buf, &value, sizeof(value)); in EncodeFixed64()
218 sizeof(value)); in PutFixed32()
229 sizeof(value)); in PutFixed64()
308 dst->append(value.data(), value.size()); in PutLengthPrefixedSlice()
459 *memory = value; in PutUnaligned()
[all …]
Dstring_util.cc90 char c = value[i]; in AppendEscapedStringTo()
269 if (value == "true" || value == "1") { in ParseBoolean()
271 } else if (value == "false" || value == "0") { in ParseBoolean()
308 char c = value[endchar]; in ParseUint64()
333 char c = value[endchar]; in ParseInt64()
358 char c = value[endchar]; in ParseInt()
372 return std::stod(value); in ParseDouble()
385 while (start < value.size()) { in ParseVectorInt()
399 *value = ""; in SerializeIntVector()
402 *value += ":"; in SerializeIntVector()
[all …]
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc80 string value; in TEST_P() local
109 string value; in TEST_P() local
144 string value; in TEST_P() local
179 string value; in TEST_P() local
220 string value; in TEST_P() local
237 string value; in TEST_P() local
277 string value; in TEST_P() local
446 string value; in TEST_P() local
475 string value; in TEST_P() local
583 string value; in TEST_P() local
[all …]
Dtransaction_test.cc264 string value; in TEST_P() local
2097 string value; in TEST_P() local
2579 string value; in TEST_P() local
2746 string value; in TEST_P() local
2835 string value; in TEST_P() local
2927 string value; in TEST_P() local
3003 string value; in TEST_P() local
3046 string value; in TEST_P() local
3284 string value; in TEST_P() local
3473 string value; in TEST_P() local
[all …]
Dwrite_unprepared_transaction_test.cc69 ASSERT_EQ(value, iter->value().ToString()); in TEST_P()
96 std::string value; in TEST_P() local
265 std::string value; in TEST_P() local
654 std::string value; in TEST_P() local
656 ASSERT_EQ(value, "a"); in TEST_P()
658 ASSERT_EQ(value, "b"); in TEST_P()
676 std::string value; in TEST_P() local
678 ASSERT_EQ(value, "a"); in TEST_P()
680 ASSERT_EQ(value, "a_untrack"); in TEST_P()
682 ASSERT_EQ(value, "b"); in TEST_P()
[all …]
/rocksdb-6.9/db/
Dinternal_stats.cc544 *value = buf; in HandleNumFilesAtLevel()
557 *value = ToString( in HandleCompressionRatioAtLevelPrefix()
568 value->append(buf); in HandleLevelStats()
596 DumpCFStats(value); in HandleCFStats()
613 DumpDBStats(value); in HandleDBStats()
863 *value = 0; in HandleActualDelayedWriteRate()
894 *value = std::min(*value, p.second->oldest_key_time); in HandleEstimateOldestKeyTime()
899 if (*value > 0) { in HandleEstimateOldestKeyTime()
903 return *value > 0 && *value < std::numeric_limits<uint64_t>::max(); in HandleEstimateOldestKeyTime()
966 value->append(buf); in DumpDBStats()
[all …]
Dinternal_stats.h51 bool (DBImpl::*handle_string_dbimpl)(std::string* value);
355 cf_stats_value_[type] += value; in AddCFStats()
363 v.fetch_add(value, std::memory_order_relaxed);
365 v.store(v.load(std::memory_order_relaxed) + value,
404 void DumpDBStats(std::string* value);
412 void DumpCFStats(std::string* value);
413 void DumpCFStatsNoFileHistogram(std::string* value);
414 void DumpCFFileHistogram(std::string* value);
521 bool HandleStats(std::string* value, Slice suffix);
523 bool HandleCFStats(std::string* value, Slice suffix);
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc52 e.value = value.ToString(); in PutCF()
61 e.value = value.ToString(); in MergeCF()
70 e.value = ""; in DeleteCF()
111 ASSERT_EQ(e.value, write_entry.value.ToString()); in TestValueAsSecondaryIndexHelper()
134 ASSERT_EQ(v->value, write_entry.value.ToString()); in TestValueAsSecondaryIndexHelper()
214 ASSERT_EQ(v->value, write_entry.value.ToString()); in TestValueAsSecondaryIndexHelper()
257 ASSERT_EQ(e.value, write_entry.value); in TestValueAsSecondaryIndexHelper()
548 ASSERT_EQ(value, iter->value().ToString()); in AssertIter()
1349 ASSERT_EQ(value, iter->Entry().value.ToString()); in AssertValue()
1397 ASSERT_EQ(value, iter->value().ToString()); in AssertIterValue()
[all …]
/rocksdb-6.9/third-party/folly/folly/
DOptional.h213 return value(); in emplace()
223 return value(); in emplace()
237 swap(value(), that.value()); in swap()
252 Value& value() & { in value() function
288 return value();
291 return value();
301 return &value();
368 Value value; member
382 Value value; member
472 return a.value() == b.value();
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DWriteBatchGetter.java13 private byte[] value; field in WriteBatchGetter
20 return value; in getValue()
28 this.value = value; in put()
35 this.value = value; in put()
44 this.value = value; in merge()
51 this.value = value; in merge()
59 this.value = null; in delete()
66 this.value = null; in delete()
74 this.value = null; in singleDelete()
81 this.value = null; in singleDelete()
[all …]
DCapturingWriteBatchHandler.java31 final byte[] value) { in put() argument
37 events.add(new Event(Action.PUT, key, value)); in put()
42 final byte[] value) { in merge() argument
48 events.add(new Event(Action.MERGE, key, value)); in merge()
91 final byte[] value) { in putBlobIndex() argument
126 public final byte[] value; field in CapturingWriteBatchHandler.Event
129 this(action, 0, key, value); in Event()
133 final byte[] value) { in Event() argument
137 this.value = value; in Event()
153 ((value == null && event.value == null) in equals()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc255 ASSERT_EQ(iter1->value(), iter2->value()); in TEST_F()
428 value); in TEST_F()
432 value); in TEST_F()
500 value); in TEST_F()
553 value.clear(); in TEST_F()
666 ASSERT_EQ(it1->value(), it2->value()); in TEST_F()
674 ASSERT_EQ(it1->value(), value); in TEST_F()
679 ASSERT_EQ(it2->value(), value); in TEST_F()
727 ASSERT_EQ(it1->value(), it2->value()); in TEST_F()
735 ASSERT_EQ(it1->value(), value); in TEST_F()
[all …]
/rocksdb-6.9/tools/advisor/advisor/
Drule_parser.py19 def set_parameter(self, key, value): argument
36 def set_parameter(self, key, value): argument
42 if isinstance(value, str):
45 self.conditions = value
47 if isinstance(value, str):
242 self.option = value
325 self.regex = value
354 self.eval_expr = value
382 self.keys = [value]
384 self.keys = value
[all …]
/rocksdb-6.9/options/
Doptions_helper.cc197 for (auto value : in BuildColumnFamilyOptions() local
309 *value = ss.str(); in SerializeVectorCompressionType()
390 value); in ParseSingleStructOption()
595 assert(value); in SerializeSingleOptionHelper()
658 value); in SerializeSingleOptionHelper()
735 value); in SerializeSingleOptionHelper()
741 value); in SerializeSingleOptionHelper()
747 value); in SerializeSingleOptionHelper()
955 ParseInt(value.substr(start, value.size() - start)); in ParseCompressionOptions()
964 ParseInt(value.substr(start, value.size() - start)); in ParseCompressionOptions()
[all …]
/rocksdb-6.9/examples/
Dtransaction_example.cc31 std::string value; in main() local
44 s = txn->Get(read_options, "abc", &value); in main()
66 s = txn->Get(read_options, "xyz", &value); in main()
68 assert(value == "zzz"); in main()
78 assert(value == "def"); in main()
100 assert(value == "xyz"); in main()
106 assert(value == "def"); in main()
138 s = txn->Get(read_options, "x", &value); in main()
157 assert(value == "y1"); in main()
174 assert(value == "x"); in main()
[all …]

12345678910>>...18