File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
src/crimson/os/alienstore Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,7 @@ CnLog::~CnLog() {
1717}
1818
1919void CnLog::_flush (EntryVector& q, bool crash) {
20+ // XXX: the waiting here will block the thread for an indeterministic peroid
2021 seastar::alien::submit_to (inst, shard, [&q] {
2122 for (auto & it : q) {
2223 crimson::get_logger (it.m_subsys ).log (
Original file line number Diff line number Diff line change @@ -57,10 +57,11 @@ class OnCommit final: public Context
5757 }
5858
5959 void finish (int ) final {
60- return seastar::alien::submit_to (alien, cpuid, [this ] {
61- alien_done.set_value ();
60+ std::ignore = seastar::alien::submit_to (alien, cpuid,
61+ [&_alien_done=this ->alien_done ] {
62+ _alien_done.set_value ();
6263 return seastar::make_ready_future<>();
63- }). wait () ;
64+ });
6465 }
6566};
6667}
You can’t perform that action at this time.
0 commit comments