bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

dirty_memory_manager: reindent region_group::release_queued_allocations()

Browse Source
This commit is contained in:
Avi Kivity
2022-10-07 17:02:45 +03:00
parent 128f1c8c21
commit 02706e78f9
1 changed files with 13 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
dirty_memory_manager.cc
View File

@@ -107,23 +107,19 @@ region_group::start_releaser(scheduling_group deferred_work_sg) {
}
future<> region_group::release_queued_allocations() {
{
{
while (!_shutdown_requested) {
if (!_blocked_requests.empty() && execution_permitted()) {
execute_one();
co_await coroutine::maybe_yield();
} else {
// We want `rl` to hold for the call to _relief.wait(), but not to wait
// for the future to resolve, hence the inner lambda.
co_await std::invoke([&] {
// Block reclaiming to prevent signal() from being called by reclaimer inside wait()
// FIXME: handle allocation failures (not very likely) like allocating_section does
tracker_reclaimer_lock rl(logalloc::shard_tracker());
return _relief.wait();
});
}
}
while (!_shutdown_requested) {
if (!_blocked_requests.empty() && execution_permitted()) {
execute_one();
co_await coroutine::maybe_yield();
} else {
// We want `rl` to hold for the call to _relief.wait(), but not to wait
// for the future to resolve, hence the inner lambda.
co_await std::invoke([&] {
// Block reclaiming to prevent signal() from being called by reclaimer inside wait()
// FIXME: handle allocation failures (not very likely) like allocating_section does
tracker_reclaimer_lock rl(logalloc::shard_tracker());
return _relief.wait();
});
}
}
}