| /rocksdb-6.9/logging/ |
| D | auto_roll_logger.h | 44 if (!logger_) { in GetLogFileSize()
52 logger = logger_; in GetLogFileSize()
62 logger = logger_; in Flush()
71 if (logger_ && !closed_) { in ~AutoRollLogger()
72 logger_->Close(); in ~AutoRollLogger()
79 if (!logger_) { in GetInfoLogLevel()
82 return logger_->GetInfoLogLevel(); in GetInfoLogLevel()
89 if (logger_) { in SetInfoLogLevel()
110 if (logger_) { in CloseImpl()
111 return logger_->Close(); in CloseImpl()
[all …]
|
| D | auto_roll_logger.cc | 56 status_ = env_->NewLogger(log_fname_, &logger_); in ResetLogger()
62 assert(logger_); in ResetLogger()
63 logger_->SetInfoLogLevel(Logger::GetInfoLogLevel()); in ResetLogger()
65 if (logger_->GetLogFileSize() == Logger::kDoNotSupportGetLogFileSize) { in ResetLogger()
161 if (!logger_) { in LogInternal()
167 logger_->Logv(format, args); in LogInternal()
173 if (!logger_) { in Logv()
181 (kMaxLogFileSize > 0 && logger_->GetLogFileSize() >= kMaxLogFileSize)) { in Logv()
200 logger = logger_; in Logv()
220 if (!logger_) { in LogHeader()
[all …]
|
| D | event_logger.cc | 19 : logger_(logger), in EventLoggerStream()
26 : logger_(nullptr), in EventLoggerStream()
37 if (logger_) { in ~EventLoggerStream()
38 EventLogger::Log(logger_, *json_writer_); in ~EventLoggerStream()
49 Log(logger_, jwriter); in Log()
|
| D | event_logger.h | 167 Logger* const logger_; variable
184 explicit EventLogger(Logger* logger) : logger_(logger) {} in EventLogger()
185 EventLoggerStream Log() { return EventLoggerStream(logger_); } in Log()
200 Logger* logger_;
|
| /rocksdb-6.9/db/ |
| D | db_iter.cc | 45 logger_(cf_options.info_log), in DBIter()
112 ROCKS_LOG_ERROR(logger_, "corrupted internal key in DBIter: %s", in ParseKey()
453 ROCKS_LOG_ERROR(logger_, "Options::merge_operator is null."); in MergeValuesNewToOld()
491 &saved_value_, logger_, statistics_, env_, &pinned_value_, true); in MergeValuesNewToOld()
512 ROCKS_LOG_ERROR(logger_, "Encounter unexpected blob index."); in MergeValuesNewToOld()
538 &saved_value_, logger_, statistics_, env_, in MergeValuesNewToOld()
826 ROCKS_LOG_ERROR(logger_, "Encounter unexpected blob index."); in FindValueForCurrentKey()
849 ROCKS_LOG_ERROR(logger_, "Encounter unexpected blob index."); in FindValueForCurrentKey()
927 ROCKS_LOG_ERROR(logger_, "Encounter unexpected blob index."); in FindValueForCurrentKeyUsingSeek()
974 merge_context_.GetOperands(), &saved_value_, logger_, statistics_, in FindValueForCurrentKeyUsingSeek()
[all …]
|
| D | merge_helper.cc | 35 logger_(logger), in MergeHelper()
215 merge_context_.GetOperands(), &merge_result, logger_, in MergeUntil()
323 merge_context_.GetOperands(), &merge_result, logger_, in MergeUntil()
353 &merge_result, logger_); in MergeUntil()
|
| D | version_set_test.cc | 188 ASSERT_EQ(0, logger_->log_count); in TEST_F()
198 ASSERT_EQ(0, logger_->log_count); in TEST_F()
203 ASSERT_EQ(0, logger_->log_count); in TEST_F()
209 ASSERT_EQ(0, logger_->log_count); in TEST_F()
216 ASSERT_EQ(1, logger_->log_count); in TEST_F()
223 logger_->log_count = 0; in TEST_F()
225 ASSERT_EQ(1, logger_->log_count); in TEST_F()
250 ASSERT_EQ(0, logger_->log_count); in TEST_F()
269 ASSERT_EQ(0, logger_->log_count); in TEST_F()
288 ASSERT_EQ(0, logger_->log_count); in TEST_F()
[all …]
|
| D | merge_helper.h | 144 Logger* logger_; variable
|
| D | db_iter.h | 275 Logger* logger_; variable
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 29 logger_(logger), in SstFileManagerImpl()
203 ROCKS_LOG_ERROR(logger_, in EnoughRoomForCompaction()
286 ROCKS_LOG_ERROR(logger_, in ClearError()
291 ROCKS_LOG_ERROR(logger_, "Cannot clear hard error\n"); in ClearError()
296 ROCKS_LOG_WARN(logger_, in ClearError()
302 ROCKS_LOG_WARN(logger_, "Cannot clear soft error\n"); in ClearError()
356 ROCKS_LOG_INFO(logger_, "Clearing error\n"); in ClearError()
|
| D | sst_file_manager_impl.h | 152 std::shared_ptr<Logger> logger_; variable
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 51 logger_(logger), in GetContext()
260 logger_, statistics_, env_); in SaveValue()
300 logger_, statistics_, env_); in SaveValue()
328 logger_, statistics_, env_); in SaveValue()
|
| D | get_context.h | 166 Logger* logger_; variable
|
| /rocksdb-6.9/memtable/ |
| D | hash_linklist_rep.cc | 205 Logger* logger_; member in ROCKSDB_NAMESPACE::__anoncfd1c5190111::HashLinkListRep
506 logger_(logger), in HashLinkListRep()
620 Info(logger_, "HashLinkedList bucket %" ROCKSDB_PRIszt in Insert()
773 if (if_log_bucket_dist_when_flash_ && logger_ != nullptr) { in GetIterator()
774 Info(logger_, "hashLinkedList Entry distribution among buckets: %s", in GetIterator()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 555 CreateLoggerFromOptions(dbname_, logger_options, &logger_); in BackupableDBTest()
559 backupdir_, test_backup_env_.get(), true, logger_.get(), true)); in BackupableDBTest()
666 std::shared_ptr<Logger> logger_; member in ROCKSDB_NAMESPACE::__anon6f9a36820111::BackupableDBTest
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_picker_test.cc | 38 CountingLogger logger_; member in ROCKSDB_NAMESPACE::CompactionPickerTest
57 log_buffer_(InfoLogLevel::INFO_LEVEL, &logger_), in CompactionPickerTest()
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd_impl.h | 528 std::unique_ptr<Logger> logger_; variable
|
| D | ldb_cmd.cc | 2967 logger_.reset(
3008 backup_options.info_log = logger_.get(); in DoCommand()
3047 opts.info_log = logger_.get(); in DoCommand()
|