Home
last modified time | relevance | path

Searched refs:db_options_ (Results 1 – 25 of 28) sorted by relevance

12

/rocksdb-6.9/db/
Dwal_manager.cc123 db_options_.wal_dir, &db_options_, read_options, file_options_, seq, in GetUpdatesSince()
137 bool const ttl_enabled = db_options_.wal_ttl_seconds > 0; in PurgeObsoleteWALFiles()
184 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
208 ROCKS_LOG_ERROR(db_options_.info_log, in PurgeObsoleteWALFiles()
220 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
249 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
257 s = DeleteDBFile(&db_options_, db_options_.wal_dir + "/" + file_path, in PurgeObsoleteWALFiles()
258 db_options_.wal_dir, false, in PurgeObsoleteWALFiles()
480 reporter.info_log = db_options_.info_log.get(); in ReadFirstLine()
483 reporter.ignore_error = !db_options_.paranoid_checks; in ReadFirstLine()
[all …]
Dwal_manager_test.cc36 db_options_(), in WalManagerTest()
48 db_options_.wal_dir = dbname_; in Init()
49 db_options_.env = env_.get(); in Init()
51 db_options_.fs = fs_; in Init()
109 ImmutableDBOptions db_options_; member in ROCKSDB_NAMESPACE::WalManagerTest
215 db_options_.wal_ttl_seconds = 0; in TEST_F()
216 db_options_.wal_size_limit_mb = 1000; in TEST_F()
236 db_options_.wal_size_limit_mb = 8; in TEST_F()
243 db_options_.wal_ttl_seconds = 1; in TEST_F()
253 db_options_.wal_ttl_seconds = 1000; in TEST_F()
[all …]
Dflush_job_test.cc36 db_options_(options_), in FlushJobTest()
43 db_options_.db_paths.emplace_back(dbname_,
54 db_options_.env = env_;
55 db_options_.fs = fs_;
66 if (db_options_.write_dbid_to_manifest) { in NewDB()
119 ImmutableDBOptions db_options_; member in ROCKSDB_NAMESPACE::FlushJobTest
134 EventLogger event_logger(db_options_.info_log.get()); in TEST_F()
217 EventLogger event_logger(db_options_.info_log.get()); in TEST_F()
279 EventLogger event_logger(db_options_.info_log.get()); in TEST_F()
352 EventLogger event_logger(db_options_.info_log.get()); in TEST_F()
[all …]
Drepair.cc116 wb_(db_options_.db_write_buffer_size), in Repairer()
117 wc_(db_options_.delayed_write_rate), in Repairer()
147 Options opts(db_options_, *cf_opts); in AddColumnFamily()
213 ROCKS_LOG_WARN(db_options_.info_log, in Run()
234 const DBOptions db_options_; member in ROCKSDB_NAMESPACE::__anon8d55d6080111::Repairer
271 same = db_options_.wal_dir == dbname_; in FindFiles()
324 ROCKS_LOG_WARN(db_options_.info_log, in ConvertLogFilesToTables()
358 reporter.info_log = db_options_.info_log; in ConvertLogToTable()
439 ROCKS_LOG_INFO(db_options_.info_log, in ConvertLogToTable()
493 db_options_.info_log, in ScanTable()
[all …]
Dflush_job.cc103 db_options_(db_options), in FlushJob()
300 const uint64_t start_micros = db_options_.env->NowMicros(); in WriteLevel0Table()
323 db_options_.info_log, in WriteLevel0Table()
351 ROCKS_LOG_INFO(db_options_.info_log, in WriteLevel0Table()
359 auto status = db_options_.env->GetCurrentTime(&_current_time); in WriteLevel0Table()
363 db_options_.info_log, in WriteLevel0Table()
380 dbname_, db_options_.env, db_options_.fs.get(), *cfd_->ioptions(), in WriteLevel0Table()
396 LogFlush(db_options_.info_log); in WriteLevel0Table()
398 ROCKS_LOG_INFO(db_options_.info_log, in WriteLevel0Table()
437 stats.micros = db_options_.env->NowMicros() - start_micros; in WriteLevel0Table()
[all …]
Dcolumn_family_test.cc82 db_options_.env = env_; in ColumnFamilyTestBase()
545 DBOptions db_options_; member in ROCKSDB_NAMESPACE::ColumnFamilyTestBase
687 db_options_.env = env_; in TEST_P()
747 db_options_.env = env_; in TEST_P()
1110 db_options_.env = env_; in TEST_P()
2978 db_options_.env = &env; in TEST_P()
3012 db_options_.env = env_; in TEST_P()
3020 db_options_.env = &env; in TEST_P()
3059 db_options_.env = env_; in TEST_P()
3067 db_options_.env = &env; in TEST_P()
[all …]
Derror_handler.cc131 db_options_.sst_file_manager.get()); in CancelErrorRecovery()
169 bool paranoid = db_options_.paranoid_checks; in SetBGError()
219 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
258 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
269 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
288 if (db_options_.sst_file_manager.get() == nullptr) { in OverrideNoSpaceError()
294 if (db_options_.allow_2pc && in OverrideNoSpaceError()
305 if (db_options_.env->GetFreeSpace(db_options_.db_paths[0].path, in OverrideNoSpaceError()
321 reinterpret_cast<SstFileManagerImpl*>(db_options_.sst_file_manager.get()); in RecoverFromNoSpace()
339 EventHelpers::NotifyOnErrorRecoveryCompleted(db_options_.listeners, in ClearBGError()
Dexternal_sst_file_ingestion_job.cc119 ROCKS_LOG_WARN(db_options_.info_log, in Prepare()
138 db_options_.use_fsync); in Prepare()
153 ROCKS_LOG_WARN(db_options_.info_log, in Prepare()
172 ROCKS_LOG_WARN(db_options_.info_log, in Prepare()
301 db_options_.info_log, in UpdateStats()
336 ROCKS_LOG_WARN(db_options_.info_log, in Cleanup()
349 db_options_.info_log, in Cleanup()
671 ROCKS_LOG_WARN(db_options_.info_log, in AssignGlobalSeqnoForIngestedFile()
722 if (db_options_.use_fsync) { in SyncIngestedFile()
Dimport_column_family_job.h31 db_options_(db_options), in ImportColumnFamilyJob()
32 fs_(db_options_.fs.get()), in ImportColumnFamilyJob()
63 const ImmutableDBOptions& db_options_; variable
Dimport_column_family_job.cc104 db_options_.use_fsync); in Prepare()
122 ROCKS_LOG_WARN(db_options_.info_log, in Prepare()
177 ROCKS_LOG_WARN(db_options_.info_log, in Cleanup()
189 db_options_.info_log, in Cleanup()
Dversion_set_test.cc622 db_options_(options_), in VersionSetTestBase()
624 immutable_cf_options_(db_options_, cf_options_), in VersionSetTestBase()
627 write_buffer_manager_(db_options_.db_write_buffer_size), in VersionSetTestBase()
648 db_options_.env = env_; in VersionSetTestBase()
649 db_options_.fs = fs_; in VersionSetTestBase()
655 dbname_, &db_options_, env_options_, table_cache_.get(), in VersionSetTestBase()
657 db_options_.db_paths.emplace_back(dbname_, in VersionSetTestBase()
683 if (db_options_.write_dbid_to_manifest) { in PrepareManifest()
771 ImmutableDBOptions db_options_; member in ROCKSDB_NAMESPACE::VersionSetTestBase
1412 if (db_options_.write_dbid_to_manifest) { in PrepareManifest()
[all …]
Derror_handler.h22 db_options_(db_options), in ErrorHandler()
64 const ImmutableDBOptions& db_options_; variable
Dwal_manager.h40 : db_options_(db_options), in db_options_() function
91 const ImmutableDBOptions& db_options_; variable
Dversion_set.cc3551 db_options_(_db_options), in VersionSet()
3951 LogFlush(db_options_->info_log); in ProcessManifestWrites()
4018 ROCKS_LOG_ERROR(db_options_->info_log, in ProcessManifestWrites()
4029 ROCKS_LOG_INFO(db_options_->info_log, in ProcessManifestWrites()
4298 db_options_->info_log, in ExtractInfoFromVersionEdit()
4575 if (db_options_->paranoid_checks) { in Recover()
4600 db_options_->info_log, in Recover()
4615 ROCKS_LOG_INFO(db_options_->info_log, in Recover()
5197 if (db_options_->write_dbid_to_manifest) { in WriteCurrentStateToManifest()
5584 db_options_->info_log, in VerifyCompactionFileConsistency()
[all …]
Dexternal_sst_file_ingestion_job.h80 db_options_(db_options), in ExternalSstFileIngestionJob()
165 const ImmutableDBOptions& db_options_; variable
Dversion_edit_handler.cc390 !(version_set_->db_options_->skip_stats_update_on_db_open)); in MaybeCreateVersion()
409 version_set_->db_options_->max_file_opening_threads, in LoadTables()
415 if (!s.ok() && !version_set_->db_options_->paranoid_checks) { in LoadTables()
564 !version_set_->db_options_->skip_stats_update_on_db_open); in MaybeCreateVersion()
Dflush_job.h107 const ImmutableDBOptions& db_options_; variable
Dversion_set.h970 assert(!db_options_->two_write_queues || s <= last_allocated_sequence_); in SetLastSequence()
1072 const ImmutableDBOptions* db_options() const { return db_options_; } in db_options()
1156 const ImmutableDBOptions* const db_options_; variable
Dcolumn_family.h710 const ImmutableDBOptions* const db_options_; variable
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc82 db_options_(db_options), in BlobDBImpl()
164 s = CreateLoggerFromOptions(dbname_, db_options_, &db_options_.info_log); in Open()
228 db_options_.info_log, in Open()
672 LogFlush(db_options_.info_log); in NewBlobFile()
1080 db_options_.info_log, in PutBlobValue()
1190 db_options_.info_log, in UpdateLiveSSTSize()
1410 db_options_.info_log, in GetBlobValue()
1506 db_options_.info_log, in GetRawBlobFromFile()
1515 db_options_.info_log, in GetRawBlobFromFile()
1531 db_options_.info_log, in GetRawBlobFromFile()
[all …]
Dblob_compaction_filter.cc66 ROCKS_LOG_INFO(context_gc_.blob_db_impl->db_options_.info_log, in ~BlobIndexCompactionFilterGC()
165 ROCKS_LOG_ERROR(blob_db_impl->db_options_.info_log, in OpenNewBlobFileIfNeeded()
191 ROCKS_LOG_ERROR(blob_db_impl->db_options_.info_log, in ReadBlobFromOldFile()
222 blob_db_impl->db_options_.info_log, in WriteBlobToNewFile()
274 ROCKS_LOG_ERROR(blob_db_impl->db_options_.info_log, in CloseAndRegisterNewBlobFile()
Dblob_db_impl_filesnapshot.cc34 ROCKS_LOG_INFO(db_options_.info_log, in DisableFileDeletions()
57 ROCKS_LOG_INFO(db_options_.info_log, "Enabled blob file deletions. count: %d", in EnableFileDeletions()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc314 db_options_(db_options), in CompactionJob()
705 LogFlush(db_options_.info_log); in Run()
870 compaction_filter, db_options_.info_log.get(), in ProcessKeyValueCompaction()
874 db_options_.statistics.get()); in ProcessKeyValueCompaction()
899 db_options_.info_log)); in ProcessKeyValueCompaction()
1321 io_s = sub_compact->outfile->Sync(db_options_.use_fsync); in FinishCompactionOutputFile()
1363 ROCKS_LOG_INFO(db_options_.info_log, in FinishCompactionOutputFile()
1487 db_options_.info_log, in OpenCompactionOutputFile()
1492 LogFlush(db_options_.info_log); in OpenCompactionOutputFile()
1505 ROCKS_LOG_WARN(db_options_.info_log, in OpenCompactionOutputFile()
[all …]
Dcompaction_job_test.cc77 db_options_(), in CompactionJobTest()
80 write_buffer_manager_(db_options_.db_write_buffer_size), in CompactionJobTest()
81 versions_(new VersionSet(dbname_, &db_options_, env_options_, in CompactionJobTest()
88 error_handler_(nullptr, db_options_, &mutex_) { in CompactionJobTest()
90 db_options_.env = env_; in CompactionJobTest()
91 db_options_.fs = fs_; in CompactionJobTest()
92 db_options_.db_paths.emplace_back(dbname_, in CompactionJobTest()
259 if (db_options_.write_dbid_to_manifest) { in NewDB()
326 EventLogger event_logger(db_options_.info_log.get());
330 0, &compaction, db_options_, env_options_, versions_.get(),
[all …]
Dcompaction_job.h155 const ImmutableDBOptions& db_options_; variable

12