]>
Commit | Line | Data |
---|---|---|
1 | /* | |
2 | * QEMU live migration | |
3 | * | |
4 | * Copyright IBM, Corp. 2008 | |
5 | * Copyright Dell MessageOne 2008 | |
6 | * Copyright Red Hat, Inc. 2015-2016 | |
7 | * | |
8 | * Authors: | |
9 | * Anthony Liguori <aliguori@us.ibm.com> | |
10 | * Charles Duffy <charles_duffy@messageone.com> | |
11 | * Daniel P. Berrange <berrange@redhat.com> | |
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 | * | |
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. | |
18 | */ | |
19 | ||
20 | #include "qemu/osdep.h" | |
21 | #include "qapi/error.h" | |
22 | #include "qemu-common.h" | |
23 | #include "migration/migration.h" | |
24 | #include "io/channel-command.h" | |
25 | #include "trace.h" | |
26 | ||
27 | ||
28 | void exec_start_outgoing_migration(MigrationState *s, const char *command, Error **errp) | |
29 | { | |
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) { | |
38 | return; | |
39 | } | |
40 | ||
41 | qio_channel_set_name(ioc, "migration-exec-outgoing"); | |
42 | migration_channel_connect(s, ioc, NULL); | |
43 | object_unref(OBJECT(ioc)); | |
44 | } | |
45 | ||
46 | static gboolean exec_accept_incoming_migration(QIOChannel *ioc, | |
47 | GIOCondition condition, | |
48 | gpointer opaque) | |
49 | { | |
50 | migration_channel_process_incoming(migrate_get_current(), ioc); | |
51 | object_unref(OBJECT(ioc)); | |
52 | return FALSE; /* unregister */ | |
53 | } | |
54 | ||
55 | void exec_start_incoming_migration(const char *command, Error **errp) | |
56 | { | |
57 | QIOChannel *ioc; | |
58 | const char *argv[] = { "/bin/sh", "-c", command, NULL }; | |
59 | ||
60 | trace_migration_exec_incoming(command); | |
61 | ioc = QIO_CHANNEL(qio_channel_command_new_spawn(argv, | |
62 | O_RDONLY, | |
63 | errp)); | |
64 | if (!ioc) { | |
65 | return; | |
66 | } | |
67 | ||
68 | qio_channel_set_name(ioc, "migration-exec-incoming"); | |
69 | qio_channel_add_watch(ioc, | |
70 | G_IO_IN, | |
71 | exec_accept_incoming_migration, | |
72 | NULL, | |
73 | NULL); | |
74 | } |