OpenE2K/qemu-e2k
13
4
Fork 0
Code Issues 4 Pull Requests Projects 2 Releases Activity

migration: Introduce multifd_recv_new_channel()

Browse Source 
Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
This commit is contained in:
Juan Quintela 2018-02-19 19:01:03 +01:00
parent 7a169d745c
commit 71bb07dbfc
3 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
migration/migration.c
View File

@ -449,8 +449,9 @@ void migration_ioc_process_incoming(QIOChannel *ioc)
if (!mis->from_src_file) { if (!mis->from_src_file) {
QEMUFile *f = qemu_fopen_channel_input(ioc); QEMUFile *f = qemu_fopen_channel_input(ioc);
migration_fd_process_incoming(f); migration_fd_process_incoming(f);
return;
} }
/* We still only have a single channel. Nothing to do here yet */ multifd_recv_new_channel(ioc);
} }
/** /**

6
migration/ram.c
View File

@ -36,6 +36,7 @@
#include "xbzrle.h" #include "xbzrle.h"
#include "ram.h" #include "ram.h"
#include "migration.h" #include "migration.h"
#include "socket.h"
#include "migration/register.h" #include "migration/register.h"
#include "migration/misc.h" #include "migration/misc.h"
#include "qemu-file.h" #include "qemu-file.h"
@ -654,6 +655,11 @@ int multifd_load_setup(void)
return 0; return 0;
} }
void multifd_recv_new_channel(QIOChannel *ioc)
{
/* nothing to do yet */
}
/** /**
* save_page_header: write page header to wire * save_page_header: write page header to wire
* *

2
migration/ram.h
View File

@ -32,6 +32,7 @@
#include "qemu-common.h" #include "qemu-common.h"
#include "qapi/qapi-types-migration.h" #include "qapi/qapi-types-migration.h"
#include "exec/cpu-common.h" #include "exec/cpu-common.h"
#include "io/channel.h"
extern MigrationStats ram_counters; extern MigrationStats ram_counters;
extern XBZRLECacheStats xbzrle_counters; extern XBZRLECacheStats xbzrle_counters;
@ -44,6 +45,7 @@ int multifd_save_setup(void);
int multifd_save_cleanup(Error **errp); int multifd_save_cleanup(Error **errp);
int multifd_load_setup(void); int multifd_load_setup(void);
int multifd_load_cleanup(Error **errp); int multifd_load_cleanup(Error **errp);
void multifd_recv_new_channel(QIOChannel *ioc);
uint64_t ram_pagesize_summary(void); uint64_t ram_pagesize_summary(void);
int ram_save_queue_pages(const char *rbname, ram_addr_t start, ram_addr_t len); int ram_save_queue_pages(const char *rbname, ram_addr_t start, ram_addr_t len);