migration/channel: Rename migration_channel_connect

Rename migration_channel_connect to indicate this is the source
side. Future patches will do similar changes to the incoming side and
this will avoid inconsistencies in naming.

Reviewed-by: Peter Xu <peterx@redhat.com>
Reviewed-by: Prasad Pandit <pjp@fedoraproject.org>
Link: https://lore.kernel.org/qemu-devel/20260123141656.6765-17-farosas@suse.de
Signed-off-by: Fabiano Rosas <farosas@suse.de>
This commit is contained in:
Fabiano Rosas
2026-01-23 11:16:46 -03:00
parent 9834b6de61
commit 9fdca27637
7 changed files with 7 additions and 14 deletions

View File

@@ -61,14 +61,7 @@ out:
}
}
/**
* @migration_channel_connect - Create new outgoing migration channel
*
* @s: Current migration state
* @ioc: Channel to which we are connecting
*/
void migration_channel_connect(MigrationState *s, QIOChannel *ioc)
void migration_channel_connect_outgoing(MigrationState *s, QIOChannel *ioc)
{
trace_migration_set_outgoing_channel(ioc, object_get_typename(OBJECT(ioc)));

View File

@@ -28,7 +28,7 @@ typedef enum {
void migration_channel_process_incoming(QIOChannel *ioc);
void migration_channel_connect(MigrationState *s, QIOChannel *ioc);
void migration_channel_connect_outgoing(MigrationState *s, QIOChannel *ioc);
int migration_channel_read_peek(QIOChannel *ioc,
const char *buf,

View File

@@ -55,7 +55,7 @@ void exec_start_outgoing_migration(MigrationState *s, strList *command,
}
qio_channel_set_name(ioc, "migration-exec-outgoing");
migration_channel_connect(s, ioc);
migration_channel_connect_outgoing(s, ioc);
object_unref(OBJECT(ioc));
}

View File

@@ -72,7 +72,7 @@ void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **
}
qio_channel_set_name(ioc, "migration-fd-outgoing");
migration_channel_connect(s, ioc);
migration_channel_connect_outgoing(s, ioc);
object_unref(OBJECT(ioc));
}

View File

@@ -122,7 +122,7 @@ void file_start_outgoing_migration(MigrationState *s,
return;
}
qio_channel_set_name(ioc, "migration-file-outgoing");
migration_channel_connect(s, ioc);
migration_channel_connect_outgoing(s, ioc);
}
static gboolean file_accept_incoming_migration(QIOChannel *ioc,

View File

@@ -73,7 +73,7 @@ static void socket_outgoing_migration(QIOTask *task,
}
trace_migration_socket_outgoing_connected();
migration_channel_connect(data->s, sioc);
migration_channel_connect_outgoing(data->s, sioc);
return;
fail:
trace_migration_socket_outgoing_error(error_get_pretty(err));

View File

@@ -114,7 +114,7 @@ static void migration_tls_outgoing_handshake(QIOTask *task,
}
trace_migration_tls_outgoing_handshake_complete();
migration_channel_connect(s, ioc);
migration_channel_connect_outgoing(s, ioc);
}
QIOChannelTLS *migration_tls_client_create(QIOChannel *ioc,