On Wed, Apr 25, 2018 at 01:27:07PM +0200, Juan Quintela wrote: > Signed-off-by: Juan Quintela <quint...@redhat.com> > Reviewed-by: Daniel P. Berrangé <berra...@redhat.com> > --- > migration/socket.c | 28 +++++++++++++++++++++++++++- > migration/socket.h | 7 +++++++ > 2 files changed, 34 insertions(+), 1 deletion(-) > > diff --git a/migration/socket.c b/migration/socket.c > index edf33c70cf..893a04f4cc 100644 > --- a/migration/socket.c > +++ b/migration/socket.c > @@ -29,6 +29,28 @@ > #include "trace.h" > > > +struct SocketOutgoingArgs { > + SocketAddress *saddr; > +} outgoing_args;
I am not sure whether I have asked before, but... could we put this into MigrateState*? The thing is that introducing more global variables will make things scattered, and we do stuff to merge them (like the RAMState cleanup work). IMHO it saves time if we can do it from the very beginning. > + > +void socket_send_channel_create(QIOTaskFunc f, void *data) > +{ > + QIOChannelSocket *sioc = qio_channel_socket_new(); > + qio_channel_socket_connect_async(sioc, outgoing_args.saddr, > + f, data, NULL, NULL); > +} > + > +int socket_send_channel_destroy(QIOChannel *send) > +{ > + /* Remove channel */ > + object_unref(OBJECT(send)); > + if (outgoing_args.saddr) { > + qapi_free_SocketAddress(outgoing_args.saddr); > + outgoing_args.saddr = NULL; > + } > + return 0; > +} Here I would possibly avoid bothering introducing the two new APIs since AFAIU they didn't do much things, and both of them are only called once... And IMHO when we call socket_send_channel_create() in multifd_save_setup() we can initialize MultiFDSendParams->c already with the object returned by qio_channel_socket_new() if without the API, instead of waiting until multifd_new_send_channel_async() is called. Thanks, -- Peter Xu