是不是非常炫酷唾糯，這么多內(nèi)存回收線程kswapd0崭篡，從此告別低內(nèi)存~
如何做到的呢？
其實(shí)社區(qū)早就有類似patch堡距，只是芯片平臺(tái)廠商沒(méi)有merge進(jìn)來(lái)甲锡，我們可以自己手動(dòng)嘗試移植下來(lái)兆蕉！
首先在proc/sys/vm下搞個(gè)節(jié)點(diǎn)，用來(lái)寫入kswapd0進(jìn)程數(shù)（一般最大為16）缤沦，回調(diào)函數(shù)kswapd_threads_sysctl_handler => update_kswapd_threads()
在mmzone.h頭文件的Node結(jié)構(gòu)體中虎韵，即typedef struct pglist_data新增kswapd0的進(jìn)程數(shù)組
struct task_struct *kswapd[MAX_KSWAPD_THREADS];-
因?yàn)樵敲總€(gè)Node配置一個(gè)kswapd0，所以要遍歷node缸废，去做kswapd0的線程的創(chuàng)建包蓝。
PS.在創(chuàng)建前要進(jìn)行內(nèi)存的熱插拔，即開(kāi)始前mem_hotplug_begin();企量，開(kāi)始后mem_hotplug_done();
/mm/vmscan.c
static void update_kswapd_threads_node(int nid) //nid就是node的id
{
pg_data_t *pgdat;
int drop, increase;
int last_idx, start_idx, hid;
int nr_threads = kswapd_threads_current;
pgdat = NODE_DATA(nid);
//就是遍歷node的struct pglist_data *node_data[MAX_NUMNODES] __read_mostly;
last_idx = nr_threads - 1;
if (kswapd_threads < nr_threads) { //設(shè)的數(shù)量比當(dāng)前小测萎，stop一些線程
drop = nr_threads - kswapd_threads;
for (hid = last_idx; hid > (last_idx - drop); hid--) {
if (pgdat->kswapd[hid]) {
kthread_stop(pgdat->kswapd[hid]);
pgdat->kswapd[hid] = NULL;
}
}
} else { //設(shè)的數(shù)量比當(dāng)前大，run一些線程
increase = kswapd_threads - nr_threads; //需要增加的線程數(shù)
start_idx = last_idx + 1; //當(dāng)前kswapd數(shù)量
for (hid = start_idx; hid < (start_idx + increase); hid++) { //執(zhí)行increase遍
pgdat->kswapd[hid] = kthread_run(kswapd, pgdat,
"kswapd%d:%d", nid, hid); //所以是kswpad0 ->代表node hid代表個(gè)數(shù)
if (IS_ERR(pgdat->kswapd[hid])) {
pr_err("Failed to start kswapd%d on node %d\n",
hid, nid);
pgdat->kswapd[hid] = NULL;
/*
* We are out of resources. Do not start any
* more threads.
*/
break;
}
}
}
}
- 在kswapd_run和kswapd_stop中完善下代碼
后續(xù)：好像高通4.19內(nèi)核部分平臺(tái)也新增了這個(gè)功能届巩，好尷尬硅瞧，所以再增加點(diǎn)內(nèi)容吧。恕汇。
比如腕唧，如何把kswapd0進(jìn)程綁定到非超大核上，以此來(lái)減少對(duì)其他ux進(jìn)程的搶占：
-
linux/sched.h頭文件中瘾英，定義了kswapd標(biāo)識(shí)
#define PF_KSWAPD 0x00020000 /* I am kswapd */ -
在調(diào)度中枣接，先對(duì)帶有kswapd的標(biāo)識(shí)的進(jìn)程不允許在超大核或者大核上運(yùn)行，一般0-3為小核缺谴，4-6為大核但惶，7為超大核，kernel/sched/core.c -> do_set_cpus_allowed :
if ((p->flags & PF_KSWAPD) && (cpumask_test_cpu(6, new_mask) || cpumask_test_cpu(7, new_mask))) return; -
在kwapd創(chuàng)建函數(shù)中vmscan.c -> kswapd增加CPU調(diào)度優(yōu)先級(jí)設(shè)置湿蛔，只設(shè)置小核或者大核
static inline int set_thread_affinity_littlecore(struct task_struct *tsk) { int ret; struct cpumask mask; cpumask_clear(&mask); cpumask_set_cpu(0, &mask); cpumask_set_cpu(1, &mask); cpumask_set_cpu(2, &mask); cpumask_set_cpu(3, &mask); cpumask_set_cpu(4, &mask); cpumask_set_cpu(5, &mask); ret = sched_setaffinity(tsk->pid, &mask); return ret; }
還有膀曾，如何增加埋點(diǎn)查看是哪些進(jìn)程因?yàn)槭裁丛騿拘鸦蛘咝菝吡薻swapd0：
喚醒：mm/vmscan.c -> wakeup_kswapd 函數(shù)
（至多每個(gè)時(shí)鐘HZ打印一次哦！不然容易掛掉）
在最后wake_up_interruptible前煌集，先打印zone妓肢、分配的order以及zone_type
加rcu_read_lock鎖，遍歷進(jìn)程打印所有進(jìn)程的內(nèi)存信息：
tsk->pid,
from_kuid(&init_user_ns, task_uid(tsk)), //uid
tsk->tgid, tsk->mm->total_vm,
get_mm_rss(tsk->mm),
tsk_nr_ptes / SZ_1K, //PTRS_PER_PTE * sizeof(pte_t) * atomic_long_read(&tsk->mm->nr_ptes);
get_mm_counter(tsk->mm, MM_SWAPENTS),
get_mm_counter(tsk->mm, MM_SHMEMPAGES),
tsk_oom_adj = tsk->signal->oom_score_adj;
task_state_to_char(tsk);,
tsk->comm,
frozen_mark = frozen(tsk) ? '*' : ' ';
休眠：mm/vmscan.c -> kswapd_try_to_sleep 函數(shù)
在prepare_kswapd_sleep后打印需要的zone 和 order
