falso
/
qemu-irix
mirror of https://github.com/n64decomp/qemu-irix.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

migration: rename functions to starting migrations 

Apply the following renames for starting incoming migration:

 process_incoming_migration -> migration_fd_process_incoming
 migration_set_incoming_channel -> migration_channel_process_incoming
 migration_tls_set_incoming_channel -> migration_tls_channel_process_incoming

and for starting outgoing migration:

 migration_set_outgoing_channel -> migration_channel_connect
 migration_tls_set_outgoing_channel -> migration_tls_channel_connect

Signed-off-by: Daniel P. Berrange <berrange@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Message-id: 1464776234-9910-3-git-send-email-berrange@redhat.com
Message-Id: <1464776234-9910-3-git-send-email-berrange@redhat.com>
Signed-off-by: Amit Shah <amit.shah@redhat.com>
This commit is contained in:
Daniel P. Berrange 2016-06-01 11:17:14 +01:00 committed by Amit Shah
parent bdbba12b6f
commit 22724f4921
7 changed files with 40 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
include/migration/migration.h
View File

@ -183,25 +183,25 @@ struct MigrationState
void migrate_set_state(int *state, int old_state, int new_state); void migrate_set_state(int *state, int old_state, int new_state);
void process_incoming_migration(QEMUFile *f); void migration_fd_process_incoming(QEMUFile *f);
void qemu_start_incoming_migration(const char *uri, Error **errp); void qemu_start_incoming_migration(const char *uri, Error **errp);
void migration_set_incoming_channel(MigrationState *s, void migration_channel_process_incoming(MigrationState *s,
QIOChannel *ioc); QIOChannel *ioc);
void migration_tls_set_incoming_channel(MigrationState *s, void migration_tls_channel_process_incoming(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
Error **errp); Error **errp);
void migration_set_outgoing_channel(MigrationState *s, void migration_channel_connect(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
const char *hostname); const char *hostname);
void migration_tls_set_outgoing_channel(MigrationState *s, void migration_tls_channel_connect(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
const char *hostname, const char *hostname,
Error **errp); Error **errp);
uint64_t migrate_max_downtime(void); uint64_t migrate_max_downtime(void);

4
migration/exec.c
View File

@ -38,7 +38,7 @@ void exec_start_outgoing_migration(MigrationState *s, const char *command, Error
return; return;
} }
migration_set_outgoing_channel(s, ioc, NULL); migration_channel_connect(s, ioc, NULL);
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
} }
@ -46,7 +46,7 @@ static gboolean exec_accept_incoming_migration(QIOChannel *ioc,
GIOCondition condition, GIOCondition condition,
gpointer opaque) gpointer opaque)
{ {
migration_set_incoming_channel(migrate_get_current(), ioc); migration_channel_process_incoming(migrate_get_current(), ioc);
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
return FALSE; /* unregister */ return FALSE; /* unregister */
} }

4
migration/fd.c
View File

@ -38,7 +38,7 @@ void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **
return; return;
} }
migration_set_outgoing_channel(s, ioc, NULL); migration_channel_connect(s, ioc, NULL);
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
} }
@ -46,7 +46,7 @@ static gboolean fd_accept_incoming_migration(QIOChannel *ioc,
GIOCondition condition, GIOCondition condition,
gpointer opaque) gpointer opaque)
{ {
migration_set_incoming_channel(migrate_get_current(), ioc); migration_channel_process_incoming(migrate_get_current(), ioc);
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
return FALSE; /* unregister */ return FALSE; /* unregister */
} }

18
migration/migration.c
View File

@ -416,7 +416,7 @@ static void process_incoming_migration_co(void *opaque)
qemu_bh_schedule(mis->bh); qemu_bh_schedule(mis->bh);
} }
void process_incoming_migration(QEMUFile *f) void migration_fd_process_incoming(QEMUFile *f)
{ {
Coroutine *co = qemu_coroutine_create(process_incoming_migration_co); Coroutine *co = qemu_coroutine_create(process_incoming_migration_co);
@ -426,8 +426,8 @@ void process_incoming_migration(QEMUFile *f)
} }
void migration_set_incoming_channel(MigrationState *s, void migration_channel_process_incoming(MigrationState *s,
QIOChannel *ioc) QIOChannel *ioc)
{ {
trace_migration_set_incoming_channel( trace_migration_set_incoming_channel(
ioc, object_get_typename(OBJECT(ioc))); ioc, object_get_typename(OBJECT(ioc)));
@ -436,20 +436,20 @@ void migration_set_incoming_channel(MigrationState *s,
!object_dynamic_cast(OBJECT(ioc), !object_dynamic_cast(OBJECT(ioc),
TYPE_QIO_CHANNEL_TLS)) { TYPE_QIO_CHANNEL_TLS)) {
Error *local_err = NULL; Error *local_err = NULL;
migration_tls_set_incoming_channel(s, ioc, &local_err); migration_tls_channel_process_incoming(s, ioc, &local_err);
if (local_err) { if (local_err) {
error_report_err(local_err); error_report_err(local_err);
} }
} else { } else {
QEMUFile *f = qemu_fopen_channel_input(ioc); QEMUFile *f = qemu_fopen_channel_input(ioc);
process_incoming_migration(f); migration_fd_process_incoming(f);
} }
} }
void migration_set_outgoing_channel(MigrationState *s, void migration_channel_connect(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
const char *hostname) const char *hostname)
{ {
trace_migration_set_outgoing_channel( trace_migration_set_outgoing_channel(
ioc, object_get_typename(OBJECT(ioc)), hostname); ioc, object_get_typename(OBJECT(ioc)), hostname);
@ -458,7 +458,7 @@ void migration_set_outgoing_channel(MigrationState *s,
!object_dynamic_cast(OBJECT(ioc), !object_dynamic_cast(OBJECT(ioc),
TYPE_QIO_CHANNEL_TLS)) { TYPE_QIO_CHANNEL_TLS)) {
Error *local_err = NULL; Error *local_err = NULL;
migration_tls_set_outgoing_channel(s, ioc, hostname, &local_err); migration_tls_channel_connect(s, ioc, hostname, &local_err);
if (local_err) { if (local_err) {
migrate_fd_error(s, local_err); migrate_fd_error(s, local_err);
error_free(local_err); error_free(local_err);

4
migration/rdma.c
View File

@ -1511,7 +1511,7 @@ static int qemu_rdma_block_for_wrid(RDMAContext *rdma, int wrid_requested,
while (1) { while (1) {
/* /*
* Coroutine doesn't start until process_incoming_migration() * Coroutine doesn't start until migration_fd_process_incoming()
* so don't yield unless we know we're running inside of a coroutine. * so don't yield unless we know we're running inside of a coroutine.
*/ */
if (rdma->migration_started_on_destination) { if (rdma->migration_started_on_destination) {
@ -3620,7 +3620,7 @@ static void rdma_accept_incoming_migration(void *opaque)
} }
rdma->migration_started_on_destination = 1; rdma->migration_started_on_destination = 1;
process_incoming_migration(f); migration_fd_process_incoming(f);
} }
void rdma_start_incoming_migration(const char *host_port, Error **errp) void rdma_start_incoming_migration(const char *host_port, Error **errp)

6
migration/socket.c
View File

@ -83,7 +83,7 @@ static void socket_outgoing_migration(Object *src,
migrate_fd_error(data->s, err); migrate_fd_error(data->s, err);
} else { } else {
trace_migration_socket_outgoing_connected(data->hostname); trace_migration_socket_outgoing_connected(data->hostname);
migration_set_outgoing_channel(data->s, sioc, data->hostname); migration_channel_connect(data->s, sioc, data->hostname);
} }
object_unref(src); object_unref(src);
} }
@ -140,8 +140,8 @@ static gboolean socket_accept_incoming_migration(QIOChannel *ioc,
trace_migration_socket_incoming_accepted(); trace_migration_socket_incoming_accepted();
migration_set_incoming_channel(migrate_get_current(), migration_channel_process_incoming(migrate_get_current(),
QIO_CHANNEL(sioc)); QIO_CHANNEL(sioc));
object_unref(OBJECT(sioc)); object_unref(OBJECT(sioc));
out: out:

18
migration/tls.c
View File

@ -72,14 +72,14 @@ static void migration_tls_incoming_handshake(Object *src,
error_report("%s", error_get_pretty(err)); error_report("%s", error_get_pretty(err));
} else { } else {
trace_migration_tls_incoming_handshake_complete(); trace_migration_tls_incoming_handshake_complete();
migration_set_incoming_channel(migrate_get_current(), ioc); migration_channel_process_incoming(migrate_get_current(), ioc);
} }
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
} }
void migration_tls_set_incoming_channel(MigrationState *s, void migration_tls_channel_process_incoming(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
Error **errp) Error **errp)
{ {
QCryptoTLSCreds *creds; QCryptoTLSCreds *creds;
QIOChannelTLS *tioc; QIOChannelTLS *tioc;
@ -119,16 +119,16 @@ static void migration_tls_outgoing_handshake(Object *src,
migrate_fd_error(s, err); migrate_fd_error(s, err);
} else { } else {
trace_migration_tls_outgoing_handshake_complete(); trace_migration_tls_outgoing_handshake_complete();
migration_set_outgoing_channel(s, ioc, NULL); migration_channel_connect(s, ioc, NULL);
} }
object_unref(OBJECT(ioc)); object_unref(OBJECT(ioc));
} }
void migration_tls_set_outgoing_channel(MigrationState *s, void migration_tls_channel_connect(MigrationState *s,
QIOChannel *ioc, QIOChannel *ioc,
const char *hostname, const char *hostname,
Error **errp) Error **errp)
{ {
QCryptoTLSCreds *creds; QCryptoTLSCreds *creds;
QIOChannelTLS *tioc; QIOChannelTLS *tioc;