Home
last modified time | relevance | path

Searched refs:Status (Results 1 – 25 of 60) sorted by relevance

123

/leveldb-1.20/include/leveldb/
H A Dstatus.h21 class Status {
24 Status() : state_(NULL) { } in Status() function
25 ~Status() { delete[] state_; } in ~Status()
28 Status(const Status& s);
29 void operator=(const Status& s);
32 static Status OK() { return Status(); } in OK()
36 return Status(kNotFound, msg, msg2);
39 return Status(kCorruption, msg, msg2);
48 return Status(kIOError, msg, msg2);
98 inline Status::Status(const Status& s) { in Status() function
[all …]
H A Denv.h69 virtual Status NewWritableFile(const std::string& fname,
93 virtual Status GetChildren(const std::string& dir,
109 virtual Status RenameFile(const std::string& src,
131 virtual Status UnlockFile(FileLock* lock) = 0;
192 virtual Status Skip(uint64_t n) = 0;
232 virtual Status Append(const Slice& data) = 0;
233 virtual Status Close() = 0;
234 virtual Status Flush() = 0;
235 virtual Status Sync() = 0;
323 Status LockFile(const std::string& f, FileLock** l) { in LockFile()
[all …]
H A Ddb.h51 static Status Open(const Options& options,
61 virtual Status Put(const WriteOptions& options,
69 virtual Status Delete(const WriteOptions& options, const Slice& key) = 0;
74 virtual Status Write(const WriteOptions& options, WriteBatch* updates) = 0;
83 virtual Status Get(const ReadOptions& options,
153 Status DestroyDB(const std::string& name, const Options& options);
159 Status RepairDB(const std::string& dbname, const Options& options);
H A Dtable_builder.h42 Status ChangeOptions(const Options& options);
56 Status status() const;
61 Status Finish();
/leveldb-1.20/helpers/memenv/
H A Dmemenv.cc62 return Status::OK(); in Read()
72 return Status::OK(); in Read()
92 return Status::OK(); in Read()
121 return Status::OK(); in Append()
176 return Status::OK(); in Skip()
217 virtual Status Close() { return Status::OK(); } in Close()
218 virtual Status Flush() { return Status::OK(); } in Flush()
219 virtual Status Sync() { return Status::OK(); } in Sync()
250 return Status::OK(); in NewSequentialFile()
262 return Status::OK(); in NewRandomAccessFile()
[all …]
/leveldb-1.20/db/
H A Dfault_injection_test.cc48 return Status::OK(); in SyncDir()
114 virtual Status Close();
115 virtual Status Flush();
116 virtual Status Sync();
124 Status SyncParent();
211 return Status::OK(); in Sync()
214 Status s = target_->Sync(); in Sync()
266 Status s; in DropUnsyncedFileData()
341 Status s; in DeleteFilesCreatedAfterLastDirSync()
418 Status s; in Verify()
[all …]
H A Dleveldbutil.cc15 virtual Status Append(const Slice& data) { in Append()
17 return Status::OK(); in Append()
19 virtual Status Close() { return Status::OK(); } in Close()
20 virtual Status Flush() { return Status::OK(); } in Flush()
21 virtual Status Sync() { return Status::OK(); } in Sync()
28 Status s = DumpFile(env, files[i], &printer); in HandleDumpCommand()
H A Ddb_impl.h33 virtual Status Delete(const WriteOptions&, const Slice& key);
35 virtual Status Get(const ReadOptions& options,
51 Status TEST_CompactMemTable();
76 Status NewDB();
81 Status Recover(VersionEdit* edit, bool* save_manifest)
84 void MaybeIgnoreError(Status* s) const;
105 void RecordBackgroundError(const Status& s);
113 Status DoCompactionWork(CompactionState* compact)
116 Status OpenCompactionOutputFile(CompactionState* compact);
118 Status InstallCompactionResults(CompactionState* compact)
[all …]
H A Ddumpfile.cc39 virtual void Corruption(size_t bytes, const Status& status) { in Corruption()
50 Status PrintLogContents(Env* env, const std::string& fname, in PrintLogContents()
54 Status s = env->NewSequentialFile(fname, &file); in PrintLogContents()
67 return Status::OK(); in PrintLogContents()
112 Status s = batch.Iterate(&batch_item_printer); in WriteBatchPrinter()
118 Status DumpLog(Env* env, const std::string& fname, WritableFile* dst) { in DumpLog()
129 Status s = edit.DecodeFrom(record); in VersionEditPrinter()
147 Status s = env->GetFileSize(fname, &file_size); in DumpTable()
205 return Status::OK(); in DumpTable()
210 Status DumpFile(Env* env, const std::string& fname, WritableFile* dst) { in DumpFile()
[all …]
H A Dwrite_batch.cc42 Status WriteBatch::Iterate(Handler* handler) const { in Iterate()
45 return Status::Corruption("malformed WriteBatch (too small)"); in Iterate()
61 return Status::Corruption("bad WriteBatch Put"); in Iterate()
68 return Status::Corruption("bad WriteBatch Delete"); in Iterate()
72 return Status::Corruption("unknown WriteBatch tag"); in Iterate()
76 return Status::Corruption("WriteBatch has wrong count"); in Iterate()
78 return Status::OK(); in Iterate()
128 Status WriteBatchInternal::InsertInto(const WriteBatch* b, in InsertInto()
H A Drepair.cc70 Status Run() { in Run()
71 Status status = FindFiles(); in Run()
116 Status FindFiles() { in FindFiles()
118 Status status = env_->GetChildren(dbname_, &filenames); in FindFiles()
152 Status status = ConvertLogToTable(logs_[i]); in ConvertLogFilesToTables()
162 Status ConvertLogToTable(uint64_t log) { in ConvertLogToTable()
268 status = Status::OK(); in ScanTable()
328 Status s = env_->NewWritableFile(copy, &file); in RepairTable()
375 Status WriteDescriptor() { in WriteDescriptor()
378 Status status = env_->NewWritableFile(tmp, &file); in WriteDescriptor()
[all …]
H A Ddb_impl.cc42 Status status;
177 Status DBImpl::NewDB() { in NewDB()
214 *s = Status::OK(); in MaybeIgnoreError()
362 return Status::OK(); in Recover()
499 Status s; in WriteLevel0Table()
714 Status status; in BackgroundCompaction()
823 Status s = input->status(); in FinishCompactionOutputFile()
911 Status status; in DoCompactionWork()
1112 Status s; in Get()
1322 Status s; in MakeRoomForWrite()
[all …]
H A Dtable_cache.cc45 Status TableCache::FindTable(uint64_t file_number, uint64_t file_size, in FindTable()
47 Status s; in FindTable()
60 s = Status::OK(); in FindTable()
91 Status s = FindTable(file_number, file_size, &handle); in NewIterator()
105 Status TableCache::Get(const ReadOptions& options, in Get()
112 Status s = FindTable(file_number, file_size, &handle); in Get()
H A Dlog_test.cc45 virtual Status Close() { return Status::OK(); } in Close()
46 virtual Status Flush() { return Status::OK(); } in Flush()
47 virtual Status Sync() { return Status::OK(); } in Sync()
48 virtual Status Append(const Slice& slice) { in Append()
50 return Status::OK(); in Append()
61 virtual Status Read(size_t n, Slice* result, char* scratch) { in Read()
67 return Status::Corruption("read error"); in Read()
76 return Status::OK(); in Read()
79 virtual Status Skip(uint64_t n) { in Skip()
87 return Status::OK(); in Skip()
[all …]
H A Dlog_writer.cc36 Status Writer::AddRecord(const Slice& slice) { in AddRecord()
43 Status s; in AddRecord()
84 Status Writer::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n) { in EmitPhysicalRecord()
100 Status s = dest_->Append(Slice(buf, kHeaderSize)); in EmitPhysicalRecord()
H A Dlog_writer.h33 Status AddRecord(const Slice& slice);
44 Status EmitPhysicalRecord(RecordType type, const char* ptr, size_t length);
/leveldb-1.20/util/
H A Denv_posix.cc103 Status s; in Read()
161 Status s; in Read()
199 Status s; in Read()
235 Status result; in Close()
262 Status s; in SyncDirIfManifest()
350 Status s; in NewRandomAccessFile()
377 Status s; in NewWritableFile()
390 Status s; in NewAppendableFile()
421 Status result; in DeleteFile()
429 Status result; in CreateDir()
[all …]
H A Denv.cc12 Status Env::NewAppendableFile(const std::string& fname, WritableFile** result) { in NewAppendableFile()
13 return Status::NotSupported("NewAppendableFile", fname); in NewAppendableFile()
40 static Status DoWriteStringToFile(Env* env, const Slice& data, in DoWriteStringToFile()
44 Status s = env->NewWritableFile(fname, &file); in DoWriteStringToFile()
62 Status WriteStringToFile(Env* env, const Slice& data, in WriteStringToFile()
67 Status WriteStringToFileSync(Env* env, const Slice& data, in WriteStringToFileSync()
72 Status ReadFileToString(Env* env, const std::string& fname, std::string* data) { in ReadFileToString()
75 Status s = env->NewSequentialFile(fname, &file); in ReadFileToString()
H A Dtestutil.h39 virtual Status NewWritableFile(const std::string& fname, in NewWritableFile()
44 return Status::IOError(fname, "fake error"); in NewWritableFile()
49 virtual Status NewAppendableFile(const std::string& fname, in NewAppendableFile()
54 return Status::IOError(fname, "fake error"); in NewAppendableFile()
H A Dstatus.cc11 const char* Status::CopyState(const char* state) { in CopyState()
19 Status::Status(Code code, const Slice& msg, const Slice& msg2) { in Status() function in leveldb::Status
36 std::string Status::ToString() const { in ToString()
/leveldb-1.20/table/
H A Dformat.cc23 Status BlockHandle::DecodeFrom(Slice* input) { in DecodeFrom()
26 return Status::OK(); in DecodeFrom()
28 return Status::Corruption("bad block handle"); in DecodeFrom()
43 Status Footer::DecodeFrom(Slice* input) { in DecodeFrom()
50 return Status::Corruption("not an sstable (bad magic number)"); in DecodeFrom()
53 Status result = metaindex_handle_.DecodeFrom(input); in DecodeFrom()
65 Status ReadBlock(RandomAccessFile* file, in ReadBlock()
85 return Status::Corruption("truncated block read"); in ReadBlock()
95 s = Status::Corruption("block checksum mismatch"); in ReadBlock()
138 return Status::Corruption("bad block type"); in ReadBlock()
[all …]
H A Diterator.cc44 EmptyIterator(const Status& s) : status_(s) { } in EmptyIterator()
53 virtual Status status() const { return status_; } in status()
55 Status status_;
60 return new EmptyIterator(Status::OK()); in NewEmptyIterator()
63 Iterator* NewErrorIterator(const Status& status) { in NewErrorIterator()
H A Dtable_test.cc96 virtual Status Close() { return Status::OK(); } in Close()
97 virtual Status Flush() { return Status::OK(); } in Flush()
98 virtual Status Sync() { return Status::OK(); } in Sync()
102 return Status::OK(); in Append()
130 return Status::OK(); in Read()
207 return Status::OK(); in FinishImpl()
241 Status s = builder.Finish(); in FinishImpl()
303 virtual Status status() const { in status()
308 mutable Status status_;
338 return Status::OK(); in FinishImpl()
[all …]
H A Dformat.h35 Status DecodeFrom(Slice* input);
64 Status DecodeFrom(Slice* input);
94 extern Status ReadBlock(RandomAccessFile* file,
H A Dtable.cc28 Status status;
38 Status Table::Open(const Options& options, in Open()
44 return Status::Corruption("file is too short to be an sstable"); in Open()
49 Status s = file->Read(size - Footer::kEncodedLength, Footer::kEncodedLength, in Open()
174 Status s = handle.DecodeFrom(&input); in BlockReader()
226 Status Table::InternalGet(const ReadOptions& options, const Slice& k, in InternalGet()
229 Status s; in InternalGet()
266 Status s = handle.DecodeFrom(&input); in ApproximateOffsetOf()

123