Home
last modified time | relevance | path

Searched refs:values (Results 1 – 25 of 140) sorted by relevance

123456

/rocksdb-6.9/db/
Ddb_merge_operand_test.cc84 ASSERT_EQ(values[0], "x"); in TEST_F()
85 ASSERT_EQ(values[1], "b"); in TEST_F()
86 ASSERT_EQ(values[2], "c"); in TEST_F()
87 ASSERT_EQ(values[3], "d"); in TEST_F()
107 ASSERT_EQ(values[0], "c"); in TEST_F()
108 ASSERT_EQ(values[1], "k"); in TEST_F()
109 ASSERT_EQ(values[2], "s"); in TEST_F()
120 ASSERT_EQ(values[0], "q"); in TEST_F()
121 ASSERT_EQ(values[1], "w"); in TEST_F()
122 ASSERT_EQ(values[2], "e"); in TEST_F()
[all …]
Ddb_basic_test.cc190 &values); in TEST_F()
1280 ASSERT_EQ(std::string(values[5].data(), values[5].size()), "v1"); in TEST_F()
1281 ASSERT_EQ(std::string(values[4].data(), values[4].size()), "v2"); in TEST_F()
1282 ASSERT_EQ(std::string(values[3].data(), values[3].size()), "v3"); in TEST_F()
1283 ASSERT_EQ(std::string(values[1].data(), values[1].size()), "v5"); in TEST_F()
1321 ASSERT_EQ(std::string(values[0].data(), values[0].size()), "v1"); in TEST_F()
1322 ASSERT_EQ(std::string(values[1].data(), values[1].size()), "v2"); in TEST_F()
1323 ASSERT_EQ(std::string(values[2].data(), values[2].size()), "v3"); in TEST_F()
1324 ASSERT_EQ(std::string(values[4].data(), values[4].size()), "v5"); in TEST_F()
1598 ASSERT_EQ(std::string(values[4].data(), values[4].size()), "v1"); in TEST_P()
[all …]
Dmerge_helper_test.cc68 ASSERT_EQ(test::EncodeInt(4U), merge_helper_->values()[0]); in TEST_F()
70 ASSERT_EQ(1U, merge_helper_->values().size()); in TEST_F()
85 ASSERT_EQ(test::EncodeInt(8U), merge_helper_->values()[0]); in TEST_F()
87 ASSERT_EQ(1U, merge_helper_->values().size()); in TEST_F()
105 ASSERT_EQ(1U, merge_helper_->values().size()); in TEST_F()
120 ASSERT_EQ("v", merge_helper_->values()[0]); in TEST_F()
122 ASSERT_EQ("v2", merge_helper_->values()[1]); in TEST_F()
124 ASSERT_EQ(2U, merge_helper_->values().size()); in TEST_F()
138 ASSERT_EQ(1U, merge_helper_->values().size()); in TEST_F()
153 ASSERT_EQ(1U, merge_helper_->values().size()); in TEST_F()
[all …]
Ddb_compaction_test.cc296 std::vector<std::string> values; in TEST_P() local
344 std::vector<std::string> values; in TEST_P() local
409 std::vector<std::string> values; in TEST_F() local
556 std::vector<std::string> values; in TEST_P() local
749 std::vector<std::string> values; in TEST_P() local
868 std::vector<std::string> values; in TEST_P() local
1106 std::vector<std::string> values; in TEST_P() local
1211 values.clear(); in TEST_P()
1916 std::vector<std::string> values; in TEST_P() local
2759 std::vector<std::string> values; in TEST_P() local
[all …]
/rocksdb-6.9/db_stress_tool/
Dbatched_ops_stress.cc40 values[i] += v.ToString(); in TestPut()
122 std::string values[10]; in TestGet() local
136 values[i] = ""; in TestGet()
141 values[i] = ""; in TestGet()
144 values[i] = from_db; in TestGet()
160 if (values[i] != values[0]) { in TestGet()
218 str.assign(values[i].data(), values[i].size()); in TestMultiGet()
219 values[i].Reset(); in TestMultiGet()
229 if (values[i] != values[0]) { in TestMultiGet()
284 std::string values[10]; in TestPrefixScan() local
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder_test.cc42 const std::vector<std::string>& values, in CheckFileContents() argument
82 ASSERT_EQ(values.empty() ? 0 : values[0].size(), value_len_found); in CheckFileContents()
187 std::vector<std::string> values; in TEST_F() local
189 values = {"v01", "v02", "v03", "v04"}; in TEST_F()
191 values = {"", "", "", ""}; in TEST_F()
221 builder.Add(Slice(keys[i]), Slice(values[i])); in TEST_F()
271 builder.Add(Slice(keys[i]), Slice(values[i])); in TEST_F()
283 CheckFileContents(keys, values, expected_locations, in TEST_F()
321 builder.Add(Slice(keys[i]), Slice(values[i])); in TEST_F()
375 builder.Add(Slice(keys[i]), Slice(values[i])); in TEST_F()
[all …]
Dcuckoo_table_reader_test.cc82 values.clear(); in SetUp()
83 values.resize(num_items); in SetUp()
130 ASSERT_STREQ(values[i].c_str(), value.data()); in CreateCuckooFileAndCheckReader()
162 ASSERT_TRUE(Slice(values[cnt]) == it->value()); in CheckIterator()
202 ASSERT_TRUE(values[num_items/2] == it->value()); in CheckIterator()
209 std::vector<std::string> values; member in ROCKSDB_NAMESPACE::CuckooReaderTest
233 values[i] = "value" + NumToStr(i); in TEST_F()
261 values[i] = "value" + NumToStr(i); in TEST_F()
288 values[i] = "value" + NumToStr(i); in TEST_F()
308 values[i] = "value" + NumToStr(i); in TEST_F()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRocksMemEnvTest.java28 final byte[][] values = { in memEnvFillAndReopen()
44 db.put(keys[i], values[i]); in memEnvFillAndReopen()
49 assertThat(db.get(keys[i])).isEqualTo(values[i]); in memEnvFillAndReopen()
58 assertThat(iterator.value()).isEqualTo(values[i]); in memEnvFillAndReopen()
70 assertThat(db.get(keys[i])).isEqualTo(values[i]); in memEnvFillAndReopen()
81 assertThat(db.get(keys[i])).isEqualTo(values[i]); in memEnvFillAndReopen()
102 final byte[][] values = { in multipleDatabaseInstances()
118 db.put(keys[i], values[i]); in multipleDatabaseInstances()
119 otherDb.put(otherKeys[i], values[i]); in multipleDatabaseInstances()
126 assertThat(db.get(keys[i])).isEqualTo(values[i]); in multipleDatabaseInstances()
[all …]
DTransactionTest.java92 final byte values[][] = new byte[][] { in multiGetForUpdate_cf_conflict()
103 txn.put(testCf, keys[0], values[0]); in multiGetForUpdate_cf_conflict()
104 txn.put(testCf, keys[1], values[1]); in multiGetForUpdate_cf_conflict()
105 assertThat(txn.multiGet(readOptions, cfList, keys)).isEqualTo(values); in multiGetForUpdate_cf_conflict()
112 .isEqualTo(values); in multiGetForUpdate_cf_conflict()
134 final byte values[][] = new byte[][] { in multiGetForUpdate_conflict()
142 txn.put(keys[0], values[0]); in multiGetForUpdate_conflict()
143 txn.put(keys[1], values[1]); in multiGetForUpdate_conflict()
144 assertThat(txn.multiGet(readOptions, keys)).isEqualTo(values); in multiGetForUpdate_conflict()
151 .isEqualTo(values); in multiGetForUpdate_conflict()
DAbstractTransactionTest.java212 final byte values[][] = new byte[][] { in multiGetPut_cf()
224 txn.put(testCf, keys[0], values[0]); in multiGetPut_cf()
225 txn.put(testCf, keys[1], values[1]); in multiGetPut_cf()
235 final byte values[][] = new byte[][] { in multiGetPut()
245 txn.put(keys[0], values[0]); in multiGetPut()
246 txn.put(keys[1], values[1]); in multiGetPut()
283 final byte values[][] = new byte[][] { in multiGetForUpdate_cf()
299 .isEqualTo(values); in multiGetForUpdate_cf()
308 final byte values[][] = new byte[][]{ in multiGetForUpdate()
317 txn.put(keys[0], values[0]); in multiGetForUpdate()
[all …]
DOptimisticTransactionTest.java100 final byte values[][] = new byte[][] { in multiGetForUpdate_cf_conflict()
111 txn.put(testCf, keys[0], values[0]); in multiGetForUpdate_cf_conflict()
112 txn.put(testCf, keys[1], values[1]); in multiGetForUpdate_cf_conflict()
113 assertThat(txn.multiGet(readOptions, cfList, keys)).isEqualTo(values); in multiGetForUpdate_cf_conflict()
120 .isEqualTo(values); in multiGetForUpdate_cf_conflict()
147 final byte values[][] = new byte[][] { in multiGetForUpdate_conflict()
155 txn.put(keys[0], values[0]); in multiGetForUpdate_conflict()
156 txn.put(keys[1], values[1]); in multiGetForUpdate_conflict()
157 assertThat(txn.multiGet(readOptions, keys)).isEqualTo(values); in multiGetForUpdate_conflict()
164 .isEqualTo(values); in multiGetForUpdate_conflict()
/rocksdb-6.9/table/block_based/
Dblock_test.cc67 values->emplace_back(RandomString(&rnd, 100)); in GenerateRandomKVs()
80 std::vector<std::string> values; in TEST_F() local
84 GenerateRandomKVs(&keys, &values, 0, num_records); in TEST_F()
87 builder.Add(keys[i], values[i]); in TEST_F()
109 ASSERT_EQ(v.ToString().compare(values[count]), 0); in TEST_F()
139 (*builder)->Add(keys[i], values[i]); in GetBlockContents()
172 ASSERT_EQ(v.ToString().compare(values[i]), 0); in CheckBlockContents()
190 std::vector<std::string> values; in TEST_F() local
206 std::vector<std::string> values; in TEST_F() local
360 std::vector<std::string> values; in TEST_F() local
[all …]
/rocksdb-6.9/util/
Dcoding_test.cc118 std::vector<uint64_t> values; in TEST() local
120 values.push_back(0); in TEST()
121 values.push_back(100); in TEST()
122 values.push_back(~static_cast<uint64_t>(0)); in TEST()
123 values.push_back(~static_cast<uint64_t>(0) - 1); in TEST()
127 values.push_back(power); in TEST()
128 values.push_back(power-1); in TEST()
129 values.push_back(power+1); in TEST()
133 for (unsigned int i = 0; i < values.size(); i++) { in TEST()
134 PutVarint64(&s, values[i]); in TEST()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DAbstractMutableOptions.java13 private final String[] values; field in AbstractMutableOptions
21 protected AbstractMutableOptions(final String[] keys, final String[] values) { in AbstractMutableOptions() argument
23 this.values = values; in AbstractMutableOptions()
31 return values; in getValues()
47 .append(values[i]); in toString()
80 protected abstract T build(final String[] keys, final String[] values); in build() argument
84 final String values[] = new String[options.size()]; in build() local
89 values[i] = option.getValue().asString(); in build()
93 return build(keys, values); in build()
DMutableColumnFamilyOptions.java22 final String[] values) { in MutableColumnFamilyOptions() argument
23 super(keys, values); in MutableColumnFamilyOptions()
156 for(final MutableColumnFamilyOptionKey key : MemtableOption.values()) {
160 for(final MutableColumnFamilyOptionKey key : CompactionOption.values()) {
164 for(final MutableColumnFamilyOptionKey key : MiscOption.values()) {
185 final String[] values) { in build() argument
186 return new MutableColumnFamilyOptions(keys, values); in build()
DMutableDBOptions.java22 private MutableDBOptions(final String[] keys, final String[] values) { in MutableDBOptions() argument
23 super(keys, values); in MutableDBOptions()
117 for(final MutableDBOptionKey key : DBOption.values()) {
138 final String[] values) { in build() argument
139 return new MutableDBOptions(keys, values); in build()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java222 for (final TickerType statsType : TickerType.values()) { in main()
234 for (final HistogramType histogramType : HistogramType.values()) { in main()
287 Map<byte[], byte[]> values = db.multiGet(keys); in main() local
288 assert (values.size() == keys.size()); in main()
289 for (final byte[] value1 : values.values()) { in main()
293 values = db.multiGet(new ReadOptions(), keys); in main()
294 assert (values.size() == keys.size()); in main()
295 for (final byte[] value1 : values.values()) { in main()
/rocksdb-6.9/tools/advisor/advisor/
Dini_parser.py68 values = IniParser.get_list_from_value(value)
69 if len(values) == 1:
71 return (key, values)
75 values = value.strip().split(':')
76 return values
Ddb_timeseries_parser.py109 agg_val = max(list(self.keys_ts[entity][stat].values()))
111 agg_val = min(list(self.keys_ts[entity][stat].values()))
113 values = list(self.keys_ts[entity][stat].values())
114 agg_val = sum(values) / len(values)
Ddb_options_parser.py54 def get_option_str(key, values): argument
57 if values:
62 if isinstance(values, list):
63 for value in values:
69 option_str += str(values)
283 values = self.options_dict[section][col_fam][option]
285 OptionsSpecParser.get_option_str(option, values) +
/rocksdb-6.9/tools/advisor/test/
Dtest_rule_parser.py64 for cond in conditions_dict.values():
66 for rule in rules_dict.values():
81 for cond in conditions_dict.values():
86 for rule in rules_dict.values():
93 self.assertIn(rule, rules_dict.values())
121 for cond in conditions_dict.values():
123 for rule in rules_dict.values():
/rocksdb-6.9/include/rocksdb/
Ddb.h480 keys, values); in MultiGet()
499 keys, values, timestamps); in MultiGet()
524 PinnableSlice* values, Status* statuses,
538 values->PinSelf(value);
539 values++;
562 values->PinSelf(value);
563 values++;
602 values->PinSelf(value);
603 values++;
624 values->PinSelf(value);
[all …]
/rocksdb-6.9/docs/_posts/
D2017-05-14-core-local-stats.markdown10 Until RocksDB 4.12, ticker/histogram statistics were implemented with std::atomic values shared acr…
40 …atistics use thread-local storage. Each thread has a local set of atomic values that no other thre…
42 …values. This adds some overhead, which may pass unnoticed if statistics are queried infrequently. …
77 …o thread-local, each core updates only its local values, thus avoiding cache line bouncing. Local …
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.h89 std::vector<std::string>* values) override;
93 std::vector<std::string>* values) override { in MultiGet() argument
96 keys, values); in MultiGet()
100 const size_t num_keys, const Slice* keys, PinnableSlice* values,
108 std::vector<std::string>* values) override;
112 std::vector<std::string>* values) override { in MultiGetForUpdate() argument
116 keys, values); in MultiGetForUpdate()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h206 const std::vector<Slice>& keys, std::vector<std::string>* values) = 0;
210 std::vector<std::string>* values) = 0;
218 PinnableSlice* values, Status* statuses,
221 statuses[i] = Get(options, column_family, keys[i], &values[i]);
285 const std::vector<Slice>& keys, std::vector<std::string>* values) = 0;
289 std::vector<std::string>* values) = 0;

123456