Home
last modified time | relevance | path

Searched refs:log (Results 1 – 25 of 93) sorted by relevance

1234

/rocksdb-6.9/options/
Ddb_options.cc124 ROCKS_LOG_HEADER(log, in Dump()
144 ROCKS_LOG_HEADER(log, in Dump()
156 ROCKS_LOG_HEADER(log, in Dump()
161 ROCKS_LOG_HEADER(log, in Dump()
164 ROCKS_LOG_HEADER(log, in Dump()
167 ROCKS_LOG_HEADER(log, in Dump()
209 ROCKS_LOG_HEADER(log, in Dump()
212 ROCKS_LOG_HEADER(log, in Dump()
217 log, in Dump()
240 ROCKS_LOG_HEADER(log, in Dump()
[all …]
Doptions.cc153 ROCKS_LOG_HEADER(log, in Dump()
163 ROCKS_LOG_HEADER(log, in Dump()
176 log, in Dump()
181 log, in Dump()
195 log, in Dump()
237 log, in Dump()
286 log, in Dump()
291 log, in Dump()
325 log, in Dump()
343 log, in Dump()
[all …]
Dcf_options.cc127 void MutableCFOptions::Dump(Logger* log) const { in Dump()
129 ROCKS_LOG_INFO(log, in Dump()
132 ROCKS_LOG_INFO(log, " max_write_buffer_number: %d", in Dump()
134 ROCKS_LOG_INFO(log, in Dump()
141 ROCKS_LOG_INFO(log, in Dump()
144 ROCKS_LOG_INFO(log, in Dump()
147 ROCKS_LOG_INFO(log, in Dump()
151 log, " prefix_extractor: %s", in Dump()
203 ROCKS_LOG_INFO(log, "compaction_options_universal.size_ratio : %d", in Dump()
212 ROCKS_LOG_INFO(log, in Dump()
[all …]
/rocksdb-6.9/build_tools/
Dprecommit_checker.py41 def log(self, str): member in Log
62 self.log.log("==== shell session ===========================")
63 self.log.log("%s> %s" % (path, cmd))
65 stdout=self.log.f, stderr=self.log.f)
66 self.log.log("status = %s" % status)
67 self.log.log("============================================== \n\n")
74 self.log.log("==== shell session ===========================")
75 self.log.log("%s> %s" % (path, cmd))
77 self.log.log("status = %s" % status)
78 self.log.log("out = %s" % out)
[all …]
Dmake_package.sh7 function log() { function
31 log "$1 is already installed. skipping."
38 log "$1 is already installed. skipping."
57 log "$1 is already installed. skipping."
68 log "using rocksdb version: $1"
Drun_ci_db_test.ps1324 param($exe, $test, $log);
325 &$exe --gtest_filter=$test > $log 2>&1
330 param($exe, $log)
331 &$exe > $log 2>&1
421 $log = $JobToLog[$completed] in RunJobs() variable
426 $log_content = @(Get-Content $log) in RunJobs()
/rocksdb-6.9/db/
Dlogs_with_prep_tracker.cc11 void LogsWithPrepTracker::MarkLogAsHavingPrepSectionFlushed(uint64_t log) { in MarkLogAsHavingPrepSectionFlushed() argument
12 assert(log != 0); in MarkLogAsHavingPrepSectionFlushed()
14 auto it = prepared_section_completed_.find(log); in MarkLogAsHavingPrepSectionFlushed()
16 prepared_section_completed_[log] = 1; in MarkLogAsHavingPrepSectionFlushed()
22 void LogsWithPrepTracker::MarkLogAsContainingPrepSection(uint64_t log) { in MarkLogAsContainingPrepSection() argument
23 assert(log != 0); in MarkLogAsContainingPrepSection()
30 for (; rit != logs_with_prep_.rend() && rit->log >= log; ++rit) { in MarkLogAsContainingPrepSection()
31 if (rit->log == log) { in MarkLogAsContainingPrepSection()
39 logs_with_prep_.insert(rit.base(), {log, 1}); in MarkLogAsContainingPrepSection()
48 auto min_log = it->log; in FindMinLogContainingOutstandingPrep()
Ddb_wal_test.cc363 for (auto& log : logs) { in TEST_F() local
364 if (log != ".." && log != ".") { in TEST_F()
365 CopyFile(options.wal_dir + "/" + log, backup_logs + "/" + log); in TEST_F()
376 for (auto& log : logs) { in TEST_F() local
377 if (log != ".." && log != ".") { in TEST_F()
378 CopyFile(backup_logs + "/" + log, options.wal_dir + "/" + log); in TEST_F()
394 for (auto& log : logs) { in TEST_F() local
395 if (log != ".." && log != ".") { in TEST_F()
396 CopyFile(backup_logs + "/" + log, options.wal_dir + "/" + log); in TEST_F()
410 if (log != ".." && log != ".") { in TEST_F()
[all …]
Dversion_set_test.cc742 std::unique_ptr<log::Writer> log_writer; in NewDB()
962 std::unique_ptr<log::Writer> log_writer_;
984 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1005 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1049 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1087 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1132 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1242 std::unique_ptr<log::Writer> log_writer; in TEST_P()
1373 std::unique_ptr<log::Writer> log_writer_;
1435 std::unique_ptr<log::Writer> log_writer_;
[all …]
Dlogs_with_prep_tracker.h23 void MarkLogAsHavingPrepSectionFlushed(uint64_t log);
25 void MarkLogAsContainingPrepSection(uint64_t log);
41 uint64_t log; // the log number member
Dversion_set.h56 namespace log {
1093 struct LogReporter : public log::Reader::Reporter {
1119 log::Writer* log);
1127 log::Reader* reader, AtomicGroupReadBuffer* read_buffer,
1183 std::unique_ptr<log::Writer> descriptor_log_;
1233 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader,
1237 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader,
1238 std::unique_ptr<log::Reader::Reporter>* manifest_reporter,
1257 log::Reader::Reporter* reporter,
1258 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader);
/rocksdb-6.9/utilities/blob_db/
Dblob_db.cc61 void BlobDBOptions::Dump(Logger* log) const { in Dump()
63 log, " BlobDBOptions.blob_dir: %s", in Dump()
66 log, " BlobDBOptions.path_relative: %d", in Dump()
69 log, " BlobDBOptions.is_fifo: %d", in Dump()
72 log, " BlobDBOptions.max_db_size: %" PRIu64, in Dump()
75 log, " BlobDBOptions.ttl_range_secs: %" PRIu64, in Dump()
78 log, " BlobDBOptions.min_blob_size: %" PRIu64, in Dump()
87 log, " BlobDBOptions.compression: %d", in Dump()
90 log, " BlobDBOptions.enable_garbage_collection: %d", in Dump()
93 log, " BlobDBOptions.garbage_collection_cutoff: %f", in Dump()
[all …]
/rocksdb-6.9/tools/advisor/test/input_files/
Dtest_rules.ini3 conditions=log-4-false
7 conditions=log-1-true:log-2-true:log-3-true
11 conditions=log-1-true:log-4-false:log-3-true
15 conditions=log-4-false:options-1-false
17 [Condition "log-1-true"]
21 [Condition "log-2-true"]
25 [Condition "log-3-true"]
29 [Condition "log-4-false"]
DLOG-03 …626725 7f82ba72e700 [db/flush_job.cc:301] [default] [JOB 3] Flushing memtable with next log file: 8
6 …f82b2f20700 [db/db_impl_write.cc:1373] [default] New memtable created with log file: #11. Immutabl…
13 …f82b2f20700 [db/db_impl_write.cc:1373] [default] New memtable created with log file: #24. Immutabl…
26 2018/05/25-14:34:21.049000 7f82bd676200 [db/db_impl.cc:563] [col-fam-A] random log message for test…
27 2018/05/25-14:34:21.049010 7f82bd676200 [db/db_impl.cc:234] [col-fam-B] log continuing on next line
28 remaining part of the log
29 2018/05/25-14:34:21.049020 7f82bd676200 [db/db_impl.cc:653] [col-fam-A] another random log message
30 2018/05/25-14:34:21.049025 7f82bd676200 [db/db_impl.cc:331] [unknown] random log message no column …
/rocksdb-6.9/docs/_posts/
D2014-03-27-how-to-persist-in-memory-rocksdb-database.markdown16 …log. Write-ahead log can be used to completely recover the data in memtable. By default, when we f…
18 … RocksDB stores write-ahead log files. If you configure this directory to be on flash or disk, you…
19 …chived log files. If the timeout is non-zero, obsolete log files will be moved to `archive/` direc…
23 You should configure the backup process to avoid backing up log files, since they are already store…
25 …log files in the backup, we need to make sure that restoring the database doesn't delete log files…
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier.cc35 Error(opt_.log, "Invalid block cache options"); in Open()
96 Error(opt_.log, "Error getting files for %s. %s", folder.c_str(), in CleanupCacheFolder()
105 Info(opt_.log, "Removing file %s.", file.c_str()); in CleanupCacheFolder()
108 Error(opt_.log, "Error deleting file %s. %s", file.c_str(), in CleanupCacheFolder()
113 ROCKS_LOG_DEBUG(opt_.log, "Skipping file %s", file.c_str()); in CleanupCacheFolder()
237 ROCKS_LOG_DEBUG(opt_.log, "Error inserting to cache file %d", in InsertImpl()
333 opt_.cache_file_size, opt_.log)); in NewCacheFile()
340 Info(opt_.log, "Created cache file %d", writer_cache_id_); in NewCacheFile()
349 Error(opt_.log, "Error inserting to metadata"); in NewCacheFile()
395 const std::shared_ptr<Logger>& log, in NewPersistentCache() argument
[all …]
Dpersistent_cache_bench.cc56 std::shared_ptr<Logger> log; in NewBlockCache() local
57 if (!Env::Default()->NewLogger(FLAGS_log_path, &log).ok()) { in NewBlockCache()
62 PersistentCacheConfig opt(Env::Default(), FLAGS_path, FLAGS_cache_size, log); in NewBlockCache()
92 std::shared_ptr<Logger> log; in NewTieredCache() local
93 if (!Env::Default()->NewLogger(FLAGS_log_path, &log).ok()) { in NewTieredCache()
100 (1 - pct) * FLAGS_cache_size, log); in NewTieredCache()
/rocksdb-6.9/tools/
Dbenchmark.sh190 echo $cmd | tee $output_dir/benchmark_bulkload_fillrandom.log
192 summarize_result $output_dir/benchmark_bulkload_fillrandom.log bulkload fillrandom
201 echo $cmd | tee $output_dir/benchmark_bulkload_compact.log
219 fillrandom_output_file=$output_dir/benchmark_man_compact_fillrandom_$3.log
220 man_compact_output_log=$output_dir/benchmark_man_compact_$3.log
309 log_file_name=$output_dir/benchmark_fillseq.wal_disabled.v${value_size}.log
312 log_file_name=$output_dir/benchmark_fillseq.wal_enabled.v${value_size}.log
361 echo $cmd | tee $output_dir/benchmark_filluniquerandom.log
363 summarize_result $output_dir/benchmark_filluniquerandom.log filluniquerandom filluniquerandom
444 echo $cmd | tee $output_dir/benchmark_rangescanwhilewriting.log
/rocksdb-6.9/tools/advisor/advisor/
Ddb_log_parser.py94 def trigger_conditions_for_log(self, conditions, log): argument
99 if re.search(cond.regex, log.get_message(), re.IGNORECASE):
103 if log.get_column_family() not in trigger:
104 trigger[log.get_column_family()] = []
105 trigger[log.get_column_family()].append(log)
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DLoggerTest.java33 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in customLogger()
62 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in warnLogger()
93 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in fatalLogger()
122 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in dbOptionsLogger()
162 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in setWarnLogLevel()
186 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in setInfoLogLevel()
211 protected void log(InfoLogLevel infoLogLevel, String logMsg) { in changeLogLevelAtRuntime()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc216 auto& log = logs_.front(); in FindObsoleteFiles() local
217 if (log.getting_synced) { in FindObsoleteFiles()
222 logs_to_free_.push_back(log.ReleaseWriter()); in FindObsoleteFiles()
590 auto log = loop_cfd->imm()->PrecomputeMinLogContainingPrepSection( in FindMinPrepLogReferencedByMemTable() local
593 if (log > 0 && (min_log == 0 || log < min_log)) { in FindMinPrepLogReferencedByMemTable()
594 min_log = log; in FindMinPrepLogReferencedByMemTable()
597 log = loop_cfd->mem()->GetMinLogContainingPrepSection(); in FindMinPrepLogReferencedByMemTable()
599 if (log > 0 && (min_log == 0 || log < min_log)) { in FindMinPrepLogReferencedByMemTable()
600 min_log = log; in FindMinPrepLogReferencedByMemTable()
Ddb_impl_secondary.h36 reader_ = new log::FragmentBufferedReader(info_log, std::move(file_reader), in LogReaderContainer()
40 log::FragmentBufferedReader* reader_;
41 log::Reader::Reporter* reporter_;
49 struct LogReporter : public log::Reader::Reporter {
217 log::FragmentBufferedReader** log_reader);
319 std::unique_ptr<log::FragmentBufferedReader> manifest_reader_;
320 std::unique_ptr<log::Reader::Reporter> manifest_reporter_;
Ddb_impl_open.cc285 log::Writer log(std::move(file_writer), 0, false); in NewDB() local
288 s = log.AddRecord(record); in NewDB()
290 s = SyncManifest(env_, &immutable_db_options_, log.file()); in NewDB()
542 for (auto& log : logs) { in Recover() local
697 struct LogReporter : public log::Reader::Reporter { in RecoverLogFiles()
1152 LogFileNumberSize log(log_number); in RestoreAliveLogFiles() local
1155 s = env_->GetFileSize(fname, &log.size); in RestoreAliveLogFiles()
1159 total_log_size_ += log.size; in RestoreAliveLogFiles()
1160 alive_log_files_.push_back(log); in RestoreAliveLogFiles()
1431 log::Writer* new_log = nullptr; in Open()
[all …]
/rocksdb-6.9/tools/rdb/
Dunit_test.js111 console.log("MARKER 1")
113 console.log("Should be no output between 'MARKER 1' and here\n")
114 console.log('Next line should be "a" => "apple"')
117 console.log("\nMARKER 2")
119 console.log("Should be no output between 'MARKER 2' and here\n")
/rocksdb-6.9/logging/
Dlog_buffer.cc60 for (BufferedLog* log : logs_) { in FlushBufferToLog()
61 const time_t seconds = log->now_tv.tv_sec; in FlushBufferToLog()
67 t.tm_sec, static_cast<int>(log->now_tv.tv_usec), log->message); in FlushBufferToLog()

1234