Commit 0d5d286f authored by Mike Rapoport's avatar Mike Rapoport Committed by Andrei Vagin

criu: lazy-pages: add nr (of pages) parameter to handle_regular_pages

travis-ci: success for uffd: A new set of improvements
Signed-off-by: 's avatarMike Rapoport <rppt@linux.vnet.ibm.com>
Signed-off-by: 's avatarPavel Emelyanov <xemul@virtuozzo.com>
parent 2ce10690
...@@ -566,7 +566,7 @@ static int uffd_zero(struct lazy_pages_info *lpi, __u64 address, int nr_pages) ...@@ -566,7 +566,7 @@ static int uffd_zero(struct lazy_pages_info *lpi, __u64 address, int nr_pages)
return len; return len;
} }
static int uffd_handle_page(struct lazy_pages_info *lpi, __u64 address) static int uffd_handle_pages(struct lazy_pages_info *lpi, __u64 address, int nr)
{ {
int ret; int ret;
...@@ -577,19 +577,19 @@ static int uffd_handle_page(struct lazy_pages_info *lpi, __u64 address) ...@@ -577,19 +577,19 @@ static int uffd_handle_page(struct lazy_pages_info *lpi, __u64 address)
return 0; return 0;
if (pagemap_zero(lpi->pr.pe)) if (pagemap_zero(lpi->pr.pe))
return uffd_zero(lpi, address, 1); return uffd_zero(lpi, address, nr);
if (opts.use_page_server) if (opts.use_page_server)
ret = get_remote_pages(lpi->pid, address, 1, lpi->buf); ret = get_remote_pages(lpi->pid, address, nr, lpi->buf);
else else
ret = lpi->pr.read_pages(&lpi->pr, address, 1, lpi->buf, 0); ret = lpi->pr.read_pages(&lpi->pr, address, nr, lpi->buf, 0);
if (ret <= 0) { if (ret <= 0) {
pr_err("%d: failed reading pages at %llx\n", lpi->pid, address); pr_err("%d: failed reading pages at %llx\n", lpi->pid, address);
return ret; return ret;
} }
return uffd_copy(lpi, address, 1); return uffd_copy(lpi, address, nr);
} }
static int handle_remaining_pages(struct lazy_pages_info *lpi) static int handle_remaining_pages(struct lazy_pages_info *lpi)
...@@ -606,7 +606,7 @@ static int handle_remaining_pages(struct lazy_pages_info *lpi) ...@@ -606,7 +606,7 @@ static int handle_remaining_pages(struct lazy_pages_info *lpi)
for (i = 0; i < nr_pages; i++) { for (i = 0; i < nr_pages; i++) {
addr = lazy_iov->base + i * PAGE_SIZE; addr = lazy_iov->base + i * PAGE_SIZE;
err = uffd_handle_page(lpi, addr); err = uffd_handle_pages(lpi, addr, 1);
if (err < 0) { if (err < 0) {
pr_err("Error during UFFD copy\n"); pr_err("Error during UFFD copy\n");
return -1; return -1;
...@@ -617,17 +617,18 @@ static int handle_remaining_pages(struct lazy_pages_info *lpi) ...@@ -617,17 +617,18 @@ static int handle_remaining_pages(struct lazy_pages_info *lpi)
return 0; return 0;
} }
static int handle_regular_pages(struct lazy_pages_info *lpi, __u64 address) static int handle_regular_pages(struct lazy_pages_info *lpi, __u64 address,
int nr)
{ {
int rc; int rc;
rc = uffd_handle_page(lpi, address); rc = uffd_handle_pages(lpi, address, nr);
if (rc < 0) { if (rc < 0) {
pr_err("Error during UFFD copy\n"); pr_err("Error during UFFD copy\n");
return -1; return -1;
} }
rc = update_lazy_iovecs(lpi, address, PAGE_SIZE); rc = update_lazy_iovecs(lpi, address, PAGE_SIZE * nr);
if (rc < 0) if (rc < 0)
return -1; return -1;
...@@ -670,7 +671,7 @@ static int handle_user_fault(struct lazy_pages_fd *lpfd) ...@@ -670,7 +671,7 @@ static int handle_user_fault(struct lazy_pages_fd *lpfd)
flags = msg.arg.pagefault.flags; flags = msg.arg.pagefault.flags;
pr_debug("msg.arg.pagefault.flags 0x%llx\n", flags); pr_debug("msg.arg.pagefault.flags 0x%llx\n", flags);
ret = handle_regular_pages(lpi, address); ret = handle_regular_pages(lpi, address, 1);
if (ret < 0) { if (ret < 0) {
pr_err("Error during regular page copy\n"); pr_err("Error during regular page copy\n");
return -1; return -1;
......
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