]> git.proxmox.com Git - mirror_qemu.git/blame - migration/exec.c
qcow2: Inform block layer about discard boundaries
[mirror_qemu.git] / migration / exec.c
CommitLineData
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 28void 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
45static 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 54void 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}