Home
last modified time | relevance | path

Searched refs:logger (Results 1 – 25 of 59) sorted by relevance

123

/rocksdb-6.9/logging/
Dauto_roll_logger_test.cc51 ROCKS_LOG_INFO(logger, "%s", message); in LogMessage()
176 EXPECT_OK(logger->GetStatus()); in RollLogFileByTimeTest()
232 std::shared_ptr<Logger> logger; in TEST_F() local
263 delete logger; in TEST_F()
268 delete logger; in TEST_F()
296 std::shared_ptr<Logger> logger; in TEST_F() local
440 std::shared_ptr<Logger> logger; in TEST_F() local
620 Info(&logger, "Rollover"); in TEST_F()
624 LogFlush(&logger); in TEST_F()
665 std::shared_ptr<Logger> logger; in TEST_F() local
[all …]
Denv_logger_test.cc18 Log(logger, "%s", message.c_str()); in LogMessage()
25 LogMessage(logger, message); in WriteLogs()
59 auto logger = CreateLogger(); in TEST_F() local
60 ASSERT_EQ(logger->Close(), Status::OK()); in TEST_F()
70 auto logger = CreateLogger(); in TEST_F() local
77 logger->Flush(); in TEST_F()
87 auto logger = CreateLogger(); in TEST_F() local
101 auto logger = CreateLogger(); in TEST_F() local
114 auto logger = CreateLogger(); in TEST_F() local
128 auto logger = CreateLogger(); in TEST_F() local
[all …]
Dauto_roll_logger.h48 std::shared_ptr<Logger> logger; in GetLogFileSize() local
52 logger = logger_; in GetLogFileSize()
54 return logger->GetLogFileSize(); in GetLogFileSize()
58 std::shared_ptr<Logger> logger; in Flush() local
62 logger = logger_; in Flush()
65 if (logger) { in Flush()
66 logger->Flush(); in Flush()
162 std::shared_ptr<Logger>* logger);
Dauto_roll_logger.cc177 std::shared_ptr<Logger> logger; in Logv() local
194 ROCKS_LOG_WARN(logger.get(), "Fail to trim old info log file: %s", in Logv()
200 logger = logger_; in Logv()
209 logger->Logv(format, ap); in Logv()
252 std::shared_ptr<Logger>* logger) { in CreateLoggerFromOptions() argument
254 *logger = options.info_log; in CreateLoggerFromOptions()
276 logger->reset(result); in CreateLoggerFromOptions()
285 auto s = env->NewLogger(fname, logger); in CreateLoggerFromOptions()
286 if (logger->get() != nullptr) { in CreateLoggerFromOptions()
287 (*logger)->SetInfoLogLevel(options.info_log_level); in CreateLoggerFromOptions()
Devent_logger.cc18 EventLoggerStream::EventLoggerStream(Logger* logger) in EventLoggerStream() argument
19 : logger_(logger), in EventLoggerStream()
52 void EventLogger::Log(Logger* logger, const JSONWriter& jwriter) { in Log() argument
56 ROCKSDB_NAMESPACE::Log(logger, "%s %s", Prefix(), jwriter.Get().c_str()); in Log()
Devent_logger_test.cc28 StringLogger logger; in TEST_F() local
29 EventLogger event_logger(&logger); in TEST_F()
32 std::string output(logger.buffer()); in TEST_F()
Devent_logger.h164 explicit EventLoggerStream(Logger* logger);
184 explicit EventLogger(Logger* logger) : logger_(logger) {} in EventLogger() argument
194 static void Log(Logger* logger, const JSONWriter& jwriter);
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DLoggerTest.java30 final Logger logger = new Logger(options) { in customLogger()
41 options.setLogger(logger); in customLogger()
59 final Logger logger = new Logger(options) { in warnLogger()
71 options.setLogger(logger); in warnLogger()
102 options.setLogger(logger); in fatalLogger()
130 options.setLogger(logger); in dbOptionsLogger()
169 assertThat(logger.infoLogLevel()). in setWarnLogLevel()
172 assertThat(logger.infoLogLevel()). in setWarnLogLevel()
193 assertThat(logger.infoLogLevel()). in setInfoLogLevel()
196 assertThat(logger.infoLogLevel()). in setInfoLogLevel()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DSstFileManager.java47 public SstFileManager(final Env env, /*@Nullable*/ final Logger logger) in SstFileManager() argument
49 this(env, logger, RATE_BYTES_PER_SEC_DEFAULT); in SstFileManager()
67 public SstFileManager(final Env env, /*@Nullable*/ final Logger logger, in SstFileManager() argument
69 this(env, logger, rateBytesPerSec, MAX_TRASH_DB_RATION_DEFAULT); in SstFileManager()
90 public SstFileManager(final Env env, /*@Nullable*/ final Logger logger, in SstFileManager() argument
93 this(env, logger, rateBytesPerSec, maxTrashDbRatio, in SstFileManager()
118 public SstFileManager(final Env env, /*@Nullable*/final Logger logger, in SstFileManager() argument
122 logger != null ? logger.nativeHandle_ : 0, in SstFileManager()
DBackupableDBOptions.java127 public BackupableDBOptions setInfoLog(final Logger logger) { in setInfoLog() argument
129 setInfoLog(nativeHandle_, logger.nativeHandle_); in setInfoLog()
130 this.infoLog = logger; in setInfoLog()
DPersistentCache.java15 final Logger logger, final boolean optimizedForNvm) in PersistentCache() argument
18 logger.nativeHandle_, optimizedForNvm)); in PersistentCache()
/rocksdb-6.9/utilities/merge_operators/
Duint64add.cc25 Logger* logger) const override { in Merge()
28 orig_value = DecodeInteger(*existing_value, logger); in Merge()
30 uint64_t operand = DecodeInteger(value, logger); in Merge()
44 uint64_t DecodeInteger(const Slice& value, Logger* logger) const { in DecodeInteger()
49 } else if (logger != nullptr) { in DecodeInteger()
51 ROCKS_LOG_ERROR(logger, "uint64 value corruption, size: %" ROCKSDB_PRIszt in DecodeInteger()
/rocksdb-6.9/db/
Dmerge_operator.cc23 &merge_out->new_value, merge_in.logger); in FullMergeV2()
32 Logger* logger) const { in PartialMergeMulti()
40 if (!PartialMerge(key, temp_slice, operand, &temp_value, logger)) { in PartialMergeMulti()
63 merge_in.logger)) { in FullMergeV2()
82 Logger* logger) const { in PartialMerge()
83 return Merge(key, &left_operand, right_operand, new_value, logger); in PartialMerge()
Dmerge_helper.cc25 Logger* logger, bool assert_valid_internal_key, in MergeHelper() argument
35 logger_(logger), in MergeHelper()
54 std::string* result, Logger* logger, in TimedFullMerge() argument
74 logger); in TimedFullMerge()
/rocksdb-6.9/utilities/
Dobject_registry.cc35 void ObjectLibrary::Dump(Logger *logger) const { in Dump()
37 ROCKS_LOG_HEADER(logger, " Registered factories for type[%s] ", in Dump()
41 ROCKS_LOG_HEADER(logger, "%c %s", (printed_one) ? ',' : ':', in Dump()
46 ROCKS_LOG_HEADER(logger, "\n"); in Dump()
80 void ObjectRegistry::Dump(Logger *logger) const { in Dump()
82 iter->get()->Dump(logger); in Dump()
/rocksdb-6.9/include/rocksdb/
Dmerge_operator.h85 logger(_logger) {} in MergeOperationInput()
96 Logger* logger; member
193 std::string* new_value, Logger* logger) const;
245 Logger* logger) const = 0;
254 Logger* logger) const override;
Dmemtablerep.h283 Logger* logger) = 0;
286 const SliceTransform* slice_transform, Logger* logger, in CreateMemTableRep() argument
288 return CreateMemTableRep(key_cmp, allocator, slice_transform, logger); in CreateMemTableRep()
318 Logger* logger) override;
347 Logger* logger) override;
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.h250 ROCKS_LOG_ERROR(merge_in.logger, in FullMergeV2()
260 merge_in.logger, in FullMergeV2()
277 operands_without_ts, merge_in.logger), in FullMergeV2()
282 merge_in.logger), in FullMergeV2()
301 merge_in.logger, in FullMergeV2()
315 std::string* new_value, Logger* logger) const in PartialMergeMulti() argument
322 ROCKS_LOG_ERROR(logger, in PartialMergeMulti()
334 logger)) { in PartialMergeMulti()
342 logger, in PartialMergeMulti()
/rocksdb-6.9/memory/
Darena.cc157 Logger* logger) { in AllocateAligned() argument
164 assert(logger != nullptr); // logger need to be passed in. in AllocateAligned()
171 ROCKS_LOG_WARN(logger, in AllocateAligned()
181 (void)logger; in AllocateAligned()
/rocksdb-6.9/table/plain/
Dplain_table_bloom.h42 Logger* logger);
120 Logger* logger) { in SetTotalBits() argument
122 logger); in SetTotalBits()
/rocksdb-6.9/utilities/merge_operators/string_append/
Dstringappend2.h33 std::string* new_value, Logger* logger) const
43 std::string* new_value, Logger* logger) const;
/rocksdb-6.9/table/
Dget_context.cc42 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument
51 logger_(logger), in GetContext()
75 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument
81 : GetContext(ucmp, merge_operator, logger, statistics, init_state, user_key, in GetContext()
/rocksdb-6.9/java/rocksjni/
Dpersistent_cache.cc32 auto* logger = in Java_org_rocksdb_PersistentCache_newPersistentCache() local
38 rocks_env, path, static_cast<uint64_t>(jsz), *logger, in Java_org_rocksdb_PersistentCache_newPersistentCache()
/rocksdb-6.9/memtable/
Dhash_linklist_rep.cc167 size_t huge_page_tlb_size, Logger* logger,
497 uint32_t threshold_use_skiplist, size_t huge_page_tlb_size, Logger* logger, in HashLinkListRep() argument
506 logger_(logger), in HashLinkListRep()
510 huge_page_tlb_size, logger); in HashLinkListRep()
827 const SliceTransform* transform, Logger* logger) { in CreateMemTableRep() argument
830 logger, bucket_entries_logging_threshold_, in CreateMemTableRep()
/rocksdb-6.9/util/
Ddynamic_bloom.cc30 Logger* logger) in DynamicBloom() argument
58 char* raw = allocator->AllocateAligned(sz, huge_page_tlb_size, logger); in DynamicBloom()

123