RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-10 13:10:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/os/seastore/async_cleaner: sort GCProcess interfaces

Browse Source 
Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
This commit is contained in:
Yingxin Cheng 2022-08-24 16:29:33 +08:00
parent b826e0cba6
commit 8dff965089
1 changed files with 38 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
src/crimson/os/seastore/async_cleaner.h
View File

@ -1086,38 +1086,6 @@ private:
*/
using gc_cycle_ret = seastar::future<>;
class GCProcess {
std::optional<gc_cycle_ret> process_join;
AsyncCleaner &cleaner;
std::optional<seastar::promise<>> blocking;
bool is_stopping() const {
return !process_join;
}
gc_cycle_ret run();
void wake() {
if (blocking) {
blocking->set_value();
blocking = std::nullopt;
}
}
seastar::future<> maybe_wait_should_run() {
return seastar::do_until(
[this] {
cleaner.log_gc_state("GCProcess::maybe_wait_should_run");
return is_stopping() || cleaner.gc_should_run();
},
[this] {
ceph_assert(!blocking);
blocking = seastar::promise<>();
return blocking->get_future();
});
}
bool is_running_until_halt = false;
public:
GCProcess(AsyncCleaner &cleaner) : cleaner(cleaner) {}
@ -1128,6 +1096,15 @@ private:
assert(!is_stopping());
}
void maybe_wake_on_space_used() {
if (is_stopping()) {
return;
}
if (cleaner.gc_should_run()) {
wake();
}
}
gc_cycle_ret stop() {
if (is_stopping()) {
return seastar::now();
@ -1162,14 +1139,37 @@ private:
);
}
void maybe_wake_on_space_used() {
if (is_stopping()) {
return;
}
if (cleaner.gc_should_run()) {
wake();
private:
bool is_stopping() const {
return !process_join;
}
gc_cycle_ret run();
void wake() {
if (blocking) {
blocking->set_value();
blocking = std::nullopt;
}
}
seastar::future<> maybe_wait_should_run() {
return seastar::do_until(
[this] {
cleaner.log_gc_state("GCProcess::maybe_wait_should_run");
return is_stopping() || cleaner.gc_should_run();
},
[this] {
ceph_assert(!blocking);
blocking = seastar::promise<>();
return blocking->get_future();
});
}
AsyncCleaner &cleaner;
std::optional<gc_cycle_ret> process_join;
std::optional<seastar::promise<>> blocking;
bool is_running_until_halt = false;
} gc_process;
using gc_ertr = work_ertr::extend_ertr<