FROMLIST: BACKPORT: mm: swap: mTHP allocate swap entries from nonfull list

Track the nonfull cluster as well as the empty cluster
on lists. Each order has one nonfull cluster list.

The cluster will remember which order it was used during
new cluster allocation.

When the cluster has free entry, add to the nonfull[order]
list.  When the free cluster list is empty, also allocate
from the nonempty list of that order.

This improves the mTHP swap allocation success rate.

There are limitations if the distribution of numbers of
different orders of mTHP changes a lot. e.g. there are a lot
of nonfull cluster assign to order A while later time there
are a lot of order B allocation while very little allocation
in order A. Currently the cluster used by order A will not
reused by order B unless the cluster is 100% empty.

Signed-off-by: Chris Li <chrisl@kernel.org>
Link: https://lore.kernel.org/r/20240711-swap-allocator-v4-2-0295a4d4c7aa@kernel.org/
Bug: 313807618
Bug: 351082780
[ Fix trivial conflict in include/linux/swap.h swap_info_struct
    - Kalesh Singh
Signed-off-by: Kalesh Singh <kaleshsingh@google.com>
Change-Id: I48cca8c1bb3d9061587f9217d72b55a6ba14adbd
This commit is contained in:
Chris Li 2024-07-11 00:29:06 -07:00 committed by Treehugger Robot
parent 96836d4fd5
commit 7cbe80f0b6
2 changed files with 35 additions and 3 deletions

View File

@ -266,9 +266,11 @@ struct swap_cluster_info {
*/ */
u16 count; u16 count;
u8 flags; u8 flags;
u8 order;
struct list_head list; struct list_head list;
}; };
#define CLUSTER_FLAG_FREE 1 /* This cluster is free */ #define CLUSTER_FLAG_FREE 1 /* This cluster is free */
#define CLUSTER_FLAG_NONFULL 2 /* This cluster is on nonfull list */
/* /*
@ -307,6 +309,8 @@ struct swap_info_struct {
unsigned char *swap_map; /* vmalloc'ed array of usage counts */ unsigned char *swap_map; /* vmalloc'ed array of usage counts */
struct swap_cluster_info *cluster_info; /* cluster info. Only for SSD */ struct swap_cluster_info *cluster_info; /* cluster info. Only for SSD */
struct list_head free_clusters; /* free clusters list */ struct list_head free_clusters; /* free clusters list */
struct list_head nonfull_clusters[SWAP_NR_ORDERS];
/* list of cluster that contains at least one free slot */
unsigned int lowest_bit; /* index of first free in swap_map */ unsigned int lowest_bit; /* index of first free in swap_map */
unsigned int highest_bit; /* index of last free in swap_map */ unsigned int highest_bit; /* index of last free in swap_map */
unsigned int pages; /* total of usable pages of swap */ unsigned int pages; /* total of usable pages of swap */

View File

@ -360,14 +360,21 @@ static void swap_cluster_schedule_discard(struct swap_info_struct *si,
memset(si->swap_map + idx * SWAPFILE_CLUSTER, memset(si->swap_map + idx * SWAPFILE_CLUSTER,
SWAP_MAP_BAD, SWAPFILE_CLUSTER); SWAP_MAP_BAD, SWAPFILE_CLUSTER);
if (ci->flags)
list_move_tail(&ci->list, &si->discard_clusters);
else
list_add_tail(&ci->list, &si->discard_clusters); list_add_tail(&ci->list, &si->discard_clusters);
ci->flags = 0;
schedule_work(&si->discard_work); schedule_work(&si->discard_work);
} }
static void __free_cluster(struct swap_info_struct *si, struct swap_cluster_info *ci) static void __free_cluster(struct swap_info_struct *si, struct swap_cluster_info *ci)
{ {
ci->flags = CLUSTER_FLAG_FREE; if (ci->flags & CLUSTER_FLAG_NONFULL)
list_move_tail(&ci->list, &si->free_clusters);
else
list_add_tail(&ci->list, &si->free_clusters); list_add_tail(&ci->list, &si->free_clusters);
ci->flags = CLUSTER_FLAG_FREE;
} }
/* /*
@ -490,7 +497,12 @@ static void dec_cluster_info_page(struct swap_info_struct *p, struct swap_cluste
ci->count--; ci->count--;
if (!ci->count) if (!ci->count)
free_cluster(p, ci); return free_cluster(p, ci);
if (!(ci->flags & CLUSTER_FLAG_NONFULL)) {
list_add_tail(&ci->list, &p->nonfull_clusters[ci->order]);
ci->flags |= CLUSTER_FLAG_NONFULL;
}
} }
/* /*
@ -549,6 +561,18 @@ new_cluster:
if (tmp == SWAP_NEXT_INVALID) { if (tmp == SWAP_NEXT_INVALID) {
if (!list_empty(&si->free_clusters)) { if (!list_empty(&si->free_clusters)) {
ci = list_first_entry(&si->free_clusters, struct swap_cluster_info, list); ci = list_first_entry(&si->free_clusters, struct swap_cluster_info, list);
list_del(&ci->list);
spin_lock(&ci->lock);
ci->order = order;
ci->flags = 0;
spin_unlock(&ci->lock);
tmp = cluster_index(si, ci) * SWAPFILE_CLUSTER;
} else if (!list_empty(&si->nonfull_clusters[order])) {
ci = list_first_entry(&si->nonfull_clusters[order], struct swap_cluster_info, list);
list_del(&ci->list);
spin_lock(&ci->lock);
ci->flags = 0;
spin_unlock(&ci->lock);
tmp = cluster_index(si, ci) * SWAPFILE_CLUSTER; tmp = cluster_index(si, ci) * SWAPFILE_CLUSTER;
} else if (!list_empty(&si->discard_clusters)) { } else if (!list_empty(&si->discard_clusters)) {
/* /*
@ -950,6 +974,7 @@ static void swap_free_cluster(struct swap_info_struct *si, unsigned long idx)
ci = lock_cluster(si, offset); ci = lock_cluster(si, offset);
memset(si->swap_map + offset, 0, SWAPFILE_CLUSTER); memset(si->swap_map + offset, 0, SWAPFILE_CLUSTER);
ci->count = 0; ci->count = 0;
ci->order = 0;
ci->flags = 0; ci->flags = 0;
free_cluster(si, ci); free_cluster(si, ci);
unlock_cluster(ci); unlock_cluster(ci);
@ -2905,6 +2930,9 @@ static int setup_swap_map_and_extents(struct swap_info_struct *p,
INIT_LIST_HEAD(&p->free_clusters); INIT_LIST_HEAD(&p->free_clusters);
INIT_LIST_HEAD(&p->discard_clusters); INIT_LIST_HEAD(&p->discard_clusters);
for (i = 0; i < SWAP_NR_ORDERS; i++)
INIT_LIST_HEAD(&p->nonfull_clusters[i]);
for (i = 0; i < swap_header->info.nr_badpages; i++) { for (i = 0; i < swap_header->info.nr_badpages; i++) {
unsigned int page_nr = swap_header->info.badpages[i]; unsigned int page_nr = swap_header->info.badpages[i];
if (page_nr == 0 || page_nr > swap_header->info.last_page) if (page_nr == 0 || page_nr > swap_header->info.last_page)