Android LowMemoryKiller原理分析
t899in80
8年前
<pre> frameworks/base/services/core/java/com/android/server/am/ProcessList.java platform/system/core/lmkd/lmkd.c kernel/common/drivers/staging/Android/lowmemorykiller.c</pre> <h2><strong>一. 概述</strong></h2> <p>Android的设计理念之一，便是应用程序退出,但进程还会继续存在系统以便再次启动时提高响应时间. 这样的设计会带来一个问题, 每个进程都有自己独立的内存地址空间，随着应用打开数量的增多,系统已使用的内存越来越大，就很有可能导致系统内存不足, 那么需要一个能管理所有进程，根据一定策略来释放进程的策略，这便有了 lmk ，全称为LowMemoryKiller(低内存杀手)，lmkd来决定什么时间杀掉什么进程.</p> <p>Android基于Linux的系统，其实Linux有类似的内存管理策略——OOM killer，全称(Out Of Memory Killer), OOM的策略更多的是用于分配内存不足时触发，将得分最高的进程杀掉。而 lmk 则会每隔一段时间检查一次，当系统剩余可用内存较低时，便会触发杀进程的策略，根据不同的剩余内存档位来来选择杀不同优先级的进程，而不是等到OOM时再来杀进程，真正OOM时系统可能已经处于异常状态，系统更希望的是未雨绸缪，在内存很低时来杀掉一些优先级较低的进程来保障后续操作的顺利进行。</p> <h2><strong>二. framework层</strong></h2> <p>位于 ProcessList.java 中定义了3种命令类型，这些文件的定义必须跟 lmkd.c 定义完全一致，格式分别如下：</p> <pre> LMK_TARGET <minfree> <minkillprio> ... (up to 6 pairs) LMK_PROCPRIO <pid> <prio> LMK_PROCREMOVE <pid></pre> <table> <thead> <tr> <th>功能</th> <th>命令</th> <th>对应方法</th> <th>触发时机</th> </tr> </thead> <tbody> <tr> <td>更新oom_adj</td> <td>LMK_TARGET</td> <td>updateOomLevels</td> <td>AMS.updateConfiguration</td> </tr> <tr> <td>设置进程adj</td> <td>LMK_PROCPRIO</td> <td>setOomAdj</td> <td>AMS.applyOomAdjLocked</td> </tr> <tr> <td>移除进程</td> <td>LMK_PROCREMOVE</td> <td>remove</td> <td>AMS.handleAppDiedLocked/cleanUpApplicationRecordLocked</td> </tr> </tbody> </table> <p>在前面文章 <a href="/misc/goto?guid=4959716594579781481" rel="nofollow,noindex">Android进程调度之adj算法</a> 中有讲到 AMS.applyOomAdjLocked ，接下来以这个过程为主线开始分析。</p> <h3><strong>2.1 AMS.applyOomAdjLocked</strong></h3> <pre> private final boolean applyOomAdjLocked(ProcessRecord app, boolean doingAll, long now, long nowElapsed) { ... if (app.curAdj != app.setAdj) { //【见小节2.2】 ProcessList.setOomAdj(app.pid, app.info.uid, app.curAdj); app.setAdj = app.curAdj; } ... }</pre> <h3><strong>2.2 PL.setOomAdj</strong></h3> <pre> public static final void setOomAdj(int pid, int uid, int amt) { //当adj=16，则直接返回 if (amt == UNKNOWN_ADJ) return; long start = SystemClock.elapsedRealtime(); ByteBuffer buf = ByteBuffer.allocate(4 * 4); buf.putInt(LMK_PROCPRIO); buf.putInt(pid); buf.putInt(uid); buf.putInt(amt); //将16Byte字节写入socket【见小节2.3】 writeLmkd(buf); long now = SystemClock.elapsedRealtime(); if ((now-start) > 250) { Slog.w("ActivityManager", "SLOW OOM ADJ: " + (now-start) + "ms for pid " + pid + " = " + amt); } }</pre> <p>buf大小为16个字节，依次写入LMK_PROCPRIO(命令类型), pid(进程pid), uid(进程uid), amt(目标adj)，将这些字节通过socket发送给lmkd.</p> <h3><strong>2.3 PL.writeLmkd</strong></h3> <pre> private static void writeLmkd(ByteBuffer buf) { //当socket打开失败会尝试3次 for (int i = 0; i < 3; i++) { if (sLmkdSocket == null) { //打开socket 【见小节2.4】 if (openLmkdSocket() == false) { try { Thread.sleep(1000); } catch (InterruptedException ie) { } continue; } } try { //将buf信息写入lmkd socket sLmkdOutputStream.write(buf.array(), 0, buf.position()); return; } catch (IOException ex) { try { sLmkdSocket.close(); } catch (IOException ex2) { } sLmkdSocket = null; } } }</pre> <ul> <li>当sLmkdSocket为空，并且打开失败，重新执行该操作；</li> <li>当sLmkdOutputStream写入buf信息失败，则会关闭sLmkdSocket，重新执行该操作；</li> </ul> <p>这个重新执行操作最多3次，如果3次后还失败，则writeLmkd操作会直接结束。尝试3次，则不管结果如何都将退出该操作，可见writeLmkd写入操作还有可能失败的。</p> <h3><strong>2.4 PL.openLmkdSocket</strong></h3> <pre> private static boolean openLmkdSocket() { try { sLmkdSocket = new LocalSocket(LocalSocket.SOCKET_SEQPACKET); //与远程lmkd守护进程建立socket连接 sLmkdSocket.connect( new LocalSocketAddress("lmkd", LocalSocketAddress.Namespace.RESERVED)); sLmkdOutputStream = sLmkdSocket.getOutputStream(); } catch (IOException ex) { Slog.w(TAG, "lowmemorykiller daemon socket open failed"); sLmkdSocket = null; return false; } return true; }</pre> <p>sLmkdSocket采用的是SOCK_SEQPACKET，这是类型的socket能提供顺序确定的，可靠的，双向基于连接的socket endpoint，与类型SOCK_STREAM很相似，唯一不同的是SEQPACKET保留消息的边界，而SOCK_STREAM是基于字节流，并不会记录边界。</p> <p>举例：本地通过write()系统调用向远程先后发送两组数据：一组4字节，一组8字节；对于SOCK_SEQPACKET类型通过read()能获知这是两组数据以及大小，而对于SOCK_STREAM类型，通过read()一次性读取到12个字节，并不知道数据包的边界情况。</p> <p>常见的数据类型还有SOCK_DGRAM，提供数据报形式，用于udp这样不可靠的通信过程。</p> <p>再回到openLmkdSocket()方法，该方法是打开一个名为 lmkd 的socket，类型为LocalSocket.SOCKET_SEQPACKET，这只是一个封装，真实类型就是SOCK_SEQPACKET。先跟远程lmkd守护进程建立连接，再向其通过write()将数据写入该socket，再接下来进入lmkd过程。</p> <h2><strong>三. lmkd</strong></h2> <p>lmkd是由init进程，通过解析init.rc文件来启动的lmkd守护进程，lmkd会创建名为 lmkd 的socket，节点位于 /dev/socket/lmkd ，该socket用于跟上层framework交互。</p> <pre> service lmkd /system/bin/lmkd class core critical socket lmkd seqpacket 0660 system system writepid /dev/cpuset/system-background/tasks</pre> <p>lmkd启动后，接下里的操作都在 platform/system/core/lmkd/lmkd.c 文件，首先进入main()方法</p> <h3><strong>3.1 main</strong></h3> <pre> int main(int argc __unused, char **argv __unused) { struct sched_param param = { .sched_priority = 1, }; mlockall(MCL_FUTURE); sched_setscheduler(0, SCHED_FIFO, ¶m); //初始化【见小节3.2】 if (!init()) mainloop(); //成功后进入loop [见小节3.3] ALOGI("exiting"); return 0; }</pre> <h3><strong>3.2 init</strong></h3> <pre> static int init(void) { struct epoll_event epev; int i; int ret; page_k = sysconf(_SC_PAGESIZE); if (page_k == -1) page_k = PAGE_SIZE; page_k /= 1024; //创建epoll监听文件句柄 epollfd = epoll_create(MAX_EPOLL_EVENTS); //获取lmkd控制描述符 ctrl_lfd = android_get_control_socket("lmkd"); //监听lmkd socket ret = listen(ctrl_lfd, 1); epev.events = EPOLLIN; epev.data.ptr = (void *)ctrl_connect_handler; //将文件句柄ctrl_lfd，加入epoll句柄 if (epoll_ctl(epollfd, EPOLL_CTL_ADD, ctrl_lfd, &epev) == -1) { return -1; } maxevents++; //该路径是否具有可写的权限 use_inkernel_interface = !access(INKERNEL_MINFREE_PATH, W_OK); if (use_inkernel_interface) { ALOGI("Using in-kernel low memory killer interface"); } else { ret = init_mp(MEMPRESSURE_WATCH_LEVEL, (void *)&mp_event); if (ret) ALOGE("Kernel does not support memory pressure events or in-kernel low memory killer"); } for (i = 0; i <= ADJTOSLOT(OOM_SCORE_ADJ_MAX); i++) { procadjslot_list[i].next = &procadjslot_list[i]; procadjslot_list[i].prev = &procadjslot_list[i]; } return 0; }</pre> <p>这里，通过检验/sys/module/lowmemorykiller/parameters/minfree节点是否具有可写权限来判断是否使用kernel接口来管理lmk事件。默认该节点是具有系统可写的权限，也就意味着 use_inkernel_interface =1.</p> <h3><strong>3.3 mainloop</strong></h3> <pre> static void mainloop(void) { while (1) { struct epoll_event events[maxevents]; int nevents; int i; ctrl_dfd_reopened = 0; //等待epollfd上的事件 nevents = epoll_wait(epollfd, events, maxevents, -1); if (nevents == -1) { if (errno == EINTR) continue; continue; } for (i = 0; i < nevents; ++i) { if (events[i].events & EPOLLERR) ALOGD("EPOLLERR on event #%d", i); // 当事件到来，则调用ctrl_connect_handler方法 【见小节3.4】 if (events[i].data.ptr) (*(void (*)(uint32_t))events[i].data.ptr)(events[i].events); } } }</pre> <p>主循环调用epoll_wait()，等待epollfd上的事件，当接收到中断或者不存在事件，则执行continue操作。当事件到来，则 调用的ctrl_connect_handler方法，该方法是由init()过程中设定的方法。</p> <h3><strong>3.4 ctrl_connect_handler</strong></h3> <pre> static void ctrl_connect_handler(uint32_t events __unused) { struct epoll_event epev; if (ctrl_dfd >= 0) { ctrl_data_close(); ctrl_dfd_reopened = 1; } ctrl_dfd = accept(ctrl_lfd, NULL, NULL); if (ctrl_dfd < 0) { ALOGE("lmkd control socket accept failed; errno=%d", errno); return; } ALOGI("ActivityManager connected"); maxevents++; epev.events = EPOLLIN; epev.data.ptr = (void *)ctrl_data_handler; //将ctrl_lfd添加到epollfd if (epoll_ctl(epollfd, EPOLL_CTL_ADD, ctrl_dfd, &epev) == -1) { ALOGE("epoll_ctl for data connection socket failed; errno=%d", errno); ctrl_data_close(); return; } }</pre> <p>当事件触发，则调用ctrl_data_handler</p> <h3><strong>3.5 ctrl_data_handler</strong></h3> <pre> static void ctrl_data_handler(uint32_t events) { if (events & EPOLLHUP) { //ActivityManager 连接已断开 if (!ctrl_dfd_reopened) ctrl_data_close(); } else if (events & EPOLLIN) { //[见小节3.6] ctrl_command_handler(); } }</pre> <h3><strong>3.6 ctrl_command_handler</strong></h3> <pre> static void ctrl_command_handler(void) { int ibuf[CTRL_PACKET_MAX / sizeof(int)]; int len; int cmd = -1; int nargs; int targets; len = ctrl_data_read((char *)ibuf, CTRL_PACKET_MAX); if (len <= 0) return; nargs = len / sizeof(int) - 1; if (nargs < 0) goto wronglen; //将网络字节顺序转换为主机字节顺序 cmd = ntohl(ibuf[0]); switch(cmd) { case LMK_TARGET: targets = nargs / 2; if (nargs & 0x1 || targets > (int)ARRAY_SIZE(lowmem_adj)) goto wronglen; cmd_target(targets, &ibuf[1]); break; case LMK_PROCPRIO: if (nargs != 3) goto wronglen; //设置进程adj【见小节3.7】 cmd_procprio(ntohl(ibuf[1]), ntohl(ibuf[2]), ntohl(ibuf[3])); break; case LMK_PROCREMOVE: if (nargs != 1) goto wronglen; cmd_procremove(ntohl(ibuf[1])); break; default: ALOGE("Received unknown command code %d", cmd); return; } return; wronglen: ALOGE("Wrong control socket read length cmd=%d len=%d", cmd, len); }</pre> <p>CTRL_PACKET_MAX 大小等于 (sizeof(int) * (MAX_TARGETS * 2 + 1))；而MAX_TARGETS=6,对于sizeof(int)=4的系统，则 CTRL_PACKET_MAX =52。 获取framework传递过来的buf数据后，根据3种不同的命令，进入不同的分支。 接下来，继续以前面传递过来的 LMK_PROCPRIO 命令来往下讲解，进入 cmd_procprio 过程。</p> <h3><strong>3.7 cmd_procprio</strong></h3> <pre> static void cmd_procprio(int pid, int uid, int oomadj) { struct proc *procp; char path[80]; char val[20]; ... snprintf(path, sizeof(path), "/proc/%d/oom_score_adj", pid); snprintf(val, sizeof(val), "%d", oomadj); //向节点/proc/<pid>/oom_score_adj写入oomadj writefilestring(path, val); //当使用kernel方式则直接返回 if (use_inkernel_interface) return; procp = pid_lookup(pid); if (!procp) { procp = malloc(sizeof(struct proc)); if (!procp) { // Oh, the irony. May need to rebuild our state. return; } procp->pid = pid; procp->uid = uid; procp->oomadj = oomadj; proc_insert(procp); } else { proc_unslot(procp); procp->oomadj = oomadj; proc_slot(procp); } }</pre> <p>向节点``/proc/ /oom_score_adj`写入oomadj。由于use_inkernel_interface=1，那么再接下里需要看看kernel的情况</p> <h3><strong>3.8 小节</strong></h3> <p>use_inkernel_interface该值后续应该会逐渐采用用户空间策略。不过目前仍为 use_inkernel_interface=1则有：</p> <ul> <li>LMK_PROCPRIO: 向 /proc/<pid>/oom_score_adj 写入oomadj，则直接返回；</li> <li>LMK_PROCREMOVE：不做任何事，直接返回；</li> <li>LMK_TARGET：分别向 /sys/module/lowmemorykiller/parameters 目录下的 minfree 和 adj 节点写入相应信息；</li> </ul> <h2><strong>四. Kernel层</strong></h2> <p>lowmemorykiller driver位于 drivers/staging/Android/lowmemorykiller.c</p> <h3><strong>4.1 lowmemorykiller初始化</strong></h3> <pre> static struct shrinker lowmem_shrinker = { .scan_objects = lowmem_scan, .count_objects = lowmem_count, .seeks = DEFAULT_SEEKS * 16 }; static int __init lowmem_init(void) { register_shrinker(&lowmem_shrinker); return 0; } static void __exit lowmem_exit(void) { unregister_shrinker(&lowmem_shrinker); } module_init(lowmem_init); module_exit(lowmem_exit);</pre> <p>通过register_shrinker和unregister_shrinker分别用于初始化和退出。</p> <h3><strong>4.2 shrinker</strong></h3> <p>LMK驱动通过注册shrinker来实现的，shrinker是linux kernel标准的回收内存page的机制，由内核线程kswapd负责监控。</p> <p>当内存不足时kswapd线程会遍历一张shrinker链表，并回调已注册的shrinker函数来回收内存page，kswapd还会周期性唤醒来执行内存操作。每个zone维护active_list和inactive_list链表，内核根据页面活动状态将page在这两个链表之间移动，最终通过shrink_slab和shrink_zone来回收内存页，有兴趣想进一步了解linux内存回收机制，可自行研究，这里再回到LowMemoryKiller的过程分析。</p> <h3><strong>4.3 lowmem_count</strong></h3> <pre> static unsigned long lowmem_count(struct shrinker *s, struct shrink_control *sc) { return global_page_state(NR_ACTIVE_ANON) + global_page_state(NR_ACTIVE_FILE) + global_page_state(NR_INACTIVE_ANON) + global_page_state(NR_INACTIVE_FILE); }</pre> <p>ANON代表匿名映射，没有后备存储器；FILE代表文件映射； 内存计算公式= 活动匿名内存 + 活动文件内存 + 不活动匿名内存 + 不活动文件内存</p> <h3><strong>4.4 lowmem_scan</strong></h3> <p>当触发lmkd,则先杀oom_adj最大的进程, 当oom_adj相等时,则选择oom_score_adj最大的进程.</p> <pre> static unsigned long lowmem_scan(struct shrinker *s, struct shrink_control *sc) { struct task_struct *tsk; struct task_struct *selected = NULL; unsigned long rem = 0; int tasksize; int i; short min_score_adj = OOM_SCORE_ADJ_MAX + 1; int minfree = 0; int selected_tasksize = 0; short selected_oom_score_adj; int array_size = ARRAY_SIZE(lowmem_adj); //获取当前剩余内存大小 int other_free = global_page_state(NR_FREE_PAGES) - totalreserve_pages; int other_file = global_page_state(NR_FILE_PAGES) - global_page_state(NR_SHMEM) - total_swapcache_pages(); //获取数组大小 if (lowmem_adj_size < array_size) array_size = lowmem_adj_size; if (lowmem_minfree_size < array_size) array_size = lowmem_minfree_size; //遍历lowmem_minfree数组找出相应的最小adj值 for (i = 0; i < array_size; i++) { minfree = lowmem_minfree[i]; if (other_free < minfree && other_file < minfree) { min_score_adj = lowmem_adj[i]; break; } } if (min_score_adj == OOM_SCORE_ADJ_MAX + 1) { return 0; } selected_oom_score_adj = min_score_adj; rcu_read_lock(); for_each_process(tsk) { struct task_struct *p; short oom_score_adj; if (tsk->flags & PF_KTHREAD) continue; p = find_lock_task_mm(tsk); if (!p) continue; if (test_tsk_thread_flag(p, TIF_MEMDIE) && time_before_eq(jiffies, lowmem_deathpending_timeout)) { task_unlock(p); rcu_read_unlock(); return 0; } oom_score_adj = p->signal->oom_score_adj; //小于目标adj的进程，则忽略 if (oom_score_adj < min_score_adj) { task_unlock(p); continue; } //获取的是进程的Resident Set Size，也就是进程独占内存 + 共享库大小。 tasksize = get_mm_rss(p->mm); task_unlock(p); if (tasksize <= 0) continue; //算法关键，选择oom_score_adj最大的进程中，并且rss内存最大的进程. if (selected) { if (oom_score_adj < selected_oom_score_adj) continue; if (oom_score_adj == selected_oom_score_adj && tasksize <= selected_tasksize) continue; } selected = p; selected_tasksize = tasksize; selected_oom_score_adj = oom_score_adj; lowmem_print(2, "select '%s' (%d), adj %hd, size %d, to kill\n", p->comm, p->pid, oom_score_adj, tasksize); } if (selected) { long cache_size = other_file * (long)(PAGE_SIZE / 1024); long cache_limit = minfree * (long)(PAGE_SIZE / 1024); long free = other_free * (long)(PAGE_SIZE / 1024); lowmem_deathpending_timeout = jiffies + HZ; set_tsk_thread_flag(selected, TIF_MEMDIE); //向选中的目标进程发送signal 9来杀掉目标进程 send_sig(SIGKILL, selected, 0); rem += selected_tasksize; } rcu_read_unlock(); return rem; }</pre> <ul> <li>选择oom_score_adj最大的进程中，并且rss内存最大的进程作为选中要杀的进程。</li> <li>杀进程方式： send_sig(SIGKILL, selected, 0) `向选中的目标进程发送signal 9来杀掉目标进程。</li> </ul> <p>另外，lowmem_minfree[]和lowmem_adj[]数组大小个数为6，通过如下两条命令：</p> <pre> module_param_named(debug_level, lowmem_debug_level, uint, S_IRUGO | S_IWUSR); module_param_array_named(adj, lowmem_adj, short, &lowmem_adj_size, S_IRUGO | S_IWUSR);</pre> <p>当如下节点数据发送变化时，会通过修改lowmem_minfree[]和lowmem_adj[]数组：</p> <pre> /sys/module/lowmemorykiller/parameters/minfree /sys/module/lowmemorykiller/parameters/adj</pre> <h2><strong>五、总结</strong></h2> <p>本文主要从frameworks的ProcessList.java调整adj，通过socket通信将事件发送给native的守护进程lmkd；lmkd再根据具体的命令来执行相应操作，其主要功能 更新进程的oom_score_adj值以及lowmemorykiller驱动的parameters(包括minfree和adj)；</p> <p>最后讲到了lowmemorykiller驱动，通过注册shrinker，借助linux标准的内存回收机制，根据当前系统可用内存以及parameters配置参数(adj,minfree)来选取合适的selected_oom_score_adj，再从所有进程中选择adj大于该目标值的并且占用rss内存最大的进程，将其杀掉，从而释放出内存。</p> <h3><strong>5.1 lmkd参数：</strong></h3> <ul> <li>oom_adj :代表进程的优先级, 数值越大,优先级越低,越容易被杀. 取值范围[-16, 15]</li> <li>oom_score_adj : 取值范围[-1000, 1000]</li> <li>oom_score：lmk策略中貌似并没有看到使用的地方，这个应该是oom才会使用。</li> </ul> <p>想查看某个进程的上述3值，只需要知道pid，查看以下几个节点:</p> <pre> /proc/<pid>/oom_adj /proc/<pid>/oom_score_adj /proc/<pid>/oom_score</pre> <p>对于oom_adj与oom_score_adj有一定的映射关系：</p> <ul> <li>当oom_adj = 15, 则oom_score_adj=1000;</li> <li>当oom_adj < 15, 则oom_score_adj= oom_adj * 1000/17;</li> </ul> <h3><strong>5.2 driver参数</strong></h3> <pre> /sys/module/lowmemorykiller/parameters/minfree (代表page个数) /sys/module/lowmemorykiller/parameters/adj (代表oom_score_adj)</pre> <p>例如：将 1,6 写入节点/sys/module/lowmemorykiller/parameters/adj，将 1024,8192 写入节点/sys/module/lowmemorykiller/parameters/minfree。策略：当系统可用内存低于 8192 个pages时，则会杀掉oom_score_adj>= 6 的进程；当系统可用内存低于 1024 个pages时，则会杀掉oom_score_adj>= 1 的进程。</p> <p> </p> <p> </p> <p>来自：http://gityuan.com/2016/09/17/android-lowmemorykiller/</p> <p> </p>