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>

diff --git a/migration/channel.c b/migration/channel.c
index b8d757c17b09ff4bb6e55dcedfc3c32606b70000..f41333adcca73b1e468cb826584094b675f638e2 100644 (file)
--- a/migration/channel.c
+++ b/migration/channel.c
@@ -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)));
 

diff --git a/migration/channel.h b/migration/channel.h
index b361e1c83817ea354cebd2528149cf48836ef382..574bfec65c17abdc380a3da19dad1bc7c82480df 100644 (file)
--- a/migration/channel.h
+++ b/migration/channel.h
@@ -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,

diff --git a/migration/exec.c b/migration/exec.c
index d83a07435a67dbe74b1c429fff7006519b91b840..d1629944dc9c08342ac7d9b8b69de2dac20ea290 100644 (file)
--- a/migration/exec.c
+++ b/migration/exec.c
@@ -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));
 }
 

diff --git a/migration/fd.c b/migration/fd.c
index f5cf58e6ee6ddcda005b63196bdaf553350bd577..20166fef46cda3ee4dca4510e261b41d371da8da 100644 (file)
--- a/migration/fd.c
+++ b/migration/fd.c
@@ -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));
 }
 

diff --git a/migration/file.c b/migration/file.c
index 7bb9c1c79fa9a3174635febf70596e6e46647306..935402f36b2e1d1d90c14e1f588295acc34d59f9 100644 (file)
--- a/migration/file.c
+++ b/migration/file.c
@@ -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,

diff --git a/migration/socket.c b/migration/socket.c
index 676fe267121fc5785be221579ee3fca1b4e5e8dd..f94959828f8814cf3def5367fa0b0eb56286e67a 100644 (file)
--- a/migration/socket.c
+++ b/migration/socket.c
@@ -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));

diff --git a/migration/tls.c b/migration/tls.c
index 837b08294f0a1190c4c467eedadbcd28263ae48f..89ba52de02ae71dcb99dcc8fd7f9acfd40d23bc2 100644 (file)
--- a/migration/tls.c
+++ b/migration/tls.c
@@ -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,