Commit 8b079cd0 authored by Nadav Amit's avatar Nadav Amit Committed by Greg Kroah-Hartman

vmw_balloon: refactor change size from vmballoon_work

The required change in the balloon size is currently computed in
vmballoon_work(), vmballoon_inflate() and vmballoon_deflate(). Refactor
it to simplify the next patches.
Reviewed-by: default avatarXavier Deguillard <xdeguillard@vmware.com>
Signed-off-by: default avatarNadav Amit <namit@vmware.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 25acbdd7
...@@ -633,6 +633,37 @@ static void vmballoon_add_page(struct vmballoon *b, int idx, struct page *p) ...@@ -633,6 +633,37 @@ static void vmballoon_add_page(struct vmballoon *b, int idx, struct page *p)
b->page = p; b->page = p;
} }
/**
* vmballoon_change - retrieve the required balloon change
*
* @b: pointer for the balloon.
*
* Return: the required change for the balloon size. A positive number
* indicates inflation, a negative number indicates a deflation.
*/
static int64_t vmballoon_change(struct vmballoon *b)
{
int64_t size, target;
size = b->size;
target = b->target;
/*
* We must cast first because of int sizes
* Otherwise we might get huge positives instead of negatives
*/
if (b->reset_required)
return 0;
/* consider a 2MB slack on deflate, unless the balloon is emptied */
if (target < size && size - target < vmballoon_page_size(true) &&
target != 0)
return 0;
return target - size;
}
/* /*
* Inflate the balloon towards its target size. Note that we try to limit * Inflate the balloon towards its target size. Note that we try to limit
* the rate of allocation to make sure we are not choking the rest of the * the rate of allocation to make sure we are not choking the rest of the
...@@ -644,8 +675,6 @@ static void vmballoon_inflate(struct vmballoon *b) ...@@ -644,8 +675,6 @@ static void vmballoon_inflate(struct vmballoon *b)
int error = 0; int error = 0;
bool is_2m_pages; bool is_2m_pages;
pr_debug("%s - size: %d, target %d\n", __func__, b->size, b->target);
/* /*
* First try NOSLEEP page allocations to inflate balloon. * First try NOSLEEP page allocations to inflate balloon.
* *
...@@ -667,11 +696,8 @@ static void vmballoon_inflate(struct vmballoon *b) ...@@ -667,11 +696,8 @@ static void vmballoon_inflate(struct vmballoon *b)
*/ */
is_2m_pages = b->supported_page_sizes == VMW_BALLOON_NUM_PAGE_SIZES; is_2m_pages = b->supported_page_sizes == VMW_BALLOON_NUM_PAGE_SIZES;
pr_debug("%s - goal: %d", __func__, b->target - b->size); while ((int64_t)(num_pages * vmballoon_page_size(is_2m_pages)) <
vmballoon_change(b)) {
while (!b->reset_required &&
b->size + num_pages * vmballoon_page_size(is_2m_pages)
< b->target) {
struct page *page; struct page *page;
STATS_INC(b->stats.alloc[is_2m_pages]); STATS_INC(b->stats.alloc[is_2m_pages]);
...@@ -742,8 +768,6 @@ static void vmballoon_deflate(struct vmballoon *b) ...@@ -742,8 +768,6 @@ static void vmballoon_deflate(struct vmballoon *b)
{ {
unsigned is_2m_pages; unsigned is_2m_pages;
pr_debug("%s - size: %d, target %d\n", __func__, b->size, b->target);
/* free pages to reach target */ /* free pages to reach target */
for (is_2m_pages = 0; is_2m_pages < b->supported_page_sizes; for (is_2m_pages = 0; is_2m_pages < b->supported_page_sizes;
is_2m_pages++) { is_2m_pages++) {
...@@ -753,11 +777,9 @@ static void vmballoon_deflate(struct vmballoon *b) ...@@ -753,11 +777,9 @@ static void vmballoon_deflate(struct vmballoon *b)
&b->page_sizes[is_2m_pages]; &b->page_sizes[is_2m_pages];
list_for_each_entry_safe(page, next, &page_size->pages, lru) { list_for_each_entry_safe(page, next, &page_size->pages, lru) {
if (b->reset_required || if ((int64_t)(num_pages *
(b->target > 0 && vmballoon_page_size(is_2m_pages)) >=
b->size - num_pages -vmballoon_change(b))
* vmballoon_page_size(is_2m_pages)
< b->target + vmballoon_page_size(true)))
break; break;
list_del(&page->lru); list_del(&page->lru);
...@@ -921,28 +943,35 @@ static void vmballoon_reset(struct vmballoon *b) ...@@ -921,28 +943,35 @@ static void vmballoon_reset(struct vmballoon *b)
pr_err("failed to send guest ID to the host\n"); pr_err("failed to send guest ID to the host\n");
} }
/* /**
* Balloon work function: reset protocol, if needed, get the new size and * vmballoon_work - periodic balloon worker for reset, inflation and deflation.
* adjust balloon as needed. Repeat in 1 sec. *
* @work: pointer to the &work_struct which is provided by the workqueue.
*
* Resets the protocol if needed, gets the new size and adjusts balloon as
* needed. Repeat in 1 sec.
*/ */
static void vmballoon_work(struct work_struct *work) static void vmballoon_work(struct work_struct *work)
{ {
struct delayed_work *dwork = to_delayed_work(work); struct delayed_work *dwork = to_delayed_work(work);
struct vmballoon *b = container_of(dwork, struct vmballoon, dwork); struct vmballoon *b = container_of(dwork, struct vmballoon, dwork);
int64_t change = 0;
STATS_INC(b->stats.timer); STATS_INC(b->stats.timer);
if (b->reset_required) if (b->reset_required)
vmballoon_reset(b); vmballoon_reset(b);
if (!b->reset_required && vmballoon_send_get_target(b)) { if (vmballoon_send_get_target(b))
unsigned long target = b->target; change = vmballoon_change(b);
if (change != 0) {
pr_debug("%s - size: %u, target %u", __func__,
b->size, b->target);
/* update target, adjust size */ if (change > 0)
if (b->size < target)
vmballoon_inflate(b); vmballoon_inflate(b);
else if (target == 0 || else /* (change < 0) */
b->size > target + vmballoon_page_size(true))
vmballoon_deflate(b); vmballoon_deflate(b);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment