andreacavalli/rocksdb
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Apply InfoLogLevel to the logs in db/flush_job.cc

Browse Source 
Summary: Apply InfoLogLevel to the logs in db/flush_job.cc

Test Plan: make

Reviewers: ljin, sdong, igor

Reviewed By: igor

Subscribers: dhruba, leveldb

Differential Revision: https://reviews.facebook.net/D27849
This commit is contained in:
Yueh-Hsuan Chiang 2014-10-29 15:12:10 -07:00
parent 34d436b7db
commit c4b468000b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
db/flush_job.cc
View File

@ -145,7 +145,7 @@ Status FlushJob::WriteLevel0Table(const autovector<MemTable*>& mems,
ro.total_order_seek = true; ro.total_order_seek = true;
Arena arena; Arena arena;
for (MemTable* m : mems) { for (MemTable* m : mems) {
Log(db_options_.info_log, Log(InfoLogLevel::INFO_LEVEL, db_options_.info_log,
"[%s] Flushing memtable with next log file: %" PRIu64 "\n", "[%s] Flushing memtable with next log file: %" PRIu64 "\n",
cfd_->GetName().c_str(), m->GetNextLogNumber()); cfd_->GetName().c_str(), m->GetNextLogNumber());
memtables.push_back(m->NewIterator(ro, &arena)); memtables.push_back(m->NewIterator(ro, &arena));
@ -154,7 +154,7 @@ Status FlushJob::WriteLevel0Table(const autovector<MemTable*>& mems,
ScopedArenaIterator iter(NewMergingIterator(&cfd_->internal_comparator(), ScopedArenaIterator iter(NewMergingIterator(&cfd_->internal_comparator(),
&memtables[0], &memtables[0],
memtables.size(), &arena)); memtables.size(), &arena));
Log(db_options_.info_log, Log(InfoLogLevel::INFO_LEVEL, db_options_.info_log,
"[%s] Level-0 flush table #%" PRIu64 ": started", "[%s] Level-0 flush table #%" PRIu64 ": started",
cfd_->GetName().c_str(), meta.fd.GetNumber()); cfd_->GetName().c_str(), meta.fd.GetNumber());
@ -165,7 +165,7 @@ Status FlushJob::WriteLevel0Table(const autovector<MemTable*>& mems,
cfd_->ioptions()->compression_opts, Env::IO_HIGH); cfd_->ioptions()->compression_opts, Env::IO_HIGH);
LogFlush(db_options_.info_log); LogFlush(db_options_.info_log);
} }
Log(db_options_.info_log, Log(InfoLogLevel::INFO_LEVEL, db_options_.info_log,
"[%s] Level-0 flush table #%" PRIu64 ": %" PRIu64 " bytes %s", "[%s] Level-0 flush table #%" PRIu64 ": %" PRIu64 " bytes %s",
cfd_->GetName().c_str(), meta.fd.GetNumber(), meta.fd.GetFileSize(), cfd_->GetName().c_str(), meta.fd.GetNumber(), meta.fd.GetFileSize(),
s.ToString().c_str()); s.ToString().c_str());