Home
last modified time | relevance | path

Searched refs:statuses (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_basic_test.cc1725 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 …]
Dcompacted_db_impl.cc64 std::vector<Status> statuses(keys.size(), Status::NotFound()); in MultiGet() local
78 statuses[idx] = Status::OK(); in MultiGet()
83 return statuses; in MultiGet()
Dversion_builder.cc678 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()
Ddb_test.cc529 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 …]
Ddb_test_util.cc830 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/
Dcf_consistency_stress.cc212 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()
Dno_batched_ops_stress.cc172 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()
Dbatched_ops_stress.cc184 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/
Ddb_ttl_impl.cc235 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()
Dttl_test.cc219 auto statuses = db_ttl_->MultiGet(ropts, keys, &values); in SimpleMultiGetTest() local
222 ASSERT_OK(statuses[i]); in SimpleMultiGetTest()
/rocksdb-6.9/include/rocksdb/
Ddb.h524 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/
Dwrite_batch_with_index.h225 PinnableSlice* values, Status* statuses,
270 PinnableSlice* values, Status* statuses,
Dtransaction.h218 PinnableSlice* values, Status* statuses,
221 statuses[i] = Get(options, column_family, keys[i], &values[i]);
Dstackable_db.h114 PinnableSlice* values, Status* statuses,
117 values, statuses, sorted_input);
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc931 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/
Dblob_db.h174 PinnableSlice* /*values*/, Status* statuses,
177 statuses[i] = Status::NotSupported(
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc46 PinnableSlice* values, Status* statuses, in MultiGet() argument
54 keys, values, statuses, sorted_input, in MultiGet()
60 statuses[i] = Status::TryAgain(); in MultiGet()
Dwrite_prepared_txn.h63 PinnableSlice* values, Status* statuses,
Dwrite_unprepared_txn.cc910 PinnableSlice* values, Status* statuses, in MultiGet() argument
918 keys, values, statuses, sorted_input, in MultiGet()
924 statuses[i] = Status::TryAgain(); in MultiGet()
Dtransaction_test.cc2804 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 …]
Dwrite_unprepared_txn.h196 PinnableSlice* values, Status* statuses,
Dtransaction_base.cc325 PinnableSlice* values, Status* statuses, in MultiGet() argument
328 num_keys, keys, values, statuses, in MultiGet()
/rocksdb-6.9/docs/_posts/
D2017-02-07-rocksdb-5-1-2-released.markdown11 * BackupEngine::Open and BackupEngineReadOnly::Open now always return error statuses matching those…
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.cc1541 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/
Ddb_impl.h207 PinnableSlice* values, Status* statuses,
213 Status* statuses,
218 PinnableSlice* values, Status* statuses,
223 Status* statuses,

12