Home
last modified time | relevance | path

Searched refs:status_ (Results 1 – 25 of 41) sorted by relevance

12

/rocksdb-6.9/table/
Dblock_fetcher.cc61 status_ = Status::Corruption( in CheckBlockChecksum()
98 if (!status_.ok()) { in TryGetFromPrefetchBuffer()
114 if (status_.ok()) { in TryGetCompressedBlockFromPersistentCache()
120 assert(!status_.ok()); in TryGetCompressedBlockFromPersistentCache()
208 if (!status_.ok()) { in ReadBlockContents()
209 return status_; in ReadBlockContents()
243 if (!status_.ok()) { in ReadBlockContents()
244 return status_; in ReadBlockContents()
256 if (status_.ok()) { in ReadBlockContents()
259 return status_; in ReadBlockContents()
[all …]
Dmerging_iterator.cc60 if (!s.ok() && status_.ok()) { in considerStatus()
61 status_ = s; in considerStatus()
84 bool Valid() const override { return current_ != nullptr && status_.ok(); } in Valid()
86 Status status() const override { return status_; } in status()
90 status_ = Status::OK(); in SeekToFirst()
102 status_ = Status::OK(); in SeekToLast()
113 status_ = Status::OK(); in Seek()
138 status_ = Status::OK(); in SeekForPrev()
292 Status status_; member in ROCKSDB_NAMESPACE::MergingIterator
Diterator.cc112 explicit EmptyIterator(const Status& s) : status_(s) { } in EmptyIterator()
128 Status status() const override { return status_; } in status()
131 Status status_; member in ROCKSDB_NAMESPACE::__anon08bc85910111::EmptyIterator
137 explicit EmptyInternalIterator(const Status& s) : status_(s) {} in EmptyInternalIterator()
153 Status status() const override { return status_; } in status()
156 Status status_; member in ROCKSDB_NAMESPACE::__anon08bc85910111::EmptyInternalIterator
Dtwo_level_iterator.cc58 return status_; in status()
68 if (status_.ok() && !s.ok()) status_ = s; in SaveError()
78 Status status_; member in ROCKSDB_NAMESPACE::__anond75762610111::TwoLevelIndexIterator
/rocksdb-6.9/tools/rdb/
Ddb_wrapper.cc115 db_wrapper->status_ = ROCKSDB_NAMESPACE::DB::Open( in Open()
118 if (!db_wrapper->status_.ok()) { in Open()
161 db_wrapper->status_ = in Get()
164 db_wrapper->status_ = in Get()
171 Handle<Value> v = db_wrapper->status_.ok() ? in Get()
191 db_wrapper->status_ = in Put()
194 db_wrapper->status_ = in Put()
217 db_wrapper->status_ = in Delete()
223 db_wrapper->status_ = in Delete()
281 if (!db_wrapper->status_.ok()) { in CreateColumnFamily()
[all …]
/rocksdb-6.9/logging/
Dauto_roll_logger.cc28 status_(Status::OK()), in AutoRollLogger()
41 status_ = s; in AutoRollLogger()
49 if (status_.ok()) { in AutoRollLogger()
50 status_ = TrimOldLogFiles(); in AutoRollLogger()
59 if (!status_.ok()) { in ResetLogger()
60 return status_; in ResetLogger()
66 status_ = Status::NotSupported( in ResetLogger()
69 if (status_.ok()) { in ResetLogger()
75 return status_; in ResetLogger()
104 if (status_.ok()) { in GetExistingFiles()
[all …]
/rocksdb-6.9/db/
Ddb_iter.cc122 assert(status_.ok()); in Next()
189 assert(status_.ok()); in FindNextUserEntryInternal()
494 status_ = s; in MergeValuesNewToOld()
517 status_ = in MergeValuesNewToOld()
542 status_ = s; in MergeValuesNewToOld()
546 assert(status_.ok()); in MergeValuesNewToOld()
831 status_ = in FindValueForCurrentKey()
864 status_ = s; in FindValueForCurrentKey()
978 status_ = s; in FindValueForCurrentKeyUsingSeek()
994 status_ = in FindValueForCurrentKeyUsingSeek()
[all …]
Dforward_iterator.cc60 status_ = Status::OK(); in SetFileIndex()
107 if (!status_.ok()) { in SeekToFirst()
122 if (!status_.ok()) { in Seek()
151 if (!status_.ok()) { in Next()
167 if (!status_.ok()) { in status()
168 return status_; in status()
196 Status status_; member in ROCKSDB_NAMESPACE::ForwardLevelIterator
215 status_(Status::OK()), in ForwardIterator()
554 if (!status_.ok()) { in status()
555 return status_; in status()
[all …]
Ddb_iter_stress_test.cc83 Status status_; member
90 assert(status_.ok()); in Valid()
96 Status status() const override { return status_; } in status()
104 status_ = Status::Incomplete("test"); in MaybeFail()
106 status_ = Status::IOError("test"); in MaybeFail()
109 std::cout << "injecting " << status_.ToString() << std::endl; in MaybeFail()
180 status_ = Status::OK(); in SeekToFirst()
188 status_ = Status::OK(); in SeekToLast()
197 status_ = Status::OK(); in Seek()
209 status_ = Status::OK(); in SeekForPrev()
Dforward_iterator.h59 status_ = Status::NotSupported("ForwardIterator::SeekForPrev()"); in SeekForPrev()
63 status_ = Status::NotSupported("ForwardIterator::SeekToLast()"); in SeekToLast()
67 status_ = Status::NotSupported("ForwardIterator::Prev"); in Prev()
134 Status status_; variable
Ddb_iter.h166 if (status_.ok()) { in status()
170 return status_; in status()
306 Status status_; variable
Dversion_edit_handler.h45 const Status& status() const { return status_; } in status()
80 Status status_; variable
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.cc255 status_ = MakeHashTable(&buckets); in Finish()
256 if (!status_.ok()) { in Finish()
257 return status_; in Finish()
315 status_ = io_status_; in Finish()
316 return status_; in Finish()
371 status_ = io_status_; in Finish()
372 return status_; in Finish()
383 status_ = io_status_; in Finish()
384 return status_; in Finish()
393 status_ = io_status_; in Finish()
[all …]
Dcuckoo_table_reader.cc56 status_ = Status::InvalidArgument("File is not mmaped"); in CuckooTableReader()
62 if (!status_.ok()) { in CuckooTableReader()
69 status_ = Status::Corruption("Number of hash functions not found"); in CuckooTableReader()
75 status_ = Status::Corruption("Empty bucket value not found"); in CuckooTableReader()
83 status_ = Status::Corruption("User key length not found"); in CuckooTableReader()
91 status_ = Status::Corruption("Value length not found"); in CuckooTableReader()
101 status_ = Status::Corruption("Hash table size not found"); in CuckooTableReader()
109 status_ = Status::Corruption("Is last level not found"); in CuckooTableReader()
117 status_ = Status::Corruption("identity as first hash not found"); in CuckooTableReader()
126 status_ = Status::Corruption("hash type is not found"); in CuckooTableReader()
[all …]
Dcuckoo_table_reader.h42 Status status() const { return status_; } in status()
84 Status status_; variable
Dcuckoo_table_builder.h47 Status status() const override { return status_; } in status()
121 Status status_; variable
/rocksdb-6.9/table/plain/
Dplain_table_builder.cc129 status_ = Status::NotSupported("Range deletion unsupported"); in Add()
185 status_ = io_status_; in Add()
226 status_ = io_status_; in Finish()
227 return status_; in Finish()
239 status_ = io_status_; in Finish()
240 return status_; in Finish()
273 status_ = io_status_; in Finish()
274 return status_; in Finish()
288 status_ = io_status_; in Finish()
289 return status_; in Finish()
Dplain_table_reader.cc91 Status status_; member in ROCKSDB_NAMESPACE::PlainTableIterator
563 status_ = in Get()
652 status_ = Status::OK(); in SeekToFirst()
674 status_ = in Seek()
685 status_ = in Seek()
705 status_ = Status::OK(); in Seek()
713 if (!status_.ok()) { in Seek()
739 status_ = in SeekForPrev()
749 status_ = in Next()
751 if (!status_.ok()) { in Next()
[all …]
Dplain_table_builder.h62 Status status() const override { return status_; } in status()
110 Status status_; variable
/rocksdb-6.9/utilities/blob_db/
Dblob_db_iterator.h36 return status_.ok(); in Valid()
43 return status_; in status()
121 status_ = Status::OK(); in UpdateBlobValue()
128 status_ = s; in UpdateBlobValue()
142 Status status_; variable
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.h20 : reader_(nullptr), reporter_(nullptr), status_(nullptr) {} in LogReaderContainer()
26 status_ = new Status(); in LogReaderContainer()
30 reporter->status = status_; in LogReaderContainer()
42 Status* status_; variable
46 delete status_; in ~LogReaderContainer() local
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc254 status_ = Status::Corruption("Corrupted internal key not expected."); in NextFromInput()
566 status_ = Status::InvalidArgument( in NextFromInput()
581 status_ = s; in NextFromInput()
633 status_ = Status::ShutdownInProgress(); in NextFromInput()
637 status_ = Status::Incomplete(Status::SubCode::kManualCompactionPaused); in NextFromInput()
648 status_ = Status::Corruption( in PrepareOutput()
652 status_ = Status::IOError("Could not relocate blob during GC"); in PrepareOutput()
/rocksdb-6.9/table/block_based/
Dblock.cc387 status_ = Status::OK(); in Seek()
398 status_ = Status::NotFound(); in Seek()
465 status_ = Status::OK(); in SeekToFirst()
484 status_ = Status::OK(); in SeekToLast()
495 status_ = Status::Corruption("bad entry in block"); in CorruptionError()
735 if (!status_.ok()) { in BinaryBlockIndexSeek()
Dblock.h260 status_ = s; in InvalidateBase()
267 Status status() const override { return status_; } in status()
315 Status status_; variable
549 status_ = Status::InvalidArgument( in SeekForPrev()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc41 status_(Status::OK()), in BaseDeltaIterator()
84 status_ = Status::NotSupported("Next() on invalid iterator"); in Next()
120 status_ = Status::NotSupported("Prev() on invalid iterator"); in Prev()
166 if (!status_.ok()) { in status()
167 return status_; in status()
261 status_ = Status::OK(); in UpdateCurrent()
335 Status status_; member in ROCKSDB_NAMESPACE::BaseDeltaIterator

12