重写-linux内存管理-伙伴分配器（一）

news2024/11/27 12:43:23

文章目录

  • 一、伙伴系统的结构
  • 二、初始化
  • 三、分配内存
    • 3.1 prepare_alloc_pages
    • 3.2 get_page_from_freelist
      • 3.2.1 zone_watermark_fast
      • 3.2.2 zone_watermark_ok
      • 3.2.3 rmqueue
        • 3.2.3.1 rmqueue_pcplist
        • 3.2.3.2 __rmqueue
        • 3.2.3.2.1 __rmqueue_smallest
        • 3.2.3.2.2 __rmqueue_fallback
    • 3.3 __alloc_pages_slowpath

一、伙伴系统的结构

我从网上找了一个图片，它很好的把整个伙伴系统免描绘出来：在这里插入图片描述

对比他们的系统，我们先看看自己的伙伴系统支持哪些内存页：

jian@ubuntu:~/share/note/p5$ sudo cat /proc/pagetypeinfo
...
Free pages count per migrate type at order       0      1      2      3      4      5      6      7      8      9     10 
Node    0, zone      DMA, type    Unmovable      0      0      0      0      0      0      0      1      0      0      0 
Node    0, zone      DMA, type      Movable      0      0      0      0      0      0      0      0      0      1      3 
Node    0, zone      DMA, type  Reclaimable      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone      DMA, type   HighAtomic      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone      DMA, type      Isolate      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone    DMA32, type    Unmovable     46      9     12    113    105     28      7      3      3      4      4 
Node    0, zone    DMA32, type      Movable      1      1      1      0      0      1      1      1      0      1    135 
Node    0, zone    DMA32, type  Reclaimable      7      3      2      5      1      1      1      0      0      0      0 
Node    0, zone    DMA32, type   HighAtomic      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone    DMA32, type      Isolate      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone   Normal, type    Unmovable     17     19      1      8      9      5      0      1      0      1      3 
Node    0, zone   Normal, type      Movable      0      0      1      0      0      0      1      1      0      0      0 
Node    0, zone   Normal, type  Reclaimable      0      1      0      1      2      1      0      1      0      1      0 
Node    0, zone   Normal, type   HighAtomic      0      0      0      0      0      0      0      0      0      0      0 
Node    0, zone   Normal, type      Isolate      0      0      0      0      0      0      0      0      0      0      0 
...

可以看到我们的内存只有一个节点，也就是node 0 ，这是正常的，一般普通PC只有一个节点，只有服务器才有多个节点；节点包含3个区域：DMA、DMA32和Normal；每个区域都有5中类型：Unmovable、Movable、Reclaimable、HighAtomic和Isolate。

二、初始化

后面补充。

三、分配内存

从伙伴算法分配函数主要有两个：alloc_pages和__get_free_pages。前者返回一个 page 实例，后者返回返回虚拟地址， 后者对前者做了封装。

unsigned long __get_free_pages(gfp_t gfp_mask, unsigned int order)
{
	struct page *page;

	page = alloc_pages(gfp_mask & ~__GFP_HIGHMEM, order);
	if (!page)
		return 0;
	return (unsigned long) page_address(page);
}

__get_free_pages首先通过alloc_pages函数分配物理内存，然后通过函数page_address把分配到的page结构体转化为虚拟地址返回。所以我们只要分析alloc_pages就可以了：

static inline struct page *alloc_pages(gfp_t gfp_mask, unsigned int order)
{
	return alloc_pages_node(numa_node_id(), gfp_mask, order);
}

static inline struct page *alloc_pages_node(int nid, gfp_t gfp_mask,
						unsigned int order)
{
	if (nid == NUMA_NO_NODE)
		nid = numa_mem_id();

	return __alloc_pages_node(nid, gfp_mask, order);
}

static inline struct page *
__alloc_pages_node(int nid, gfp_t gfp_mask, unsigned int order)
{
	VM_BUG_ON(nid < 0 || nid >= MAX_NUMNODES);
	VM_WARN_ON((gfp_mask & __GFP_THISNODE) && !node_online(nid));

	return __alloc_pages(gfp_mask, order, nid);
}

static inline struct page *
__alloc_pages(gfp_t gfp_mask, unsigned int order, int preferred_nid)
{
	return __alloc_pages_nodemask(gfp_mask, order, preferred_nid, NULL);
}

__alloc_pages_nodemask是伙伴分配器分配物理内存的核心函数：

struct page *
__alloc_pages_nodemask(gfp_t gfp_mask, unsigned int order, int preferred_nid,
							nodemask_t *nodemask)
{
	struct page *page;
	unsigned int alloc_flags = ALLOC_WMARK_LOW;
	gfp_t alloc_mask; /* The gfp_t that was actually used for allocation */
	struct alloc_context ac = { };

	if (unlikely(order >= MAX_ORDER)) {//如果申请order超过上限
		WARN_ON_ONCE(!(gfp_mask & __GFP_NOWARN));
		return NULL;//返回失败
	}

	gfp_mask &= gfp_allowed_mask;
	alloc_mask = gfp_mask;
	//根据标志位设置好alloc_context和alloc_flags
	if (!prepare_alloc_pages(gfp_mask, order, preferred_nid, nodemask, &ac, &alloc_mask, &alloc_flags))
		return NULL;

	//修改alloc_flags
	alloc_flags |= alloc_flags_nofragment(ac.preferred_zoneref->zone, gfp_mask);

	//第一次分配尝试，也叫快速路径
	page = get_page_from_freelist(alloc_mask, order, alloc_flags, &ac);
	if (likely(page))//分配成功
		goto out;//返回

	//将任务的gfp上下文应用到分配标志中。GFP_NOFS和GFP_NOIO
	alloc_mask = current_gfp_context(gfp_mask);
	ac.spread_dirty_pages = false;

	ac.nodemask = nodemask;//恢复原始的节点掩码

	page = __alloc_pages_slowpath(alloc_mask, order, &ac);//慢速路径申请内存

out:
	if (memcg_kmem_enabled() && (gfp_mask & __GFP_ACCOUNT) && page &&
	    unlikely(__memcg_kmem_charge_page(page, gfp_mask, order) != 0)) {
		__free_pages(page, order);
		page = NULL;
	}

	trace_mm_page_alloc(page, order, alloc_mask, ac.migratetype);

	return page;
}

我们看到__alloc_pages_nodemask首先判断申请的代销是否超出上限，超出则退出，然后调用函数prepare_alloc_pages主要做分配内存的准备工作，根据标志位设置好alloc_context和alloc_flags，主要是alloc_context里面的备用节点zonelist，首选区域和首选可迁移类型；接着调用函数get_page_from_freelist进行第一次内存分配，也叫快速路径，成功就直接返回page；失败则修改alloc_mask 后调用函数__alloc_pages_slowpath进行慢速路径申请内存。我们需要分析3个函数：prepare_alloc_pages、get_page_from_freelist和__alloc_pages_slowpath。

3.1 prepare_alloc_pages

static inline bool prepare_alloc_pages(gfp_t gfp_mask, unsigned int order,
		int preferred_nid, nodemask_t *nodemask,
		struct alloc_context *ac, gfp_t *alloc_mask,
		unsigned int *alloc_flags)
{
	ac->highest_zoneidx = gfp_zone(gfp_mask);//根据gfp_mask选择合适的zone
	ac->zonelist = node_zonelist(preferred_nid, gfp_mask);//找到当前节点的备用分区列表
	ac->nodemask = nodemask;
	ac->migratetype = gfp_migratetype(gfp_mask);//根据gfp_mask选择合适迁移类型

	if (cpusets_enabled()) {//开启cpuset
		*alloc_mask |= __GFP_HARDWALL;
		/*
		 * When we are in the interrupt context, it is irrelevant
		 * to the current task context. It means that any node ok.
		 */
		if (!in_interrupt() && !ac->nodemask)//如果不在中断上下文
			ac->nodemask = &cpuset_current_mems_allowed;//可以申请任意内存节点
		else
			*alloc_flags |= ALLOC_CPUSET;//设置支持CPUSET
	}

	fs_reclaim_acquire(gfp_mask);//空函数
	fs_reclaim_release(gfp_mask);//空函数

	might_sleep_if(gfp_mask & __GFP_DIRECT_RECLAIM);//可能会睡眠，如果支持申请者表示可以收回

	if (should_fail_alloc_page(gfp_mask, order))
		return false;

	*alloc_flags = current_alloc_flags(gfp_mask, *alloc_flags);//根据current情况修改可以申请的可迁移类型

	//打算脏化该页。以避免所有脏页面都位于一个区域(公平的区域分配策略)。
	ac->spread_dirty_pages = (gfp_mask & __GFP_WRITE);

	/*
	 * The preferred zone is used for statistics but crucially it is
	 * also used as the starting point for the zonelist iterator. It
	 * may get reset for allocations that ignore memory policies.
	 */
	//设置申请内存的首选区域
	ac->preferred_zoneref = first_zones_zonelist(ac->zonelist,
					ac->highest_zoneidx, ac->nodemask);

	return true;
}

prepare_alloc_pages调用函数gfp_zone根据gfp_mask选择合适的zone，调用 node_zonelis选择当前节点的备用分区列表，调用gfp_migratetype根据gfp_mask选择合适迁移类型，调用函数first_zones_zonelist设置申请内存的首选区域。中间还有就是对alloc_flags 的一些修，就不一一说了，自己看上面的代码注释。

3.2 get_page_from_freelist

static struct page *
get_page_from_freelist(gfp_t gfp_mask, unsigned int order, int alloc_flags,
						const struct alloc_context *ac)
{
	struct zoneref *z;
	struct zone *zone;
	struct pglist_data *last_pgdat_dirty_limit = NULL;
	bool no_fallback;

retry:
	/*
	 * Scan zonelist, looking for a zone with enough free.
	 * See also __cpuset_node_allowed() comment in kernel/cpuset.c.
	 */
	no_fallback = alloc_flags & ALLOC_NOFRAGMENT;
	z = ac->preferred_zoneref;
	//遍历备用区域列表中每一个满足条件的区域，如果区域类型小于等于首选区域类型，并且内存节点在节点掩码中的相应位被设置
	for_next_zone_zonelist_nodemask(zone, z, ac->highest_zoneidx,
					ac->nodemask) {
		struct page *page;
		unsigned long mark;

		if (cpusets_enabled() &&	//如果编译了cpuset功能
			(alloc_flags & ALLOC_CPUSET) &&	//调用者设置ALLOC_CPUSET要求使用cpuset检查
			!__cpuset_zone_allowed(zone, gfp_mask))//cpuset不允许当前进程从这个内存节点分配页
				continue;//不能从这个区域分配页，进行下一个区域的遍历

		//如果调用者设置标志位__GFP_WRITE表示文件系统申请分配一个页缓存页用于写文件
		if (ac->spread_dirty_pages) {
			if (last_pgdat_dirty_limit == zone->zone_pgdat)//如果内存节点为NULL
				continue;//不能从这个区域分配页，进行下一个区域的遍历

			if (!node_dirty_ok(zone->zone_pgdat)) {//如果内存节点的脏页数量是否超过限制
				last_pgdat_dirty_limit = zone->zone_pgdat;
				continue;//不能从这个区域分配页，进行下一个区域的遍历
			}
		}

		if (no_fallback && nr_online_nodes > 1 &&
		    zone != ac->preferred_zoneref->zone) {
			int local_nid;

			/*
			 * If moving to a remote node, retry but allow
			 * fragmenting fallbacks. Locality is more important
			 * than fragmentation avoidance.
			 */
			local_nid = zone_to_nid(ac->preferred_zoneref->zone);
			if (zone_to_nid(zone) != local_nid) {
				alloc_flags &= ~ALLOC_NOFRAGMENT;
				goto retry;
			}
		}

		//获取申请内存的限制水位线，是普通申请的LOW还是最低限制的MIN
		mark = wmark_pages(zone, alloc_flags & ALLOC_WMARK_MASK);
		//如果（区域的空闲页数−       申请的页数）小于水线
		if (!zone_watermark_fast(zone, order, mark,
				       ac->highest_zoneidx, alloc_flags,
				       gfp_mask)) {
			int ret;

			/* Checked here to keep the fast path fast */
			BUILD_BUG_ON(ALLOC_NO_WATERMARKS < NR_WMARK);
			
			if (alloc_flags & ALLOC_NO_WATERMARKS)//如果调用者要求不检查水线
				goto try_this_zone;//那么可以从这个区域分配页

			if (node_reclaim_mode == 0 ||	//如果没有开启节点回收功能，
			    !zone_allows_reclaim(ac->preferred_zoneref->zone, zone))//当前节点和首选节点之间的距离大于回收距离
				continue;//不能从这个区域分配页，进行下一个区域的遍历

			//尝试通过回收从该节点释放一些页面，我们UMA直接返回不扫描
			ret = node_reclaim(zone->zone_pgdat, gfp_mask, order);
			switch (ret) {
			case NODE_RECLAIM_NOSCAN://不扫描
				/* did not scan */
				continue;
			case NODE_RECLAIM_FULL://扫描但是回收失败
				/* scanned but unreclaimable */
				continue;
			default://回收到内存
				if (zone_watermark_ok(zone, order, mark,//如果回收后内存足够
					ac->highest_zoneidx, alloc_flags))
					goto try_this_zone;//那么可以从这个区域分配页

				continue;
			}
		}

try_this_zone:
		//从当前区域分配页
		page = rmqueue(ac->preferred_zoneref->zone, zone, order,
				gfp_mask, alloc_flags, ac->migratetype);
		if (page) {//如果分配成功，调用函数 prep_new_page 以初始化页
			prep_new_page(page, order, gfp_mask, alloc_flags);

			//如果这是一个高阶原子分配，并且区域中高阶原子类型的页数没有超过限制
			if (unlikely(order && (alloc_flags & ALLOC_HARDER)))	
				//把分配的页所属的页块转换为高阶原子类型
				reserve_highatomic_pageblock(page, zone, order);

			return page;
		} 
	}

	if (no_fallback) {//如果存在no_fallback
		alloc_flags &= ~ALLOC_NOFRAGMENT;//设置alloc_flags的ALLOC_NOFRAGMENT
		goto retry;//回到开头再试一次
	}

	return NULL;
}

get_page_from_freelist首先遍历备用区域列表中每一个满足条件的区域，如果区域类型小于等于首选区域类型，并且内存节点在节点掩码中的相应位被设置了，则进行下面一系列的复杂操作：

  1. 如果编译了cpuset功能，并且调用者设置了ALLOC_CPUSET要求使用cpuset检查，但是cpuset不允许当前进程从这个内存节点分配页，那么不能从这个区域分配页，进行下一个区域的遍历。
  2. 如果调用者设置标志位__GFP_WRITE表示文件系统申请分配一个页缓存页用于写文件，并且内存节点为NULL或者脏页数量是否超过限制，那么不能从这个区域分配页，进行下一个区域的遍历。
  3. 调用函数wmark_pages获取申请内存的限制水位线，如果（区域的空闲页数− 申请的页数）小于水线，并且调用者要求检查水线或者没有开启节点回收功能，都不能从这个区域分配页，进行下一个区域的遍历；否则调用node_reclaim函数尝试通过回收从该节点释放一些页面，如果回收到内存，调用函数zone_watermark_ok检查水位线，水位线还是不足，那么不能从这个区域分配页，进行下一个区域的遍历。
  4. 来都这里说明水位线是足够的，或者不检查水位线，可以调用函数rmqueue开始分配当前区域的内存了。如果分配成功，调用函数 prep_new_page 以初始化页内存；如果这是一个高阶原子分配，并且区域中高阶原子类型的页数没有超过限制，就把分配的页所属的页块转换为高阶原子类型。返回page。
  5. 如果失败了，如果存在no_fallback，则设置alloc_flags的ALLOC_NOFRAGMENT，回到开头再试一次。

我们继续看zone_watermark_fast、zone_watermark_ok和rmqueue。

3.2.1 zone_watermark_fast

static inline bool zone_watermark_fast(struct zone *z, unsigned int order,
				unsigned long mark, int highest_zoneidx,
				unsigned int alloc_flags, gfp_t gfp_mask)
{
	long free_pages;

	free_pages = zone_page_state(z, NR_FREE_PAGES);//获取区域空闲物理页数量

	//针对0阶执行快速检查
	if (!order) {
		long usable_free;
		long reserved;

		usable_free = free_pages;
		//计算不可用的空闲页，可能包含高阶原子和CMA
		reserved = __zone_watermark_unusable_free(z, 0, alloc_flags);

		/* reserved may over estimate high-atomic reserves. */
		usable_free -= min(usable_free, reserved);//计算出可用空闲页
		//如果空闲页数大于（水线 +  低端内存保留页数）
		if (usable_free > mark + z->lowmem_reserve[highest_zoneidx])
			return true;//水位线足够，允许从这个区域分配页
	}

	if (__zone_watermark_ok(z, order, mark, highest_zoneidx, alloc_flags,
					free_pages))// 高阶调用__zone_watermark_ok检查水位
		return true;

	//如果是高阶原子分配，并且允许从最低水位分配
	if (unlikely(!order && (gfp_mask & __GFP_ATOMIC) && z->watermark_boost
		&& ((alloc_flags & ALLOC_WMARK_MASK) == WMARK_MIN))) {
		mark = z->_watermark[WMARK_MIN];//修改为水低水位线
		return __zone_watermark_ok(z, order, mark, highest_zoneidx,
					alloc_flags, free_pages);
	}

	return false;
}

zone_watermark_fast调用函数zone_page_state获取区域空闲物理页数量，如果是0阶，调用__zone_watermark_unusable_free计算不可用的空闲页，最后计算出可用的空闲页，然后判断如果可用空闲页数大于（水线 + 低端内存保留页数），说明内存足够，返回ture；剩下就是高阶了，调用__zone_watermark_ok检查水位，水位线足够则返回真。如果水位不足，再判断是高阶原子分配，并且允许调用__zone_watermark_ok从最低水位分配。我们看看__zone_watermark_ok：

bool __zone_watermark_ok(struct zone *z, unsigned int order, unsigned long mark,
			 int highest_zoneidx, unsigned int alloc_flags,
			 long free_pages)
{
	long min = mark;
	int o;
	const bool alloc_harder = (alloc_flags & (ALLOC_HARDER|ALLOC_OOM));

	//空闲页减去不可用的空闲页，得到可用的空闲页数量
	free_pages -= __zone_watermark_unusable_free(z, order, alloc_flags);

	if (alloc_flags & ALLOC_HIGH)//如果调用者是高优先级的
		min -= min / 2;//把水线减半

	if (unlikely(alloc_harder)) {//如果调用者要求更努力分配
		if (alloc_flags & ALLOC_OOM)//如果是OOM触发的内存分配
			min -= min / 2;//把水线减半
		else//不是OOM触发的内存分配
			min -= min / 4;//把水线减去四分之一
	}

	//如果可用空闲页小于等于（水线 +  低端内存保留页数）
	if (free_pages <= min + z->lowmem_reserve[highest_zoneidx])
		return false;//不能从这个区域分配页

	if (!order)//如果只申请一页
		return true;//允许从这个区域分配页

	
	for (o = order; o < MAX_ORDER; o++) {//如果申请阶数大于0
		struct free_area *area = &z->free_area[o];
		int mt;

		if (!area->nr_free)//如果该区域没有空闲页
			continue;

		//不可移动、可移动和可回收任何一种迁移类型，
		for (mt = 0; mt < MIGRATE_PCPTYPES; mt++) {
			if (!free_area_empty(area, mt))//只要该区域不是空
				return true;//允许从这个区域分配页
		}

#ifdef CONFIG_CMA
		if ((alloc_flags & ALLOC_CMA) &&	//如果调用者允许从 CMA 迁移类型分配， 
		    !free_area_empty(area, MIGRATE_CMA)) {//只要该区域不是空
			return true;//允许从这个区域分配页
		}
#endif
		//如果调用者要求更努力分配，并且高阶原子区域不为空
		if (alloc_harder && !free_area_empty(area, MIGRATE_HIGHATOMIC))
			return true;//允许从这个区域分配页
	}
	return false;//不能从这个区域分配页
}

__zone_watermark_ok调用函数__zone_watermark_unusable_free计算不可用的空闲页，空闲页减去不可用的空闲页，得到可用的空闲页数量，如果调用者是高优先级的，把水线减半；如果调用者要求更努力分配，再根据是否oom设置把水线；接着判断如果可用空闲页小于等于（水线 + 低端内存保留页数），说明不能从这个区域分配页，返回false。如果只申请一页，允许从这个区域分配页，返回true。如果申请阶数大于0，则遍历不可移动、可移动和可回收任何一种迁移类型，只要该区域不是空，允许从这个区域分配页返回true。如果调用者允许从 CMA 迁移类型分配， 只要CMA区域不是空，也允许从这个区域分配页，返回true。如果调用者要求更努力分配，并且高阶原子区域不为空，允许从这个区域分配页，返回true。

3.2.2 zone_watermark_ok

bool zone_watermark_ok(struct zone *z, unsigned int order, unsigned long mark,
		      int highest_zoneidx, unsigned int alloc_flags)
{
	return __zone_watermark_ok(z, order, mark, highest_zoneidx, alloc_flags,
					zone_page_state(z, NR_FREE_PAGES));
}

zone_watermark_ok是调用zone_watermark_ok函数判断水位的，zone_watermark_ok函数我们前面讲过了。

3.2.3 rmqueue

static inline
struct page *rmqueue(struct zone *preferred_zone,
			struct zone *zone, unsigned int order,
			gfp_t gfp_flags, unsigned int alloc_flags,
			int migratetype)
{
	unsigned long flags;
	struct page *page;

	if (likely(order == 0)) {//如果申请阶数是 0 
		/*
		 * MIGRATE_MOVABLE pcplist could have the pages on CMA area and
		 * we need to skip it when CMA area isn't allowed.
		 */
		if (!IS_ENABLED(CONFIG_CMA) || alloc_flags & ALLOC_CMA ||
				migratetype != MIGRATE_MOVABLE) {//允许CMA或者不是可移动的
			page = rmqueue_pcplist(preferred_zone, zone, gfp_flags,
					migratetype, alloc_flags);//从每处理器页集合分配页
			goto out;
		}
	}

	//如果申请阶数大于1，不要试图无限次重试
	WARN_ON_ONCE((gfp_flags & __GFP_NOFAIL) && (order > 1));
	spin_lock_irqsave(&zone->lock, flags);//自旋锁

	do {
		page = NULL;
		/*
		 * order-0 request can reach here when the pcplist is skipped
		 * due to non-CMA allocation context. HIGHATOMIC area is
		 * reserved for high-order atomic allocation, so order-0
		 * request should skip it.
		 */
		if (order > 0 && alloc_flags & ALLOC_HARDER) {//如果调用者要求更努力分配
			page = __rmqueue_smallest(zone, order, MIGRATE_HIGHATOMIC);//先尝试从高阶原子类型分配页。
			if (page)
				trace_mm_page_alloc_zone_locked(page, order, migratetype);
		}
		if (!page)//高阶原子类型分配失败
			page = __rmqueue(zone, order, migratetype, alloc_flags);//从指定迁移类型分配页。
	} while (page && check_new_pages(page, order));//检查分配到的每一个page是否是新的
	spin_unlock(&zone->lock);//自旋锁解锁
	if (!page)
		goto failed;
	__mod_zone_freepage_state(zone, -(1 << order),//修改每cpu的zone的迁移属性
				  get_pcppage_migratetype(page));

	__count_zid_vm_events(PGALLOC, page_zonenum(page), 1 << order);
	zone_statistics(preferred_zone, zone);
	local_irq_restore(flags);//恢复中断

out:
	//从应急列表中申请内存会设置ZONE_BOOSTED_WATERMARK
	if (test_bit(ZONE_BOOSTED_WATERMARK, &zone->flags)) {
		clear_bit(ZONE_BOOSTED_WATERMARK, &zone->flags);
		wakeup_kswapd(zone, 0, 0, zone_idx(zone));//都应急了，说明内存不足，需要唤醒kswapd
	}

	VM_BUG_ON_PAGE(page && bad_range(zone, page), page);
	return page;

failed:
	local_irq_restore(flags);
	return NULL;
}
  1. 如果申请阶数是 0 ，并且允许CMA或者不是可移动的，那么调用rmqueue_pcplist函数从每处理器页集合分配页，成功就返回；
  2. 如果申请阶数大于1，不要试图无限次重试，自旋锁上锁
  3. 如果调用者要求更努力分配，调用函数__rmqueue_smallest先尝试从高阶原子类型分配页。
  4. 如果高阶原子类型分配失败，调用函数__rmqueue从指定迁移类型分配页。
  5. 如果成功分配则调用check_new_pages检查分配到的每一个page是否是新的，是就往下走，不是就回到2重新分配
  6. 自旋锁解锁
  7. 调用函数__mod_zone_freepage_state修改每cpu的zone的迁移属性
  8. 如果从应急列表中申请内存会设置ZONE_BOOSTED_WATERMARK，调用函数wakeup_kswapd唤醒kswapd回收内存

下面我们需要分析rmqueue_pcplist、__rmqueue_smallest和__rmqueue函数。

3.2.3.1 rmqueue_pcplist

static struct page *rmqueue_pcplist(struct zone *preferred_zone,
			struct zone *zone, gfp_t gfp_flags,
			int migratetype, unsigned int alloc_flags)
{
	struct per_cpu_pages *pcp;
	struct list_head *list;
	struct page *page;
	unsigned long flags;

	local_irq_save(flags);//关闭中断
	pcp = &this_cpu_ptr(zone->pageset)->pcp;//找到pcp
	list = &pcp->lists[migratetype];//选择pcp中3个类型链表中的一个
	//从每cpu列表中删除页面
	page = __rmqueue_pcplist(zone,  migratetype, alloc_flags, pcp, list);
	if (page) {
		__count_zid_vm_events(PGALLOC, page_zonenum(page), 1);//计数加一
		zone_statistics(preferred_zone, zone);//更新NUMA命中/错过统计数据
	}
	local_irq_restore(flags);//恢复中断
	return page;
}

rmqueue_pcplist：

  1. 关中断，找到pcp，从pcp取出需要申请的类型链表
  2. 调用该函数__rmqueue_pcplist从每cpu列表中删除页面
  3. 如果每cpu列表中取到内存，pcp的计数加一，更新NUMA命中/错过统计数据
  4. 恢复中断
    我们再看看__rmqueue_pcplist是怎么从每cpu列表中拿到内存的：
static struct page *__rmqueue_pcplist(struct zone *zone, int migratetype,
			unsigned int alloc_flags,
			struct per_cpu_pages *pcp,
			struct list_head *list)
{
	struct page *page;

	do {
		if (list_empty(list)) {//如果每处理器页集合中指定迁移类型的链表是空的，
			//批量申请页加入链表
			pcp->count += rmqueue_bulk(zone, 0,
					pcp->batch, list,
					migratetype, alloc_flags);
			if (unlikely(list_empty(list)))
				return NULL;
		}

		page = list_first_entry(list, struct page, lru);//从lru list中找到第一个page
		list_del(&page->lru);//把page移出lru列表
		pcp->count--;//pcp计数减一
	} while (check_new_pcp(page));//检查page是否新页

	return page;
}

__rmqueue_pcplist：

  1. 如果每处理器页集合中指定迁移类型的链表是空的，调用rmqueue_bulk函数批量申请页加入链表，
  2. 调用函数list_first_entry从lru list中找到第一个page，
  3. 调用函数list_del把page移出lru列表，pcp计数减一
  4. 调用check_new_pcp检查page是否是新的，如果是，返回page，如果不是，回到1重新来过

rmqueue_bulk是从当pcp为空的时候，批量申请页放入pcp链表中，我们看看过程：

static int rmqueue_bulk(struct zone *zone, unsigned int order,
			unsigned long count, struct list_head *list,
			int migratetype, unsigned int alloc_flags)
{
	int i, alloced = 0;

	spin_lock(&zone->lock);//自旋锁上锁
	for (i = 0; i < count; ++i) {//循环调用__rmqueue从指定迁移类型分配页
		struct page *page = __rmqueue(zone, order, migratetype,
								alloc_flags);//从指定迁移类型分配页。
		if (unlikely(page == NULL))//中途失败返回
			break;

		if (unlikely(check_pcp_refill(page)))
			continue;

		list_add_tail(&page->lru, list);//把该页加到空闲链表
		alloced++;//申请数量加一
		//如果page的类型是CMA
		if (is_migrate_cma(get_pcppage_migratetype(page)))
			__mod_zone_page_state(zone, NR_FREE_CMA_PAGES,
					      -(1 << order));//zone的CMA类型数量减去相应的数值
	}

	//zone的空闲页数量减去相应的数值
	__mod_zone_page_state(zone, NR_FREE_PAGES, -(i << order));
	spin_unlock(&zone->lock);//自旋锁解锁
	return alloced;
}

rmqueue_bulk：

  1. 自旋锁上锁
  2. 在for循环里面调用__rmqueue函数从伙伴系统中的指定区域的指定迁移类型分配页出来，
  3. 每取出一个page就把这个page加入到pcp的空闲链表中，
  4. 如果取出的是CMA区域的内存，调用__mod_zone_page_state函数修改CMA空闲页的数量
  5. 直到分配失败或者数量达到pcp->batch，就退出循环
  6. 最后调用__mod_zone_page_state修改zone的全部空闲页数量，自旋锁解锁

这里还有一个很重要的函数，__rmqueue，这个函数是从伙伴系统中取出指定zone指定迁移类型指定order的page的函数，下面一点点会讲的。

3.2.3.2 __rmqueue

static __always_inline struct page *
__rmqueue(struct zone *zone, unsigned int order, int migratetype,
						unsigned int alloc_flags)
{
	struct page *page;

	if (IS_ENABLED(CONFIG_CMA)) {
		//当CMA区域的空闲页数量大于全部区域空闲页的一半的时候
		if (alloc_flags & ALLOC_CMA &&
		    zone_page_state(zone, NR_FREE_CMA_PAGES) >
		    zone_page_state(zone, NR_FREE_PAGES) / 2) {
		    //从CMA区域分配，从而平衡常规区域和CMA区域之间的可移动分配
			page = __rmqueue_cma_fallback(zone, order);
			if (page)
				goto out;
		}
	}
retry:
	//分配指定类型的内存页
	page = __rmqueue_smallest(zone, order, migratetype);
	if (unlikely(!page)) {
		if (alloc_flags & ALLOC_CMA)//如果允许从CMA区域分配内存
			page = __rmqueue_cma_fallback(zone, order);//从CMA区域分配

		if (!page && __rmqueue_fallback(zone, order, migratetype,
								alloc_flags))//从备用迁移类型盗用页
			goto retry;
	}
out:
	if (page)
		trace_mm_page_alloc_zone_locked(page, order, migratetype);
	return page;
}

__rmqueue 的处理过程如下：

  1. 如果CMA区域内存很多，那么调用函数__rmqueue_cma_fallback从CMA区域分配内存，如果分配成功，那么处理结束；如果分配失败往下走，
  2. 调用函数__rmqueue_smallest从指定的zone、指定迁移类型分配指定order的页，如果分配成功，那么处理结束；如果分配失败往下走，
  3. 如果调用者允许从CMA区域分配内存，那么调用函数__rmqueue_cma_fallback从 CMA 类型分配。如果分配成功，那么处理结束；如果分配失败往下走，
  4. 调用函数__rmqueue_fallback从备用迁移类型盗用页，如果分配成功，那么处理结束；如果分配失败，回到2再试试。

函数就是调用__rmqueue_smallest指定CMA类型从CMA区域分配内存的，所以我们需要__rmqueue_smallest和__rmqueue_fallback。

3.2.3.2.1 __rmqueue_smallest

static __always_inline
struct page *__rmqueue_smallest(struct zone *zone, unsigned int order,
						int migratetype)
{
	unsigned int current_order;
	struct free_area *area;
	struct page *page;

	//从申请阶数到最大分配阶数逐个尝试
	for (current_order = order; current_order < MAX_ORDER; ++current_order) {
		area = &(zone->free_area[current_order]);//找到order对应的区域
		page = get_page_from_free_area(area, migratetype);//从区域中获取第一个页
		if (!page)//找不到
			continue;//尝试下一个order
		//从zone中取出找到的page，修改zone的统计数量
		del_page_from_free_list(page, zone, current_order);
		//分裂page，把多余部分放到其他页块链表里面
		expand(zone, page, order, current_order, migratetype);
		set_pcppage_migratetype(page, migratetype);//设置page的类型
		return page;
	}

	return NULL;
}

__rmqueue_smallest的处理过程如下：
使用for循环从申请的order到最大的order，执行下面的操作：

  1. 找到zone对应order的area，然后从area拿到第一个页，如果拿不到，尝试下一个order，
  2. 拿到了，调用del_page_from_free_list函数从zone中取出找到的page，修改zone的统计数量，
  3. 调用函数expand，把page分裂，然后把多余部分放到其他页块链表里面，
  4. 最后设置page的类型，返回page

expand(zone, page, order, current_order, migratetype)函数就是把刚刚从zone区域的拿到的page，这个page的阶是current_order，需要分裂出我们需要的阶为order的页，把其他的页放入zone的migratetype类型空闲链表中。

static inline void expand(struct zone *zone, struct page *page,
	int low, int high, int migratetype)
{
	unsigned long size = 1 << high;

	while (high > low) {//如果申请到的order大于申请的order
		high--;//逐步把high阶的内存分裂，直到成成low阶的内存，
		size >>= 1;
		VM_BUG_ON_PAGE(bad_range(zone, &page[size]), &page[size]);

		//标记为保护页，当其伙伴被释放时，允许合并，这里是空函数
		if (set_page_guard(zone, &page[size], high, migratetype))
			continue;

		//把另一个页面放入空闲链表中
		add_to_free_list(&page[size], zone, high, migratetype);
		set_buddy_order(&page[size], high);//修改页的private
	}
}

expand的处理过程如下：
使用for循环，从申请到的阶数high开始，直到需要的阶数order，逐步把page分裂，执行下面的操作：

  1. 阶数减1，意思是把一个阶数为high的page分裂成两个阶数为high-1的page，size减半，order减少了，page 的大小也要修改
  2. 调用函数set_page_guard把第二个page标记一下，因为第一个page是我们需要的
  3. 调用函数add_to_free_list把第二个page放入zone的hight阶migratetype类型的链表中，因为第一个page是我们需要的，
  4. 调用函数set_buddy_order修改page的private参数，这个参数存放pag的order大小。

3.2.3.2.2 __rmqueue_fallback

static __always_inline bool
__rmqueue_fallback(struct zone *zone, int order, int start_migratetype,
						unsigned int alloc_flags)
{
	struct free_area *area;
	int current_order;
	int min_order = order;
	struct page *page;
	int fallback_mt;
	bool can_steal;

	if (alloc_flags & ALLOC_NOFRAGMENT)//如果设置了ALLOC_NOFRAGMENT，避免页面太分散
		min_order = pageblock_order;//设置最小偷取的阶层，这里是9

	//从最大分配阶数开始逐个尝试，直到刚刚设置的最小申请页面
	for (current_order = MAX_ORDER - 1; current_order >= min_order;
				--current_order) {
		area = &(zone->free_area[current_order]);//找到order对应的区域
		fallback_mt = find_suitable_fallback(area, current_order,
				start_migratetype, false, &can_steal);//查找适合的类型
		if (fallback_mt == -1)
			continue;

		//如果我们可以偷，并且要偷的类型是可移动的
		if (!can_steal && start_migratetype == MIGRATE_MOVABLE
					&& current_order > order)
			goto find_smallest;//我们不要偷太大，偷个最小的

		goto do_steal;//否则就偷个最大的
	}

	return false;

find_smallest:
	//从申请阶数到最大分配阶数逐个尝试
	for (current_order = order; current_order < MAX_ORDER;
							current_order++) {
		area = &(zone->free_area[current_order]);//找到order对应的区域
		fallback_mt = find_suitable_fallback(area, current_order,
				start_migratetype, false, &can_steal);查找适合的类型
		if (fallback_mt != -1)
			break;
	}

	/*
	 * This should not happen - we already found a suitable fallback
	 * when looking for the largest page.
	 */
	VM_BUG_ON(current_order == MAX_ORDER);

do_steal:
	page = get_page_from_free_area(area, fallback_mt);//从区域中获取第一个页
	//实际的偷窃函数
	steal_suitable_fallback(zone, page, alloc_flags, start_migratetype,
								can_steal);

	trace_mm_page_alloc_extfrag(page, order, current_order,
		start_migratetype, fallback_mt);

	return true;

}

__rmqueue_fallback是从同一个zone的其他类型偷取一个大的page过来使用的函数，处理过程如下：

  1. 如果设置了ALLOC_NOFRAGMENT，避免页面太分散，设置最小偷取的阶层，这里是9
  2. for循环从最大分配阶数开始逐个尝试，直到刚刚设置的最小申请页面，在循环里面执行：
  3. 找到自己的zone对应阶层的frea，
  4. 调用函数find_suitable_fallback查找其他类型，查找可以偷的类型的index，找到就退出循环。
  5. 如果我们偷的类型是可移动的，我们不要偷太大，去到6偷个最小的，否则去到7开始偷。
  6. 进入for循环，从申请阶数到最大分配阶数逐个尝试，循环体中调用函数查找适合的类型。然后去到7开始偷
  7. 调用函数get_page_from_free_area从备用区域找到第一个ye
  8. 调用函数steal_suitable_fallback从zone的备用区域偷取出一整块内存。

steal_suitable_fallback主要作用是把从找到的类型中拿出一个大的page，我们一起看看：

static void steal_suitable_fallback(struct zone *zone, struct page *page,
		unsigned int alloc_flags, int start_type, bool whole_block)
{
	unsigned int current_order = buddy_order(page);//获取当前页面的order
	int free_pages, movable_pages, alike_pages;
	int old_block_type;

	old_block_type = get_pageblock_migratetype(page);//获取要偷的页的迁移类型

	if (is_migrate_highatomic(old_block_type))
		goto single_page;

	/* Take ownership for orders >= pageblock_order */
	if (current_order >= pageblock_order) {
		change_pageblock_range(page, current_order, start_type);
		goto single_page;
	}

	//如果调用boost_watermark提高水位线，并且调用者允许KSWAPD
	if (boost_watermark(zone) && (alloc_flags & ALLOC_KSWAPD))
		set_bit(ZONE_BOOSTED_WATERMARK, &zone->flags);//设置ZONE_BOOSTED_WATERMARK位

	if (!whole_block)//如果不允许偷一整块
		goto single_page;//去偷一页
	
	free_pages = move_freepages_block(zone, page, start_type,
						&movable_pages);//偷取一整块的页面
	/*
	 * Determine how many pages are compatible with our allocation.
	 * For movable allocation, it's the number of movable pages which
	 * we just obtained. For other types it's a bit more tricky.
	 */
	if (start_type == MIGRATE_MOVABLE) {//如果偷取的类型为可移动
		alike_pages = movable_pages;
	} else {
		/*
		 * If we are falling back a RECLAIMABLE or UNMOVABLE allocation
		 * to MOVABLE pageblock, consider all non-movable pages as
		 * compatible. If it's UNMOVABLE falling back to RECLAIMABLE or
		 * vice versa, be conservative since we can't distinguish the
		 * exact migratetype of non-movable pages.
		 */
		if (old_block_type == MIGRATE_MOVABLE)
			alike_pages = pageblock_nr_pages
						- (free_pages + movable_pages);
		else
			alike_pages = 0;
	}

	if (!free_pages)//整个块的移动失败了，
		goto single_page;//去偷一页

	/*
	 * If a sufficient number of pages in the block are either free or of
	 * comparable migratability as our allocation, claim the whole block.
	 */
	//如果块中有足够多的空闲页面
	if (free_pages + alike_pages >= (1 << (pageblock_order-1)) ||
			page_group_by_mobility_disabled)
		set_pageblock_migratetype(page, start_type);//修改整块的类型

	return;

single_page:
	将page从盗用freelist 移动到需要的freelist中
	move_to_free_list(page, zone, current_order, start_type);
}

steal_suitable_fallback过程如下：

  1. 首先调用函数buddy_order获取传入页面的order，
  2. 调用函数get_pageblock_migratetype获取要偷的页的迁移类型，
  3. 如果迁移类型是高阶原子，去到进行末尾执行盗取单页，
  4. 如果调用boost_watermark提高水位线，并且调用者允许KSWAPD，设置ZONE_BOOSTED_WATERMARK位，前面讲的ZONE_BOOSTED_WATERMARK决定我们是否启动进程KSWAPD就是在这里被设置的，
  5. 开始调用函数move_freepages_block偷取一整块内存页，
  6. 如果整个块的偷取失败了，去到进行末尾执行盗取单页，
  7. 如果块中有足够多的空闲页面，修改整块的类型，然后返回。
  8. 调用函数move_to_free_list将page从盗用freelist 移动一个page到需要的freelist中

move_freepages_block是怎么拿到一整块内存的：

int move_freepages_block(struct zone *zone, struct page *page,
				int migratetype, int *num_movable)
{
	unsigned long start_pfn, end_pfn;
	struct page *start_page, *end_page;

	if (num_movable)
		*num_movable = 0;

	start_pfn = page_to_pfn(page);//根据盗用的页，获取页的页帧
	start_pfn = start_pfn & ~(pageblock_nr_pages-1);//对齐页帧，找到起始页帧
	start_page = pfn_to_page(start_pfn);//根据页帧找到对应的page
	end_page = start_page + pageblock_nr_pages - 1;//计算出页最后一个page
	end_pfn = start_pfn + pageblock_nr_pages - 1;//计算出页尾的页帧

	//根据zone，避免越过区域边界
	if (!zone_spans_pfn(zone, start_pfn))
		start_page = page;
	if (!zone_spans_pfn(zone, end_pfn))
		return 0;

	return move_freepages(zone, start_page, end_page, migratetype,
								num_movable);
}

move_freepages_block的过程如下所示：

  1. 调用函数page_to_pfn根据盗用的页，获取页的页帧
  2. 对齐页帧，找到起始页帧
  3. 根据页帧找到对应的page
  4. 计算出页最后一个page
  5. 计算出页尾的页帧
  6. 根据zone，避免越过区域边界
  7. 最后调用move_freepages移动整块页面

move_freepages：

static int move_freepages(struct zone *zone,
			  struct page *start_page, struct page *end_page,
			  int migratetype, int *num_movable)
{
	struct page *page;
	unsigned int order;
	int pages_moved = 0;
	//for循环来进行移动每一个页
	for (page = start_page; page <= end_page;) {
		if (!pfn_valid_within(page_to_pfn(page))) {//如果此page的页帧不是有效的
			page++;
			continue;//则跳过，下一个
		}

		if (!PageBuddy(page)) {//如果page不在buddy中
			if (num_movable &&
					(PageLRU(page) || __PageMovable(page)))
				(*num_movable)++;

			page++;
			continue;//则跳过
		}

		/* Make sure we are not inadvertently changing nodes */
		VM_BUG_ON_PAGE(page_to_nid(page) != zone_to_nid(zone), page);
		VM_BUG_ON_PAGE(page_zone(page) != zone, page);

		order = buddy_order(page);//记录page的order
		//将page从盗用freelist 移动到需要的freelist中
		move_to_free_list(page, zone, order, migratetype);
		page += 1 << order;
		pages_moved += 1 << order;
	}

	return pages_moved;
}

move_freepages的过程如下：
使用for循环来进行移动每一个页，从start_page到end_page，执行下面的操作：

  1. 调用函数pfn_valid_within判断page的页帧不是有效的，如果不是则跳过，执行下一个page
  2. 调用函数PageBuddy判断一个page在不在伙伴系统中，如果不在则跳过，执行下一个page
  3. 调用函数buddy_order记录page的order，然后调用函数move_to_free_list把一个page移出来

3.3 __alloc_pages_slowpath

如果使用低水线分配失败，那么执行慢速路径，慢速路径是在函数__alloc_pages_slowpath 中实现的：

static inline struct page *
__alloc_pages_slowpath(gfp_t gfp_mask, unsigned int order,
						struct alloc_context *ac)
{
	bool can_direct_reclaim = gfp_mask & __GFP_DIRECT_RECLAIM;
	const bool costly_order = order > PAGE_ALLOC_COSTLY_ORDER;
	struct page *page = NULL;
	unsigned int alloc_flags;
	unsigned long did_some_progress;
	enum compact_priority compact_priority;
	enum compact_result compact_result;
	int compaction_retries;
	int no_progress_loops;
	unsigned int cpuset_mems_cookie;
	unsigned int zonelist_iter_cookie;
	int reserve_flags;

	/*
	 * We also sanity check to catch abuse of atomic reserves being used by
	 * callers that are not in atomic context.
	 */
	if (WARN_ON_ONCE((gfp_mask & (__GFP_ATOMIC|__GFP_DIRECT_RECLAIM)) ==
				(__GFP_ATOMIC|__GFP_DIRECT_RECLAIM)))
		gfp_mask &= ~__GFP_ATOMIC;

restart:
	compaction_retries = 0;
	no_progress_loops = 0;
	compact_priority = DEF_COMPACT_PRIORITY;
	//后面可能会检查cpuset是否允许当前进程从哪些内存节点申请页
	cpuset_mems_cookie = read_mems_allowed_begin();
	zonelist_iter_cookie = zonelist_iter_begin();


	//把分配标志位转换成内部分配标志位
	alloc_flags = gfp_to_alloc_flags(gfp_mask);

	//获取首选的内存区域
	ac->preferred_zoneref = first_zones_zonelist(ac->zonelist,
					ac->highest_zoneidx, ac->nodemask);
	if (!ac->preferred_zoneref->zone)
		goto nopage;

	if (alloc_flags & ALLOC_KSWAPD)//如果调用者允许异步回收页，
		wake_all_kswapds(order, gfp_mask, ac);//唤醒页回收线程

	/*
	 * The adjusted alloc_flags might result in immediate success, so try
	 * that first
	 */
	//调整alloc_flags后可能会立即申请成功，所以再尝试一下
	page = get_page_from_freelist(gfp_mask, order, alloc_flags, ac);
	if (page)//如果申请到内存
		goto got_pg;//可以返回了


	if (can_direct_reclaim &&	//如果可以直接回收
			(costly_order ||	//如果大于3阶或者申请不可移动的连续页
			   (order > 0 && ac->migratetype != MIGRATE_MOVABLE))
			&& !gfp_pfmemalloc_allowed(gfp_mask)) {//不允许使用紧急保留内存
		//尝试对高阶分配进行异步内存压缩，然后尝试分配
		page = __alloc_pages_direct_compact(gfp_mask, order,
						alloc_flags, ac,
						INIT_COMPACT_PRIORITY,
						&compact_result);
		if (page)//如果申请到内存
			goto got_pg;//可以返回了

		如果申请的内存大于等于3阶，并且调用者表示不再尝试
		if (costly_order && (gfp_mask & __GFP_NORETRY)) {
			//如果压缩过了但是失败，或者压缩过了导致一段时间内不会再次压缩
			if (compact_result == COMPACT_SKIPPED ||
			    compact_result == COMPACT_DEFERRED)
				goto nopage;//返回失败

			compact_priority = INIT_COMPACT_PRIORITY;//使用异步压缩
		}
	}

retry:
	/* Ensure kswapd doesn't accidentally go to sleep as long as we loop */
	if (alloc_flags & ALLOC_KSWAPD)//如果调用者允许KSWAPD
		wake_all_kswapds(order, gfp_mask, ac);

	//如果调用者没有反对CMA分配，则允许CMA分配
	reserve_flags = __gfp_pfmemalloc_flags(gfp_mask);
	if (reserve_flags)
		alloc_flags = current_alloc_flags(gfp_mask, reserve_flags);

	//如果调用者没有要求使用cpuset，那么重新获取区域列表
	if (!(alloc_flags & ALLOC_CPUSET) || reserve_flags) {
		ac->nodemask = NULL;
		ac->preferred_zoneref = first_zones_zonelist(ac->zonelist,
					ac->highest_zoneidx, ac->nodemask);
	}

	//重新调整alloc_flags后尝试分配
	page = get_page_from_freelist(gfp_mask, order, alloc_flags, ac);
	if (page)
		goto got_pg;

	if (!can_direct_reclaim)//调用者要求直接分配，不能等待
		goto nopage;//返回失败

	//直接回收页的时候给进程设置了标志位PF_MEMALLOC
	if (current->flags & PF_MEMALLOC)//如果设置了PF_MEMALLOC，避免递归
		goto nopage;//返回失败

	//尝试直接回收页
	page = __alloc_pages_direct_reclaim(gfp_mask, order, alloc_flags, ac,
							&did_some_progress);
	if (page)
		goto got_pg;

	//执行同步模式的内存碎片整理
	page = __alloc_pages_direct_compact(gfp_mask, order, alloc_flags, ac,
					compact_priority, &compact_result);
	if (page)
		goto got_pg;

	if (gfp_mask & __GFP_NORETRY)//如果调用者要求不要重试
		goto nopage;

	//如果申请阶数大于3，并且调用者没有要求重试，
	if (costly_order && !(gfp_mask & __GFP_RETRY_MAYFAIL))
		goto nopage;

	//如果认为有必要重新尝试回收页
	if (should_reclaim_retry(gfp_mask, order, ac, alloc_flags,
				 did_some_progress > 0, &no_progress_loops))
		goto retry;

	/*
	 * It doesn't make any sense to retry for the compaction if the order-0
	 * reclaim is not able to make any progress because the current
	 * implementation of the compaction depends on the sufficient amount
	 * of free memory (see __compaction_suitable)
	 */
	if (did_some_progress > 0 &&	//之前直接回收页有进展
			should_compact_retry(ac, order, alloc_flags,//如果认为有必要重新尝试压缩
				compact_result, &compact_priority,
				&compaction_retries))
		goto retry;


	if (check_retry_cpuset(cpuset_mems_cookie, ac) ||	//如果cpuset更新
	    check_retry_zonelist(zonelist_iter_cookie))	//如果zonelist更新 
		goto restart;

	//使用内存耗尽杀手选择一个进程杀死
	page = __alloc_pages_may_oom(gfp_mask, order, ac, &did_some_progress);
	if (page)
		goto got_pg;

	if (tsk_is_oom_victim(current) &&	//如果当前进程正在被内存耗尽杀手杀死
	    (alloc_flags & ALLOC_OOM ||		//调用者允许OOM
	     (gfp_mask & __GFP_NOMEMALLOC)))	//不允许使用紧急内存
		goto nopage;

	if (did_some_progress) {//如果内存耗尽杀手取得进展
		no_progress_loops = 0;
		goto retry;
	}

nopage:
	/*
	 * Deal with possible cpuset update races or zonelist updates to avoid
	 * a unnecessary OOM kill.
	 */
	if (check_retry_cpuset(cpuset_mems_cookie, ac) ||	//如果cpuset更新
	    check_retry_zonelist(zonelist_iter_cookie))		//如果zonelist更新 
		goto restart;

	/*
	 * Make sure that __GFP_NOFAIL request doesn't leak out and make sure
	 * we always retry
	 */
	if (gfp_mask & __GFP_NOFAIL) {//如果调用者要求不能失败
		if (WARN_ON_ONCE(!can_direct_reclaim))//同时要求不能失败和不能直接回收页
			goto fail;
		
		WARN_ON_ONCE(current->flags & PF_MEMALLOC);
		WARN_ON_ONCE(order > PAGE_ALLOC_COSTLY_ORDER);

		//先使用标志位ALLOC_CPUSET尝试分配，失败再使用ALLOC_HARDER尝试分配
		page = __alloc_pages_cpuset_fallback(gfp_mask, order, ALLOC_HARDER, ac);
		if (page)
			goto got_pg;

		cond_resched();
		goto retry;
	}
fail:
	warn_alloc(gfp_mask, ac->nodemask,
			"page allocation failure: order:%u", order);
got_pg:
	return page;
}
  1. 如果允许异步回收页，那么调用函数wake_all_kswapds针对每个目标区域，唤醒区域所属内存节点的页回收线程。
  2. 调整alloc_flags后调用函数get_page_from_freelist尝试分配
  3. 如果申请阶数大于 3 并且允许直接回收页，那么调用函数__alloc_pages_direct_compact执行异步模式的内存碎片整理，然后尝试分配。
  4. 重新调整alloc_flags后调用函数get_page_from_freelist尝试分配
  5. 调用函数__alloc_pages_direct_reclaim直接回收页，然后尝试分配。
  6. 调用函数__alloc_pages_direct_compact执行同步模式的内存碎片整理，然后尝试分配。
  7. 如果多次尝试直接回收页和同步模式的内存碎片整理，仍然分配失败，那么调用函数__alloc_pages_may_oom使用杀伤力比较大的内存耗尽杀手选择一个进程杀死，然后尝试分配。

wake_all_kswapds函数主要作用是遍历每一个zone，然后回调zone所在的pglist_data的kcompactd_wait方法和kswapd_wait方法来实现异步压缩和回收的。get_page_from_freelist我们在快速路径中已经分析过了。__alloc_pages_cpuset_fallback就是两次调用函数get_page_from_freelist而已。都是很简单的我们不会继续展开。
下面的函数我们会继续分析，但是放在下一章：
a. 内存压缩函数：__alloc_pages_direct_compact
b. 内存回收函数：__alloc_pages_direct_reclaim
c. 内存杀手函数：__alloc_pages_may_oom

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/345433.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

怎么代理微信小程序创业？

怎么代理微信小程序创业？

随着微信的兴起&#xff0c;小程序已经成为了人们生活中不可或缺的一部分。如果你想要创业的话&#xff0c;那么代理微信小程序是一个不错的选择。本文将为大家介绍怎么代理微信小程序创业。 一、什么是微信小程序 微信小程序是一款专为移动设备使用者而设计的应用。它通过扫…
阅读更多...
javaEE 初阶 — 滑动窗口

javaEE 初阶 — 滑动窗口

文章目录滑动窗口1 滑动窗口下如何处理丢包TCP 工作机制&#xff1a;确认应答机制 超时重传机制 连接管理机制 滑动窗口 确认应答机制、超时重传机制、连接管理机制 都是给 TCP 的可靠性提供支持的。 虽然事变的比较可靠了&#xff0c;但是是有牺牲的&#xff0c;那就是传输…
阅读更多...
黑马SpringCloud知识点和面试题

黑马SpringCloud知识点和面试题

目录 一、微服务 1.1、微服务技术栈 1.2、微服务的介绍&#xff1a; 1.3、微服务技术对比 1.4、认识微服务-springcloud 1.4.1、springcloud和springboot的兼容性&#xff08;左边springcloud右边springboot版本&#xff09; 1.5、服务拆分&#xff0c;服务远程调用&…
阅读更多...
数学建模美赛【LaTeX】公式、表格、图片

数学建模美赛【LaTeX】公式、表格、图片

数学建模美赛【LaTeX】公式、表格、图片 1 宏包 \package{ } 就是在调用宏包&#xff0c;对计算机实在外行的同学姑且可以理解为工具箱。 每一个宏包里都定义了一些专门的命令&#xff0c;通过这些命令可以实现对于一类对象&#xff08;如数学公式等&#xff09;的统一排版&a…
阅读更多...
opencv的TrackBar控件

opencv的TrackBar控件

大家好&#xff0c;我是csdn的博主&#xff1a;lqj_本人 这是我的个人博客主页&#xff1a; lqj_本人的博客_CSDN博客-微信小程序,前端,python领域博主lqj_本人擅长微信小程序,前端,python,等方面的知识https://blog.csdn.net/lbcyllqj?spm1011.2415.3001.5343哔哩哔哩欢迎关注…
阅读更多...
HTML预格式化文本pre标签

HTML预格式化文本pre标签

文章目录参考white-spaceword-breakfont-family参考 https://blog.csdn.net/weixin_44368963/article/details/120054949 https://www.zhangxinxu.com/wordpress/2017/03/css-font-family-chinese-english/ pre 元素可定义预格式化的文本。被包围在 pre 元素中的文本通常会保留…
阅读更多...
UG二次开发装配篇 添加/拖动/删除组件方法的实现

UG二次开发装配篇 添加/拖动/删除组件方法的实现

我们在UG装配的过程中&#xff0c;经常会遇到需要调整组件目录位置&#xff0c;在软件设计过程中可以通过在目录树里面拖动组件来完成。 那么&#xff0c;如果要用程序实现组件的移动/拖动&#xff0c;我们要怎么做呢&#xff1f; 本节就完成了添加/拖动/删除组件方法的实现&…
阅读更多...
ZooKeeper集群搭建步骤

ZooKeeper集群搭建步骤

一、准备虚拟机准备三台虚拟机&#xff0c;对应ip地址和主机名如下&#xff1a;ip地址Hostname192.168.153.150ant163192.168.153.151ant164192.168.153.152ant165修改hostname&#xff0c;并使之生效[rootlocalhost /]# hostnamectl set-hostname zookeeper1 //修改hostname …
阅读更多...
分享好玩的h5小游戏制作步骤_怎么做h5微信小游戏

分享好玩的h5小游戏制作步骤_怎么做h5微信小游戏

近年来&#xff0c;市面上一直流行各种h5游戏&#xff0c;例如投票、答题、刮刮乐、大转盘等等等等&#xff0c;而且我在各种营销场景下经常看到它们的身影&#xff0c;是做促销&#xff0c;引流和宣传的神器之一&#xff01;那么&#xff0c;怎么做好玩的h5游戏&#xff1f;还…
阅读更多...
网络安全-Nmap

网络安全-Nmap

网络安全-Nmap Nmap-号称诸神之眼 这个呢就是用来扫描网络端口的 Namp的工作原理很像一个雷达 做任何攻击之前&#xff0c;得先知道怎么去找破绽&#xff0c;而不是钢铁洪流&#xff0c;那个是不叫渗透了&#xff0c;叫硬钢。 咋用呢&#xff1f; 很简单 直接 nmap 后面跟网址…
阅读更多...
Linux内核转储---kdump原理梳理

Linux内核转储---kdump原理梳理

文章目录Kexec和Kdump设计的区别kexeckdumpKdump的执行流程kexec的实现用户空间kexec内核空间vmcoreKdump的实现可以分为两部分&#xff1a;内核和用户工具。内核提供机制&#xff0c;用户工具在这些机制上实现各种转储策略&#xff0c;内核机制对用户工具的接口是一个系统调用…
阅读更多...
华为HCIE学习之Openstack Nova组件

华为HCIE学习之Openstack Nova组件

文章目录一、openstack组成形式二、Nova的模块1、Nova-api功能2、Nova-scheduler功能3、Nova-conductor功能4、Nova-novncproxy5、Nova-compute三、nova中的一些概念 一、openstack组成形式 openstack由一个个组件组成&#xff0c;每个组件由一个个模块组成。 二、Nova的模块…
阅读更多...
mac上安装redis的两种方法

mac上安装redis的两种方法

mac上安装redis的两种方法1. 安装方式1->使用homebrew安装redis1.1 安装redis1.1.1 安装homebrew1.1.2 查看redis安装目录1.2 安装等简单命令1.3 启动等相关命令1.3.1 使用brew命令启动1.3.2 redis-cli连接redis服务1.3.3 使用配置文件启动1.42. 安装方式2->官网下载安装…
阅读更多...
Spring Cloud之Zuul

Spring Cloud之Zuul

目录 简介 Zuul中的过滤器 过滤器的执行流程 使用过滤器 route过滤器的默认三种配置 路由到服务 路由到url地址 转发给自己 自定义过滤器 简介 Zuul是Netflix开源的微服务网关&#xff0c;主要功能是路由转发和过滤器&#xff0c;其原理也是一系列filters&#xff0…
阅读更多...
图文解说S参数（进阶篇）

图文解说S参数（进阶篇）

S参数是RF工程师/SI工程师必须掌握的内容&#xff0c;业界已有多位大师写过关于S参数的文章&#xff0c;即便如此&#xff0c;在相关领域打滚多年的人&#xff0c; 可能还是会被一些问题困扰着。你懂S参数吗? 图文解说S参数&#xff08;基础篇&#xff09; 请继续往下看...台湾…
阅读更多...
数据结构（三）：集合、字典、哈希表

数据结构（三）：集合、字典、哈希表

数据结构&#xff08;三&#xff09;一、集合&#xff08;Set&#xff09;1.封装一个集合类2.集合常见的操作&#xff08;1&#xff09;并集&#xff08;2&#xff09;交集&#xff08;3&#xff09;差集&#xff08;4&#xff09;子集二、字典&#xff08;Map&#xff09;三、…
阅读更多...
Powershell Install SQL Server 2022

Powershell Install SQL Server 2022

前言 SQL Server 2022 (16.x) 在早期版本的基础上构建，旨在将 SQL Server 发展成一个平台，以提供开发语言、数据类型、本地或云环境以及操作系统选项。 SQL Server Management Studio (SSMS) 是一种集成环境，用于管理从 SQL Server 到 Azure SQL 数据库的任何 SQL 基础结构…
阅读更多...
nginx如何用html显示多个图片并加入播放链接

nginx如何用html显示多个图片并加入播放链接

需求背景通过nginx来做个点播服务&#xff0c;ffmpeg截取视频中的某一帧作为视频的封面&#xff0c;前端页面展示这个封面&#xff0c;&#xff0c;并链接到对应的视频播放链接&#xff0c;加载播放器进行播放简单介绍一下ffmpeg截取视频中的某一帧的方式截取视频的第一帧&…
阅读更多...
HashedWheelTimer

HashedWheelTimer

序言这种算法是一种轮询算法的优化升级,能够以只有一个Timer的情况下处理大量的定时任务.Begin结合HashedWheelTimer的思想根据自然时间1分钟为例,来做大批量的定时任务触发首先定一个长度为60的数组,数组中存放的是Set集合,集合里面是任务详情.当有定时任务刚来的时候判断是否…
阅读更多...
死锁检测组件 -- 使用hook检测死锁

死锁检测组件 -- 使用hook检测死锁

目录 hook hook是什么 dlsym()函数 hook的实现步骤 加入hook的demo C/CLinux服务器开发/后台架构师【零声教育】-学习视频教程-腾讯课堂 hook hook可以把系统或第三方库提供的函数&#xff0c;替换成我们写的同名函数。会调用我们实现的函数。 hook是什么 hook提供了两…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023