gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 4 Packages Projects Releases Wiki Activity

Update oom_score_adjusted_by_redis to oom_score_adjusted_by_valkey in server.c (#229)

Browse Source 
Update oom_score_adjusted_by_redis to oom_score_adjusted_by_valkey in
server.c

Signed-off-by: Shivshankar-Reddy <shiva.sheri.github@gmail.com>
This commit is contained in:
Shivshankar 2024-04-17 23:53:22 -04:00 committed by GitHub
parent 3040c439b8
commit af47cffc83
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/server.c
View File

@ -2237,7 +2237,7 @@ int setOOMScoreAdj(int process_class) {
* when another configuration parameter was invalid and causes a rollback after
* applying a new oom-score) we can return to the oom-score value from before our
* adjustments. */
static int oom_score_adjusted_by_redis = 0;
static int oom_score_adjusted_by_valkey = 0;
static int oom_score_adj_base = 0;
int fd;
@ -2245,8 +2245,8 @@ int setOOMScoreAdj(int process_class) {
char buf[64];
if (server.oom_score_adj != OOM_SCORE_ADJ_NO) {
if (!oom_score_adjusted_by_redis) {
oom_score_adjusted_by_redis = 1;
if (!oom_score_adjusted_by_valkey) {
oom_score_adjusted_by_valkey = 1;
/* Backup base value before enabling the server control over oom score */
fd = open("/proc/self/oom_score_adj", O_RDONLY);
if (fd < 0 || read(fd, buf, sizeof(buf)) < 0) {
@ -2263,8 +2263,8 @@ int setOOMScoreAdj(int process_class) {
val += oom_score_adj_base;
if (val > 1000) val = 1000;
if (val < -1000) val = -1000;
} else if (oom_score_adjusted_by_redis) {
oom_score_adjusted_by_redis = 0;
} else if (oom_score_adjusted_by_valkey) {
oom_score_adjusted_by_valkey = 0;
val = oom_score_adj_base;
}
else {