wenchao-hao
/
lmkd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lmkd: enable ro.lmk.kill_timeout_ms to be used with kill notifications am: 03dccf35a1 am: d77a36e91b 

Change-Id: Ib92ac62009b7cefa3e265c29278080fabb51fb71
This commit is contained in:
Suren Baghdasaryan 2020-04-30 00:33:25 +00:00 committed by Automerger Merge Worker
parent f548154e2f d77a36e91b
commit 3967548543
1 changed files with 39 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
lmkd.cpp
View File

@ -2252,21 +2252,23 @@ static void mp_event_psi(int data, uint32_t events, struct polling_params *poll_
int min_score_adj = 0; int min_score_adj = 0;
int swap_util = 0; int swap_util = 0;
/* Skip while still killing a process */
if (is_kill_pending()) {
goto no_kill;
}
/*
* Process is dead, stop waiting. This has no effect if pidfds are supported and
* death notification already caused waiting to stop.
*/
stop_wait_for_proc_kill(true);
if (clock_gettime(CLOCK_MONOTONIC_COARSE, &curr_tm) != 0) { if (clock_gettime(CLOCK_MONOTONIC_COARSE, &curr_tm) != 0) {
ALOGE("Failed to get current time"); ALOGE("Failed to get current time");
return; return;
} }
bool kill_pending = is_kill_pending();
if (kill_pending &&
(kill_timeout_ms == 0 || get_time_diff_ms(&last_kill_tm, &curr_tm) < kill_timeout_ms)) {
/* Skip while still killing a process */
goto no_kill;
}
/*
* Process is dead or kill timeout is over, stop waiting. This has no effect if pidfds are
* supported and death notification already caused waiting to stop.
*/
stop_wait_for_proc_kill(!kill_pending);
if (vmstat_parse(&vs) < 0) { if (vmstat_parse(&vs) < 0) {
ALOGE("Failed to parse vmstat!"); ALOGE("Failed to parse vmstat!");
return; return;
@ -2933,6 +2935,15 @@ static int init(void) {
return 0; return 0;
} }
static bool polling_paused(struct polling_params *poll_params) {
return poll_params->paused_handler != NULL;
}
static void resume_polling(struct polling_params *poll_params, struct timespec curr_tm) {
poll_params->poll_start_tm = curr_tm;
poll_params->poll_handler = poll_params->paused_handler;
}
static void call_handler(struct event_handler_info* handler_info, static void call_handler(struct event_handler_info* handler_info,
struct polling_params *poll_params, uint32_t events) { struct polling_params *poll_params, uint32_t events) {
struct timespec curr_tm; struct timespec curr_tm;
@ -2959,8 +2970,7 @@ static void call_handler(struct event_handler_info* handler_info,
poll_params->poll_handler = NULL; poll_params->poll_handler = NULL;
break; break;
case POLLING_RESUME: case POLLING_RESUME:
poll_params->poll_start_tm = curr_tm; resume_polling(poll_params, curr_tm);
poll_params->poll_handler = poll_params->paused_handler;
break; break;
case POLLING_DO_NOT_CHANGE: case POLLING_DO_NOT_CHANGE:
if (get_time_diff_ms(&poll_params->poll_start_tm, &curr_tm) > PSI_WINDOW_SIZE_MS) { if (get_time_diff_ms(&poll_params->poll_start_tm, &curr_tm) > PSI_WINDOW_SIZE_MS) {
@ -3017,8 +3027,23 @@ static void mainloop(void) {
call_handler(poll_params.poll_handler, &poll_params, 0); call_handler(poll_params.poll_handler, &poll_params, 0);
} }
} else { } else {
/* Wait for events with no timeout */ if (kill_timeout_ms && is_waiting_for_kill()) {
nevents = epoll_wait(epollfd, events, maxevents, -1); clock_gettime(CLOCK_MONOTONIC_COARSE, &curr_tm);
delay = kill_timeout_ms - get_time_diff_ms(&last_kill_tm, &curr_tm);
/* Wait for pidfds notification or kill timeout to expire */
nevents = (delay > 0) ? epoll_wait(epollfd, events, maxevents, delay) : 0;
if (nevents == 0) {
/* Kill notification timed out */
stop_wait_for_proc_kill(false);
if (polling_paused(&poll_params)) {
clock_gettime(CLOCK_MONOTONIC_COARSE, &curr_tm);
resume_polling(&poll_params, curr_tm);
}
}
} else {
/* Wait for events with no timeout */
nevents = epoll_wait(epollfd, events, maxevents, -1);
}
} }
if (nevents == -1) { if (nevents == -1) {