Skip to content

Commit

Permalink
migration: pass MigrationIncomingState* into migration check functions
Browse files Browse the repository at this point in the history
That tiny refactoring is necessary to be able to set
UFFD_FEATURE_THREAD_ID while requesting features, and then
to create downtime context in case when kernel supports it.

Signed-off-by: Alexey Perevalov <a.perevalov@samsung.com>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Signed-off-by: Juan Quintela <quintela@redhat.com>
  • Loading branch information
Alexey Perevalov authored and Juan Quintela committed Sep 22, 2017
1 parent 58110f0 commit d7651f1
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 8 deletions.
3 changes: 2 additions & 1 deletion migration/migration.c
Expand Up @@ -659,6 +659,7 @@ static bool migrate_caps_check(bool *cap_list,
{
MigrationCapabilityStatusList *cap;
bool old_postcopy_cap;
MigrationIncomingState *mis = migration_incoming_get_current();

old_postcopy_cap = cap_list[MIGRATION_CAPABILITY_POSTCOPY_RAM];

Expand Down Expand Up @@ -692,7 +693,7 @@ static bool migrate_caps_check(bool *cap_list,
* special support.
*/
if (!old_postcopy_cap && runstate_check(RUN_STATE_INMIGRATE) &&
!postcopy_ram_supported_by_host()) {
!postcopy_ram_supported_by_host(mis)) {
/* postcopy_ram_supported_by_host will have emitted a more
* detailed message
*/
Expand Down
10 changes: 5 additions & 5 deletions migration/postcopy-ram.c
Expand Up @@ -61,7 +61,7 @@ struct PostcopyDiscardState {
#include <sys/eventfd.h>
#include <linux/userfaultfd.h>

static bool ufd_version_check(int ufd)
static bool ufd_version_check(int ufd, MigrationIncomingState *mis)
{
struct uffdio_api api_struct;
uint64_t ioctl_mask;
Expand Down Expand Up @@ -124,7 +124,7 @@ static int test_ramblock_postcopiable(const char *block_name, void *host_addr,
* normally fine since if the postcopy succeeds it gets turned back on at the
* end.
*/
bool postcopy_ram_supported_by_host(void)
bool postcopy_ram_supported_by_host(MigrationIncomingState *mis)
{
long pagesize = getpagesize();
int ufd = -1;
Expand All @@ -147,7 +147,7 @@ bool postcopy_ram_supported_by_host(void)
}

/* Version and features check */
if (!ufd_version_check(ufd)) {
if (!ufd_version_check(ufd, mis)) {
goto out;
}

Expand Down Expand Up @@ -523,7 +523,7 @@ int postcopy_ram_enable_notify(MigrationIncomingState *mis)
* Although the host check already tested the API, we need to
* do the check again as an ABI handshake on the new fd.
*/
if (!ufd_version_check(mis->userfault_fd)) {
if (!ufd_version_check(mis->userfault_fd, mis)) {
return -1;
}

Expand Down Expand Up @@ -661,7 +661,7 @@ void *postcopy_get_tmp_page(MigrationIncomingState *mis)

#else
/* No target OS support, stubs just fail */
bool postcopy_ram_supported_by_host(void)
bool postcopy_ram_supported_by_host(MigrationIncomingState *mis)
{
error_report("%s: No OS support", __func__);
return false;
Expand Down
2 changes: 1 addition & 1 deletion migration/postcopy-ram.h
Expand Up @@ -14,7 +14,7 @@
#define QEMU_POSTCOPY_RAM_H

/* Return true if the host supports everything we need to do postcopy-ram */
bool postcopy_ram_supported_by_host(void);
bool postcopy_ram_supported_by_host(MigrationIncomingState *mis);

/*
* Make all of RAM sensitive to accesses to areas that haven't yet been written
Expand Down
2 changes: 1 addition & 1 deletion migration/savevm.c
Expand Up @@ -1380,7 +1380,7 @@ static int loadvm_postcopy_handle_advise(MigrationIncomingState *mis)
return 0;
}

if (!postcopy_ram_supported_by_host()) {
if (!postcopy_ram_supported_by_host(mis)) {
postcopy_state_set(POSTCOPY_INCOMING_NONE);
return -1;
}
Expand Down

0 comments on commit d7651f1

Please sign in to comment.