gian/ceph-mirror
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2026-08-03 07:22:20 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

crimson/os/alienstore/alien_log: _flush concurrently

Browse Source 
In continuation to c15e56e386

Authored-by: Yingxin Cheng <yingxin.cheng@intel.com>
Signed-off-by: Matan Breizman <mbreizma@redhat.com>
This commit is contained in:
Matan Breizman 2024-01-21 09:33:59 +00:00
parent 19aa8fc73d
commit 511af83e27
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/crimson/os/alienstore/alien_log.cc
View File

@ -17,8 +17,7 @@ CnLog::~CnLog() {
}
void CnLog::_flush(EntryVector& q, bool crash) {
// XXX: the waiting here will block the thread for an indeterministic peroid
seastar::alien::submit_to(inst, shard, [&q] {
std::ignore = seastar::alien::submit_to(inst, shard, [&q] {
for (auto& it : q) {
crimson::get_logger(it.m_subsys).log(
crimson::to_log_level(it.m_prio),
@ -26,7 +25,7 @@ void CnLog::_flush(EntryVector& q, bool crash) {
it.strv());
}
return seastar::make_ready_future<>();
}).wait();
});
q.clear();
return;
}