From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from eggs.gnu.org ([2001:4830:134:3::10]:34699) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1aZK2g-0008KN-Up for qemu-devel@nongnu.org; Fri, 26 Feb 2016 10:10:58 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1aZK2f-0002kr-Oy for qemu-devel@nongnu.org; Fri, 26 Feb 2016 10:10:54 -0500 Received: from mx1.redhat.com ([209.132.183.28]:35480) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1aZK2f-0002kj-I9 for qemu-devel@nongnu.org; Fri, 26 Feb 2016 10:10:53 -0500 Received: from int-mx11.intmail.prod.int.phx2.redhat.com (int-mx11.intmail.prod.int.phx2.redhat.com [10.5.11.24]) by mx1.redhat.com (Postfix) with ESMTPS id 4E70090E7A for ; Fri, 26 Feb 2016 15:10:53 +0000 (UTC) From: "Daniel P. Berrange" Date: Fri, 26 Feb 2016 15:10:15 +0000 Message-Id: <1456499430-8558-13-git-send-email-berrange@redhat.com> In-Reply-To: <1456499430-8558-1-git-send-email-berrange@redhat.com> References: <1456499430-8558-1-git-send-email-berrange@redhat.com> Subject: [Qemu-devel] [PATCH v3 12/27] migration: rename unix.c to socket.c List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-devel@nongnu.org Cc: Amit Shah , "Dr. David Alan Gilbert" , Juan Quintela The unix.c file will be nearly the same as the tcp.c file, only differing in the initial SocketAddress creation code. Rename unix.c to socket.c and refactor it a little to prepare for merging the TCP code. Signed-off-by: Daniel P. Berrange --- migration/Makefile.objs | 2 +- migration/{unix.c => socket.c} | 53 +++++++++++++++++++++++++----------------- trace-events | 8 +++---- 3 files changed, 37 insertions(+), 26 deletions(-) rename migration/{unix.c => socket.c} (65%) diff --git a/migration/Makefile.objs b/migration/Makefile.objs index a5f8a03..9d83997 100644 --- a/migration/Makefile.objs +++ b/migration/Makefile.objs @@ -1,4 +1,4 @@ -common-obj-y += migration.o tcp.o unix.o +common-obj-y += migration.o tcp.o socket.o common-obj-y += vmstate.o common-obj-y += qemu-file.o qemu-file-buf.o qemu-file-unix.o qemu-file-stdio.o common-obj-y += qemu-file-channel.o diff --git a/migration/unix.c b/migration/socket.c similarity index 65% rename from migration/unix.c rename to migration/socket.c index f24a058..ef0a673 100644 --- a/migration/unix.c +++ b/migration/socket.c @@ -37,42 +37,49 @@ static SocketAddress *unix_build_address(const char *path) } -static void unix_outgoing_migration(Object *src, - Error *err, - gpointer opaque) +static void socket_outgoing_migration(Object *src, + Error *err, + gpointer opaque) { MigrationState *s = opaque; QIOChannel *sioc = QIO_CHANNEL(src); if (err) { - trace_migration_unix_outgoing_error(error_get_pretty(err)); + trace_migration_socket_outgoing_error(error_get_pretty(err)); s->to_dst_file = NULL; migrate_fd_error(s, err); } else { - trace_migration_unix_outgoing_connected(); + trace_migration_socket_outgoing_connected(); migration_set_outgoing_channel(s, sioc); } object_unref(src); } - -void unix_start_outgoing_migration(MigrationState *s, const char *path, Error **errp) +static void socket_start_outgoing_migration(MigrationState *s, + SocketAddress *saddr, + Error **errp) { - SocketAddress *saddr = unix_build_address(path); - QIOChannelSocket *sioc; - sioc = qio_channel_socket_new(); + QIOChannelSocket *sioc = qio_channel_socket_new(); qio_channel_socket_connect_async(sioc, saddr, - unix_outgoing_migration, + socket_outgoing_migration, s, NULL); qapi_free_SocketAddress(saddr); } +void unix_start_outgoing_migration(MigrationState *s, + const char *path, + Error **errp) +{ + SocketAddress *saddr = unix_build_address(path); + socket_start_outgoing_migration(s, saddr, errp); +} + -static gboolean unix_accept_incoming_migration(QIOChannel *ioc, - GIOCondition condition, - gpointer opaque) +static gboolean socket_accept_incoming_migration(QIOChannel *ioc, + GIOCondition condition, + gpointer opaque) { QIOChannelSocket *sioc; Error *err = NULL; @@ -85,7 +92,7 @@ static gboolean unix_accept_incoming_migration(QIOChannel *ioc, goto out; } - trace_migration_unix_incoming_accepted(); + trace_migration_socket_incoming_accepted(); migration_set_incoming_channel(migrate_get_current(), QIO_CHANNEL(sioc)); @@ -98,12 +105,11 @@ out: } -void unix_start_incoming_migration(const char *path, Error **errp) +static void socket_start_incoming_migration(SocketAddress *saddr, + Error **errp) { - SocketAddress *saddr = unix_build_address(path); - QIOChannelSocket *listen_ioc; + QIOChannelSocket *listen_ioc = qio_channel_socket_new(); - listen_ioc = qio_channel_socket_new(); if (qio_channel_socket_listen_sync(listen_ioc, saddr, errp) < 0) { object_unref(OBJECT(listen_ioc)); qapi_free_SocketAddress(saddr); @@ -112,9 +118,14 @@ void unix_start_incoming_migration(const char *path, Error **errp) qio_channel_add_watch(QIO_CHANNEL(listen_ioc), G_IO_IN, - unix_accept_incoming_migration, + socket_accept_incoming_migration, listen_ioc, (GDestroyNotify)object_unref); - qapi_free_SocketAddress(saddr); } + +void unix_start_incoming_migration(const char *path, Error **errp) +{ + SocketAddress *saddr = unix_build_address(path); + socket_start_incoming_migration(saddr, errp); +} diff --git a/trace-events b/trace-events index bf36ae8..6608cf0 100644 --- a/trace-events +++ b/trace-events @@ -1600,10 +1600,10 @@ postcopy_ram_incoming_cleanup_entry(void) "" postcopy_ram_incoming_cleanup_exit(void) "" postcopy_ram_incoming_cleanup_join(void) "" -# migration/unix.c -migration_unix_incoming_accepted(void) "" -migration_unix_outgoing_connected(void) "" -migration_unix_outgoing_error(const char *err) "error=%s" +# migration/socket.c +migration_socket_incoming_accepted(void) "" +migration_socket_outgoing_connected(void) "" +migration_socket_outgoing_error(const char *err) "error=%s" # kvm-all.c kvm_ioctl(int type, void *arg) "type 0x%x, arg %p" -- 2.5.0