| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_test.cc | 157 Status s; in TEST_P() local
265 Status s; in TEST_P() local
358 Status s; in TEST_P() local
539 auto s = in TEST_P() local
860 Status s; in TEST_P() local
1056 Status s; in TEST_P() local
1185 Status s; in TEST_P() local
1223 Status s; in TEST_P() local
1294 Status s; in TEST_P() local
1493 Status s; in TEST_P() local
[all …]
|
| D | optimistic_transaction_test.cc | 66 Status s = in Open() local
81 Status s; in TEST_P() local
110 Status s; in TEST_P() local
145 Status s; in TEST_P() local
180 Status s; in TEST_P() local
221 Status s; in TEST_P() local
238 Status s; in TEST_P() local
278 Status s; in TEST_P() local
447 Status s; in TEST_P() local
476 Status s; in TEST_P() local
[all …]
|
| D | pessimistic_transaction.cc | 169 return s; in CommitBatch()
173 Status s; in Prepare() local
220 return s; in Prepare()
260 return s; in PrepareInternal()
264 Status s; in Commit() local
344 return s; in Commit()
349 auto s = in CommitWithoutPrepareInternal() local
357 return s; in CommitWithoutPrepareInternal()
369 return s; in CommitBatchInternal()
387 auto s = in CommitInternal() local
[all …]
|
| D | transaction_base.cc | 251 return s; in Get()
283 return s; in GetForUpdate()
303 return s; in GetForUpdate()
390 return s; in Put()
407 return s; in Put()
424 return s; in Merge()
441 return s; in Delete()
458 return s; in Delete()
475 return s; in SingleDelete()
492 return s; in SingleDelete()
[all …]
|
| /rocksdb-6.9/examples/ |
| D | transaction_example.cc | 26 assert(s.ok()); in main()
49 assert(s.ok()); in main()
58 assert(s.ok()); in main()
67 assert(s.ok()); in main()
72 assert(s.ok()); in main()
77 assert(s.ok()); in main()
95 assert(s.ok()); in main()
99 assert(s.ok()); in main()
105 assert(s.ok()); in main()
141 assert(s.ok()); in main()
[all …]
|
| D | optimistic_transaction_example.cc | 26 assert(s.ok()); in main()
50 assert(s.ok()); in main()
60 assert(s.ok()); in main()
62 assert(s.ok()); in main()
70 assert(s.ok()); in main()
74 assert(s.ok()); in main()
92 assert(s.ok()); in main()
97 assert(s.ok()); in main()
113 assert(s.ok()); in main()
136 assert(s.ok()); in main()
[all …]
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.cc | 78 if (s.ok()) { in CreateCheckpoint()
82 return s; in CreateCheckpoint()
109 if (s.ok()) { in CreateCheckpoint()
163 return s; in CreateCheckpoint()
179 Status s; in CreateCustomCheckpoint() local
253 return s; in CreateCustomCheckpoint()
335 return s; in CreateCustomCheckpoint()
354 return s; in ExportColumnFamily()
466 return s; in ExportColumnFamily()
477 Status s; in ExportFilesInMetaData() local
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | env_librados.cc | 127 Status s; in Read() local
142 return s; in Read()
205 Status s; in Read() local
219 return s; in Read()
234 strncpy(id, _fid.c_str() + (_fid.size() - s), s); in GetUniqueId()
484 strncpy(id, _fid.c_str() + (_fid.size() - s), s); in GetUniqueId()
900 Status s; in NewSequentialFile() local
923 return s; in NewSequentialFile()
943 Status s; in NewRandomAccessFile() local
966 return s; in NewRandomAccessFile()
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_dump_tool.cc | 34 Status s; in Run() local
38 return s; in Run()
43 return s; in Run()
48 return s; in Run()
61 return s; in Run()
65 return s; in Run()
91 return s; in Run()
111 return s; in Read()
141 return s; in DumpBlobLogHeader()
169 return s; in DumpBlobLogFooter()
[all …]
|
| D | blob_file.cc | 128 return s; in WriteFooterAndCloseLocked()
143 Status s; in ReadFooter() local
152 if (!s.ok()) return s; in ReadFooter()
159 return s; in ReadFooter()
172 Status s; in Fsync() local
177 return s; in Fsync()
194 Status s; in GetReader() local
208 return s; in GetReader()
219 return s; in GetReader()
226 return s; in GetReader()
[all …]
|
| /rocksdb-6.9/file/ |
| D | writable_file_writer.cc | 27 IOStatus s; in Append() local
94 return s; in Append()
124 IOStatus s; in Close() local
131 return s; in Close()
163 return s; in Close()
169 IOStatus s; in Flush() local
221 return s; in Flush()
266 return s; in SyncWithoutFlush()
281 return s; in SyncInternal()
344 return s; in WriteBuffered()
[all …]
|
| D | delete_scheduler.cc | 58 Status s; in DeleteFile() local
69 return s; in DeleteFile()
83 return s; in DeleteFile()
100 return s; in DeleteFile()
117 Status s; in CleanupDirectory() local
122 return s; in CleanupDirectory()
146 return s; in CleanupDirectory()
157 Status s; in MarkAsTrash() local
161 return s; in MarkAsTrash()
187 return s; in MarkAsTrash()
[all …]
|
| /rocksdb-6.9/db/ |
| D | wal_manager.cc | 41 if (s.ok()) { in DeleteFile()
45 return s; in DeleteFile()
52 Status s; in GetSortedWalFiles() local
57 return s; in GetSortedWalFiles()
77 return s; in GetSortedWalFiles()
101 return s; in GetSortedWalFiles()
115 return s; in GetUpdatesSince()
120 return s; in GetUpdatesSince()
388 Status s; in ReadFirstRecord() local
415 return s; in ReadFirstRecord()
[all …]
|
| D | version_edit_handler.cc | 79 return s; in Iterate()
83 Status s; in Initialize() local
105 return s; in Initialize()
110 Status s; in ApplyVersionEdit() local
122 return s; in ApplyVersionEdit()
133 Status s; in OnColumnFamilyAdd() local
160 return s; in OnColumnFamilyAdd()
172 Status s; in OnColumnFamilyDrop() local
181 return s; in OnColumnFamilyDrop()
192 Status s; in OnNonCfOperation() local
[all …]
|
| D | snapshot_impl.h | 68 s->number_ = seq; in New()
71 s->list_ = this; in New()
72 s->next_ = &list_; in New()
73 s->prev_ = list_.prev_; in New()
74 s->prev_->next_ = s; in New()
75 s->next_->prev_ = s; in New()
77 return s; in New()
82 assert(s->list_ == this); in Delete()
83 s->prev_->next_ = s->next_; in Delete()
84 s->next_->prev_ = s->prev_; in Delete()
[all …]
|
| D | error_handler_fs_test.cc | 162 Status s; in TEST_F() local
194 Status s; in TEST_F() local
257 Status s; in TEST_F() local
300 Status s; in TEST_F() local
345 Status s; in TEST_F() local
396 Status s; in TEST_F() local
469 Status s; in TEST_F() local
524 Status s; in TEST_F() local
568 Status s; in TEST_F() local
756 ASSERT_EQ(s, s.NoSpace()); in TEST_F()
[all …]
|
| /rocksdb-6.9/db_stress_tool/ |
| D | no_batched_ops_stress.cc | 148 if (s.ok()) { in TestGet()
159 return s; in TestGet()
299 return s; in TestPrefixScan()
331 return s; in TestPut()
338 Status s; in TestPut() local
378 return s; in TestPut()
408 Status s; in TestDelete() local
454 return s; in TestDelete()
505 return s; in TestDeleteRange()
527 Status s; in TestIngestExternalFile() local
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 181 Status s; in SanitizeOptionsByTable() local
195 Status s; in ValidateOptions() local
203 return s; in ValidateOptions()
299 return s; in NewDB()
420 Status s; in Recover() local
598 return s; in Recover()
603 Status s; in PersistentStatsProcessFormatVersion() local
663 return s; in PersistentStatsProcessFormatVersion()
674 Status s; in InitPersistStatsColumnFamily() local
690 return s; in InitPersistStatsColumnFamily()
[all …]
|
| /rocksdb-6.9/util/ |
| D | coding_test.cc | 18 std::string s; in TEST() local
32 std::string s; in TEST() local
46 std::string s; in TEST() local
96 std::string s; in TEST() local
113 ASSERT_EQ(p, s.data() + s.size()); in TEST()
132 std::string s; in TEST() local
161 std::string s; in TEST() local
168 GetVarint32Ptr(s.data(), s.data() + s.size(), &result) != nullptr); in TEST()
181 std::string s; in TEST() local
188 GetVarint64Ptr(s.data(), s.data() + s.size(), &result) != nullptr); in TEST()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.cc | 355 Status s; in PrepareProcessing() local
407 return s; in ReadTraceHeader()
419 return s; in ReadTraceFooter()
435 return s; in ReadTraceRecord()
442 Status s; in StartProcessing() local
514 return s; in StartProcessing()
523 Status s; in MakeStatistics() local
663 Status s; in MakeStatisticKeyStatsOrPrefix() local
793 Status s; in MakeStatisticQPS() local
1005 Status s; in ReProcessing() local
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 91 Status s; in DBGet() local
115 if (s.ok()) { in DBGet()
128 return s; in DBGet()
133 Status s; in DoInsert() local
153 if (!s.ok()) { in DoInsert()
156 if (is_optimistic || !(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
164 if (s.ok()) { in DoInsert()
169 if (!get_for_update && (s.IsBusy() || s.IsTimedOut())) { in DoInsert()
194 if (s.ok()) { in DoInsert()
233 if (!(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
[all …]
|
| D | fault_injection_test_env.cc | 38 return s; in Truncate()
67 return s; in Truncate()
134 return s; in Append()
143 return s; in Close()
151 return s; in Flush()
249 return s; in NewWritableFile()
270 return s; in ReopenWritableFile()
291 return s; in NewRandomRWFile()
315 return s; in DeleteFile()
378 Status s; in DropFileData() local
[all …]
|
| /rocksdb-6.9/ |
| D | Makefile | 30 % : s.%
453 build_version.s: build_version.cc.s
692 db/builder.s: db/builder.cc.s
719 db/c.s: db/c.cc.s
1313 db/db_iter.s: db/db_iter.cc.s
1340 db/dbformat.s: db/dbformat.cc.s
1745 db/memtable.s: db/memtable.cc.s
1931 db/repair.s: db/repair.cc.s
2336 env/env.s: env/env.cc.s
5642 util/hash.s: util/hash.cc.s
[all …]
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 933 Status s; in TEST_F() local
949 ASSERT_OK(s); in TEST_F()
953 ASSERT_OK(s); in TEST_F()
966 ASSERT_OK(s); in TEST_F()
975 ASSERT_OK(s); in TEST_F()
989 ASSERT_OK(s); in TEST_F()
1037 ASSERT_OK(s); in TEST_F()
1050 ASSERT_OK(s); in TEST_F()
1599 Status s; in TEST_F() local
1714 Status s; in TEST_F() local
[all …]
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 1001 return s; in CreateNewBackupWithMetadata()
1193 Status s; in RestoreDBFromBackup() local
1254 return s; in RestoreDBFromBackup()
1301 Status s; in CopyOrCreateFile() local
1383 return s; in CopyOrCreateFile()
1400 Status s; in AddBackupFileWorkItem() local
1511 return s; in AddBackupFileWorkItem()
1550 return s; in CalculateChecksum()
1737 Status s; in Delete() local
1752 return s; in Delete()
[all …]
|