| /rocksdb-6.9/db/ |
| D | db_basic_test.cc | 1725 std::vector<Status> statuses; in TEST_F() local
1733 statuses.resize(keys.size()); in TEST_F()
2149 std::vector<Status> statuses; in TEST_P() local
2158 statuses.resize(keys.size()); in TEST_P()
2190 statuses.resize(10); in TEST_P()
2195 statuses[i] = Status::OK(); in TEST_P()
2201 ASSERT_OK(statuses[i]); in TEST_P()
2212 statuses.resize(10); in TEST_P()
2223 ASSERT_OK(statuses[i]); in TEST_P()
2234 statuses.resize(5); in TEST_P()
[all …]
|
| D | compacted_db_impl.cc | 64 std::vector<Status> statuses(keys.size(), Status::NotFound()); in MultiGet() local
78 statuses[idx] = Status::OK(); in MultiGet()
83 return statuses; in MultiGet()
|
| D | version_builder.cc | 678 std::vector<Status> statuses; in LoadTableHandlers() local
685 statuses.emplace_back(Status::OK()); in LoadTableHandlers()
706 statuses[file_idx] = table_cache_->FindTable( in LoadTableHandlers()
728 for (const auto& s : statuses) { in LoadTableHandlers()
|
| D | db_test.cc | 529 auto statuses = in TEST_F() local
535 ASSERT_OK(statuses[0]); in TEST_F()
536 ASSERT_OK(statuses[1]); in TEST_F()
560 statuses = in TEST_F()
562 ASSERT_TRUE(statuses[0].ok()); in TEST_F()
564 ASSERT_TRUE(statuses[1].ok()); in TEST_F()
569 ASSERT_OK(statuses[2]); in TEST_F()
589 statuses = in TEST_F()
598 ASSERT_TRUE(statuses[2].ok()); in TEST_F()
2445 if (statuses[cf].ok()) { in MTThreadBody()
[all …]
|
| D | db_test_util.cc | 830 std::vector<Status> statuses(k.size()); in MultiGet() local
837 keys.data(), pin_values.data(), statuses.data()); in MultiGet()
843 for (unsigned int i = 0; i < statuses.size(); ++i) { in MultiGet()
844 if (statuses[i].IsNotFound()) { in MultiGet()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | cf_consistency_stress.cc | 212 std::vector<Status> statuses(num_keys); in TestMultiGet() local
220 statuses.data()); in TestMultiGet()
221 for (auto s : statuses) { in TestMultiGet()
234 return statuses; in TestMultiGet()
376 std::vector<Status> statuses(num, Status::OK()); in VerifyDb() local
387 statuses[idx] = iter->status(); in VerifyDb()
394 const auto& s = statuses[i]; in VerifyDb()
408 if (statuses[i].ok()) { in VerifyDb()
414 statuses[i].ToString().c_str()); in VerifyDb()
|
| D | no_batched_ops_stress.cc | 172 std::vector<Status> statuses(num_keys); in TestMultiGet() local
235 statuses.data()); in TestMultiGet()
239 statuses.data()); in TestMultiGet()
244 for (const auto& s : statuses) { in TestMultiGet()
260 return statuses; in TestMultiGet()
|
| D | batched_ops_stress.cc | 184 std::vector<Status> statuses(num_prefixes); in TestMultiGet() local
198 values.data(), statuses.data()); in TestMultiGet()
200 Status s = statuses[i]; in TestMultiGet()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 235 auto statuses = db_->MultiGet(options, column_family, keys, values); in MultiGet() local
237 if (!statuses[i].ok()) { in MultiGet()
240 statuses[i] = SanityCheckTimestamp((*values)[i]); in MultiGet()
241 if (!statuses[i].ok()) { in MultiGet()
244 statuses[i] = StripTS(&(*values)[i]); in MultiGet()
246 return statuses; in MultiGet()
|
| D | ttl_test.cc | 219 auto statuses = db_ttl_->MultiGet(ropts, keys, &values); in SimpleMultiGetTest() local
222 ASSERT_OK(statuses[i]); in SimpleMultiGetTest()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | db.h | 524 PinnableSlice* values, Status* statuses,
536 std::copy(status.begin(), status.end(), statuses);
547 Status* statuses, const bool /*sorted_input*/ = false) {
559 std::copy(status.begin(), status.end(), statuses);
588 PinnableSlice* values, Status* statuses,
600 std::copy(status.begin(), status.end(), statuses);
609 Status* statuses, const bool /*sorted_input*/ = false) {
621 std::copy(status.begin(), status.end(), statuses);
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 225 PinnableSlice* values, Status* statuses,
270 PinnableSlice* values, Status* statuses,
|
| D | transaction.h | 218 PinnableSlice* values, Status* statuses,
221 statuses[i] = Get(options, column_family, keys[i], &values[i]);
|
| D | stackable_db.h | 114 PinnableSlice* values, Status* statuses,
117 values, statuses, sorted_input);
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 931 Status* statuses, bool sorted_input) { in MultiGetFromBatchAndDB() argument
933 values, statuses, sorted_input, nullptr); in MultiGetFromBatchAndDB()
939 Status* statuses, bool sorted_input, ReadCallback* callback) { in MultiGetFromBatchAndDB() argument
957 Status* s = &statuses[i]; in MultiGetFromBatchAndDB()
986 /*timestamp*/ nullptr, &statuses[i]); in MultiGetFromBatchAndDB()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db.h | 174 PinnableSlice* /*values*/, Status* statuses,
177 statuses[i] = Status::NotSupported(
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn.cc | 46 PinnableSlice* values, Status* statuses, in MultiGet() argument
54 keys, values, statuses, sorted_input, in MultiGet()
60 statuses[i] = Status::TryAgain(); in MultiGet()
|
| D | write_prepared_txn.h | 63 PinnableSlice* values, Status* statuses,
|
| D | write_unprepared_txn.cc | 910 PinnableSlice* values, Status* statuses, in MultiGet() argument
918 keys, values, statuses, sorted_input, in MultiGet()
924 statuses[i] = Status::TryAgain(); in MultiGet()
|
| D | transaction_test.cc | 2804 std::vector<Status> statuses(keys.size()); in TEST_P() local
2808 ASSERT_TRUE(statuses[0].ok()); in TEST_P()
2810 ASSERT_TRUE(statuses[1].IsNotFound()); in TEST_P()
2811 ASSERT_TRUE(statuses[2].ok()); in TEST_P()
2814 ASSERT_TRUE(statuses[4].ok()); in TEST_P()
2816 ASSERT_TRUE(statuses[5].ok()); in TEST_P()
2818 ASSERT_TRUE(statuses[6].ok()); in TEST_P()
2898 std::vector<Status> statuses(keys.size()); in TEST_P() local
2906 ASSERT_TRUE(statuses[2].ok()); in TEST_P()
2909 ASSERT_TRUE(statuses[i].ok()); in TEST_P()
[all …]
|
| D | write_unprepared_txn.h | 196 PinnableSlice* values, Status* statuses,
|
| D | transaction_base.cc | 325 PinnableSlice* values, Status* statuses, in MultiGet() argument
328 num_keys, keys, values, statuses, in MultiGet()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-02-07-rocksdb-5-1-2-released.markdown | 11 * BackupEngine::Open and BackupEngineReadOnly::Open now always return error statuses matching those…
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_reader.cc | 1541 autovector<Status, MultiGetContext::MAX_BATCH_SIZE>* statuses, in RetrieveMultipleBlocks() argument
1561 (*statuses)[idx_in_batch] = in RetrieveMultipleBlocks()
1766 (*statuses)[idx_in_batch] = s; in RetrieveMultipleBlocks()
2338 autovector<Status, MultiGetContext::MAX_BATCH_SIZE> statuses; in MultiGet() local
2392 statuses.emplace_back(); in MultiGet()
2445 &statuses, &results, scratch, dict); in MultiGet()
2475 statuses[idx_in_batch]); in MultiGet()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 207 PinnableSlice* values, Status* statuses,
213 Status* statuses,
218 PinnableSlice* values, Status* statuses,
223 Status* statuses,
|