]>
Commit | Line | Data |
---|---|---|
065e2813 AL |
1 | /* |
2 | * QEMU live migration | |
3 | * | |
4 | * Copyright IBM, Corp. 2008 | |
5 | * Copyright Dell MessageOne 2008 | |
527792fa | 6 | * Copyright Red Hat, Inc. 2015-2016 |
065e2813 AL |
7 | * |
8 | * Authors: | |
9 | * Anthony Liguori <aliguori@us.ibm.com> | |
10 | * Charles Duffy <charles_duffy@messageone.com> | |
527792fa | 11 | * Daniel P. Berrange <berrange@redhat.com> |
065e2813 AL |
12 | * |
13 | * This work is licensed under the terms of the GNU GPL, version 2. See | |
14 | * the COPYING file in the top-level directory. | |
15 | * | |
6b620ca3 PB |
16 | * Contributions after 2012-01-13 are licensed under the terms of the |
17 | * GNU GPL, version 2 or (at your option) any later version. | |
065e2813 AL |
18 | */ |
19 | ||
1393a485 | 20 | #include "qemu/osdep.h" |
da34e65c | 21 | #include "qapi/error.h" |
065e2813 | 22 | #include "qemu-common.h" |
caf71f86 | 23 | #include "migration/migration.h" |
527792fa DB |
24 | #include "io/channel-command.h" |
25 | #include "trace.h" | |
065e2813 | 26 | |
065e2813 | 27 | |
f37afb5a | 28 | void exec_start_outgoing_migration(MigrationState *s, const char *command, Error **errp) |
065e2813 | 29 | { |
527792fa DB |
30 | QIOChannel *ioc; |
31 | const char *argv[] = { "/bin/sh", "-c", command, NULL }; | |
32 | ||
33 | trace_migration_exec_outgoing(command); | |
34 | ioc = QIO_CHANNEL(qio_channel_command_new_spawn(argv, | |
35 | O_WRONLY, | |
36 | errp)); | |
37 | if (!ioc) { | |
f37afb5a | 38 | return; |
065e2813 AL |
39 | } |
40 | ||
22724f49 | 41 | migration_channel_connect(s, ioc, NULL); |
527792fa | 42 | object_unref(OBJECT(ioc)); |
065e2813 AL |
43 | } |
44 | ||
527792fa DB |
45 | static gboolean exec_accept_incoming_migration(QIOChannel *ioc, |
46 | GIOCondition condition, | |
47 | gpointer opaque) | |
065e2813 | 48 | { |
22724f49 | 49 | migration_channel_process_incoming(migrate_get_current(), ioc); |
527792fa DB |
50 | object_unref(OBJECT(ioc)); |
51 | return FALSE; /* unregister */ | |
8a43b1ea CL |
52 | } |
53 | ||
43eaae28 | 54 | void exec_start_incoming_migration(const char *command, Error **errp) |
8a43b1ea | 55 | { |
527792fa DB |
56 | QIOChannel *ioc; |
57 | const char *argv[] = { "/bin/sh", "-c", command, NULL }; | |
8a43b1ea | 58 | |
527792fa DB |
59 | trace_migration_exec_incoming(command); |
60 | ioc = QIO_CHANNEL(qio_channel_command_new_spawn(argv, | |
61 | O_RDONLY, | |
62 | errp)); | |
63 | if (!ioc) { | |
43eaae28 | 64 | return; |
8a43b1ea CL |
65 | } |
66 | ||
527792fa DB |
67 | qio_channel_add_watch(ioc, |
68 | G_IO_IN, | |
69 | exec_accept_incoming_migration, | |
70 | NULL, | |
71 | NULL); | |
065e2813 | 72 | } |