| /rocksdb-6.9/tools/dump/ |
| D | db_dump_tool.cc | 37 if (!status.ok()) { in Run()
47 if (!status.ok()) { in Run()
55 if (!status.ok()) { in Run()
62 if (!status.ok()) { in Run()
84 if (!status.ok()) { in Run()
89 if (!status.ok()) { in Run()
101 if (!status.ok()) { in Run()
106 if (!status.ok()) { in Run()
149 if (!status.ok()) { in Run()
178 if (!status.ok()) { in Run()
[all …]
|
| /rocksdb-6.9/env/ |
| D | env_encryption.cc | 50 return status; in Read()
54 return status; in Read()
67 return status; in Skip()
70 return status; in Skip()
98 return status; in PositionedRead()
102 return status; in PositionedRead()
136 return status; in Read()
200 Status status; in Append() local
221 return status; in Append()
226 Status status; in PositionedAppend() local
[all …]
|
| D | composite_env_wrapper.h | 69 Status status; in MultiRead() local
81 reqs[i].status = fs_reqs[i].status; in MultiRead()
83 return status; in MultiRead()
298 Status status; in NewSequentialFile() local
299 status = in NewSequentialFile()
304 return status; in NewSequentialFile()
311 Status status; in NewRandomAccessFile() local
312 status = in NewRandomAccessFile()
317 return status; in NewRandomAccessFile()
324 status = in NewWritableFile()
[all …]
|
| /rocksdb-6.9/db/ |
| D | external_sst_file_ingestion_job.cc | 32 Status status; in Prepare() local
39 return status; in Prepare()
104 status = in Prepare()
179 return status; in Prepare()
189 Status status = in NeedsFlush() local
195 return status; in NeedsFlush()
201 Status status; in Run() local
264 return status; in Run()
523 return status; in GetIngestedFileInfo()
530 Status status; in AssignLevelAndSeqnoForIngestedFile() local
[all …]
|
| D | repair.cc | 163 return status; in AddColumnFamily()
176 return status; in Run()
192 status = in Run()
221 return status; in Run()
386 status = in ConvertLogToTable()
452 return status; in ConvertLogToTable()
503 status = in ScanTable()
549 status = iter->status(); in ScanTable()
557 return status; in ScanTable()
657 return status; in RepairDB()
[all …]
|
| D | import_column_family_job.cc | 23 Status status; in Prepare() local
30 if (!status.ok()) { in Prepare()
31 return status; in Prepare()
95 status = in Prepare()
129 return status; in Prepare()
135 Status status; in Run() local
167 return status; in Run()
207 return status; in GetIngestedFileInfo()
218 return status; in GetIngestedFileInfo()
229 return status; in GetIngestedFileInfo()
[all …]
|
| D | db_encryption_test.cc | 33 auto status = env_->GetChildren(dbname_, &fileNames); in TEST_F() local
34 ASSERT_OK(status); in TEST_F()
46 ASSERT_OK(status); in TEST_F()
49 status = defaultEnv->GetFileSize(filePath, &fileSize); in TEST_F()
50 ASSERT_OK(status); in TEST_F()
56 ASSERT_OK(status); in TEST_F()
93 Status status; in TEST_F() local
97 ASSERT_OK(status); in TEST_F()
102 ASSERT_OK(status); in TEST_F()
108 status = seqFile->Read(16, &data, (char*)scratch.data()); in TEST_F()
[all …]
|
| D | write_thread.cc | 561 if (!write_group.status.ok()) { in ExitAsMemTableWriter()
562 w->status = write_group.status; in ExitAsMemTableWriter()
590 if (!w->status.ok()) { in CompleteParallelMemTableWriter()
592 write_group->status = w->status; in CompleteParallelMemTableWriter()
601 w->status = write_group->status; in CompleteParallelMemTableWriter()
609 assert(write_group->status.ok()); in ExitAsBatchGroupFollower()
611 assert(w->status.ok()); in ExitAsBatchGroupFollower()
624 if (status.ok() && !write_group.status.ok()) { in ExitAsBatchGroupLeader()
625 status = write_group.status; in ExitAsBatchGroupLeader()
632 w->status = status; in ExitAsBatchGroupLeader()
[all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier.cc | 25 Status status; in Open() local
34 if (!status.ok()) { in Open()
36 return status; in Open()
44 return status; in Open()
66 return status; in Open()
98 return status; in CleanupCacheFolder()
271 bool status; in Lookup() local
273 if (!status) { in Lookup()
296 if (!status) { in Lookup()
336 if (!status) { in NewCacheFile()
[all …]
|
| D | hash_table_bench.cc | 103 bool status = impl_->Insert(k, tmp); in RunWrite() local
104 assert(status); in RunWrite()
114 bool status = impl_->Lookup(k, &s); in RunRead() local
115 assert(status); in RunRead()
124 bool status = impl_->Erase(k); in RunErase() local
125 nerases_failed_ += !status; in RunErase()
143 assert(status); in Prepop()
150 assert(status); in Prepop()
241 bool status = impl_.Find(n, &n, &rlock); in Lookup() local
242 if (status) { in Lookup()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | writebatchhandlerjnicallback.cc | 143 if(status == nullptr) { in PutCF()
176 if(status == nullptr) { in MergeCF()
207 if(status == nullptr) { in DeleteCF()
236 if(status == nullptr) { in SingleDeleteCF()
267 if(status == nullptr) { in DeleteRangeCF()
311 if(status == nullptr) { in PutBlobIndexCF()
360 if(status == nullptr) { in MarkEndPrepare()
404 if(status == nullptr) { in MarkRollback()
423 if(status == nullptr) { in MarkCommit()
490 return status; in kv_op()
[all …]
|
| D | backupenginejni.cc | 32 if (status.ok()) { in Java_org_rocksdb_BackupEngine_open()
51 auto status = backup_engine->CreateNewBackup( in Java_org_rocksdb_BackupEngine_createNewBackup() local
54 if (status.ok()) { in Java_org_rocksdb_BackupEngine_createNewBackup()
85 if (status.ok()) { in Java_org_rocksdb_BackupEngine_createNewBackupWithMetadata()
146 if (status.ok()) { in Java_org_rocksdb_BackupEngine_garbageCollect()
163 auto status = backup_engine->PurgeOldBackups( in Java_org_rocksdb_BackupEngine_purgeOldBackups() local
166 if (status.ok()) { in Java_org_rocksdb_BackupEngine_purgeOldBackups()
183 auto status = backup_engine->DeleteBackup( in Java_org_rocksdb_BackupEngine_deleteBackup() local
186 if (status.ok()) { in Java_org_rocksdb_BackupEngine_deleteBackup()
223 if (status.ok()) { in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
[all …]
|
| D | write_batch.cc | 171 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_put__J_3BI_3BI()
196 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_put__J_3BI_3BIJ()
244 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_merge__J_3BI_3BI()
269 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_merge__J_3BI_3BIJ()
287 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_delete__J_3BI()
311 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_delete__J_3BIJ()
333 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_singleDelete__J_3BI()
359 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_singleDelete__J_3BIJ()
405 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_deleteRange__J_3BI_3BI()
431 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatch_deleteRange__J_3BI_3BIJ()
[all …]
|
| D | write_batch_with_index.cc | 101 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_put__J_3BI_3BI()
128 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_put__J_3BI_3BIJ()
176 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_merge__J_3BI_3BI()
203 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_merge__J_3BI_3BIJ()
226 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_delete__J_3BI()
250 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_delete__J_3BIJ()
272 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_singleDelete__J_3BI()
297 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_singleDelete__J_3BIJ()
343 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_deleteRange__J_3BI_3BI()
370 if (status != nullptr && !status->ok()) { in Java_org_rocksdb_WriteBatchWithIndex_deleteRange__J_3BI_3BIJ()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 103 Status status; in WriteImpl() local
147 return status; in WriteImpl()
457 return status; in WriteImpl()
657 Status status; in WriteImplWALOnly() local
829 return status; in WriteImplWALOnly()
836 !status.IsBusy() && !status.IsIncomplete()) { in WriteStatusCheck()
873 Status status; in PreprocessWrite() local
947 return status; in PreprocessWrite()
1219 Status status; in SwitchWAL() local
1308 return status; in SwitchWAL()
[all …]
|
| D | db_impl_open.cc | 706 if (this->status != nullptr && this->status->ok()) { in RecoverLogFiles()
713 Status status; in RecoverLogFiles() local
791 if (!status.ok()) { in RecoverLogFiles()
794 return status; in RecoverLogFiles()
815 reporter.status = &status; in RecoverLogFiles()
878 status = in RecoverLogFiles()
981 if (!status.ok()) { in RecoverLogFiles()
986 return status; in RecoverLogFiles()
1010 return status; in RecoverLogFiles()
1103 if (status.ok()) { in RecoverLogFiles()
[all …]
|
| D | db_impl_compaction_flush.cc | 258 Status status; in FlushMemTablesToOutputFiles() local
268 status = s; in FlushMemTablesToOutputFiles()
276 return status; in FlushMemTablesToOutputFiles()
1112 return status; in CompactFilesImpl()
1270 Status status; in ReFitLevel() local
1340 return status; in ReFitLevel()
2204 Status status; in BackgroundFlush() local
2276 return status; in BackgroundFlush()
2520 manual_compaction->status = status; in BackgroundCompaction()
2872 if (status.ok() || status.IsCompactionTooLarge() || in BackgroundCompaction()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | RocksDBException.java | 14 /* @Nullable */ private final Status status; field in RocksDBException
25 public RocksDBException(final String msg, final Status status) { in RocksDBException() argument
27 this.status = status; in RocksDBException()
30 public RocksDBException(final Status status) { in RocksDBException() argument
31 super(status.getState() != null ? status.getState() in RocksDBException()
32 : status.getCodeString()); in RocksDBException()
33 this.status = status; in RocksDBException()
42 return status; in getStatus()
|
| D | AbstractTraceWriter.java | 53 private static short statusToShort(/*@Nullable*/ final Status status) { in statusToShort() argument
54 final Status.Code code = status != null && status.getCode() != null in statusToShort()
55 ? status.getCode() in statusToShort()
57 final Status.SubCode subCode = status != null && status.getSubCode() != null in statusToShort()
58 ? status.getSubCode() in statusToShort()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 117 Status status; member
181 status = std::move(o.status); in operator =()
611 status = state.status; in Run()
684 status = state.status; in Run()
708 compact_->status = status; in Run()
716 Status status = compact_->status; in Install() local
1016 status = in ProcessKeyValueCompaction()
1019 if ((status.ok() || status.IsColumnFamilyDropped()) && in ProcessKeyValueCompaction()
1029 status = input->status(); in ProcessKeyValueCompaction()
1032 status = c_iter->status(); in ProcessKeyValueCompaction()
[all …]
|
| /rocksdb-6.9/table/ |
| D | iterator.cc | 128 Status status() const override { return status_; } in status() function in ROCKSDB_NAMESPACE::__anon08bc85910111::EmptyIterator
153 Status status() const override { return status_; } in status() function in ROCKSDB_NAMESPACE::__anon08bc85910111::EmptyInternalIterator
162 Iterator* NewErrorIterator(const Status& status) { in NewErrorIterator() argument
163 return new EmptyIterator(status); in NewErrorIterator()
168 return new EmptyInternalIterator<TValue>(status); in NewErrorInternalIterator()
171 const Status& status);
173 const Status& status);
179 return NewErrorInternalIterator<TValue>(status); in NewErrorInternalIterator()
182 return new (mem) EmptyInternalIterator<TValue>(status); in NewErrorInternalIterator()
186 const Status& status, Arena* arena);
[all …]
|
| /rocksdb-6.9/build_tools/ |
| D | precommit_checker.py | 66 self.log.log("status = %s" % status)
68 return status
76 status, out = commands.getstatusoutput(cmd)
77 self.log.log("status = %s" % status)
80 return status, out
97 status, out = self.GetOutput(
99 return status, out
108 status, cmds = self.get_commands(test)
109 if status != 0:
127 status = self.shell(cmd, ".")
[all …]
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_shared_state.h | 91 Status status; in SharedState() local
94 status = Status::InvalidArgument( in SharedState()
99 status = Status::InvalidArgument( in SharedState()
104 if (status.ok()) { in SharedState()
108 if (status.ok() && size == 0) { in SharedState()
110 status = in SharedState()
113 if (status.ok() && size == 0) { in SharedState()
115 status = wfile->Append(buf); in SharedState()
118 if (status.ok()) { in SharedState()
122 if (status.ok()) { in SharedState()
[all …]
|
| /rocksdb-6.9/port/win/ |
| D | io_win.cc | 146 Status status; in fallocate() local
158 return status; in fallocate()
163 Status status; in ftruncate() local
175 return status; in ftruncate()
247 Status status; in UnmapCurrentRegion() local
269 return status; in UnmapCurrentRegion()
274 Status status; in MapNewRegion() local
337 return status; in MapNewRegion()
536 Status status; in Allocate() local
553 return status; in Allocate()
[all …]
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 108 ASSERT_OK(iter->status()); in TestValueAsSecondaryIndexHelper()
334 ASSERT_OK(iter->status()); in TEST_F()
338 ASSERT_OK(iter->status()); in TEST_F()
342 ASSERT_OK(iter->status()); in TEST_F()
346 ASSERT_OK(iter->status()); in TEST_F()
353 ASSERT_OK(iter->status()); in TEST_F()
357 ASSERT_OK(iter->status()); in TEST_F()
361 ASSERT_OK(iter->status()); in TEST_F()
368 ASSERT_OK(iter->status()); in TEST_F()
372 ASSERT_OK(iter->status()); in TEST_F()
[all …]
|