mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-12 19:05:47 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

chore: fix a regression build break (#4162)

Browse source
This commit is contained in:
Roman Gershman 2024-11-21 12:40:18 +02:00 • committed by GitHub
parent 581cfbf6c5
commit a694bf46b8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/server/main_service.cc
View file

@ -722,6 +722,16 @@ string FailedCommandToString(std::string_view command, facade::CmdArgList args,
return result; return result;
} }
void SetOomDenyRatioOnAllThreads(double ratio) {
auto cb = [ratio](unsigned, auto*) { ServerState::tlocal()->oom_deny_ratio = ratio; };
shard_set->pool()->AwaitBrief(cb);
}
void SetRssOomDenyRatioOnAllThreads(double ratio) {
auto cb = [ratio](unsigned, auto*) { ServerState::tlocal()->rss_oom_deny_ratio = ratio; };
shard_set->pool()->AwaitBrief(cb);
}
} // namespace } // namespace
Service::Service(ProactorPool* pp) Service::Service(ProactorPool* pp)
@ -734,7 +744,7 @@ Service::Service(ProactorPool* pp)
#ifdef PRINT_STACKTRACES_ON_SIGNAL #ifdef PRINT_STACKTRACES_ON_SIGNAL
LOG(INFO) << "PRINT STACKTRACES REGISTERED"; LOG(INFO) << "PRINT STACKTRACES REGISTERED";
pp_.GetNextProactor()->RegisterSignal({SIGUSR1}, [this](int signal) { ProactorBase::RegisterSignal({SIGUSR1}, pp_.GetNextProactor(), [this](int signal) {
LOG(INFO) << "Received " << strsignal(signal); LOG(INFO) << "Received " << strsignal(signal);
base::SetVLogLevel("uring_proactor", 2); base::SetVLogLevel("uring_proactor", 2);
@ -759,17 +769,11 @@ Service::Service(ProactorPool* pp)
engine_varz.emplace("engine", [this] { return GetVarzStats(); }); engine_varz.emplace("engine", [this] { return GetVarzStats(); });
} }
void SetOomDenyRatioOnAllThreads(double ratio) {
auto cb = [ratio](unsigned, auto*) { ServerState::tlocal()->oom_deny_ratio = ratio; };
shard_set->pool()->AwaitBrief(cb);
}
void SetRssOomDenyRatioOnAllThreads(double ratio) {
auto cb = [ratio](unsigned, auto*) { ServerState::tlocal()->rss_oom_deny_ratio = ratio; };
shard_set->pool()->AwaitBrief(cb);
}
Service::~Service() { Service::~Service() {
#ifdef PRINT_STACKTRACES_ON_SIGNAL
ProactorBase::ClearSignal({SIGUSR1});
#endif
delete shard_set; delete shard_set;
shard_set = nullptr; shard_set = nullptr;
} }