4 * Copyright IBM, Corp. 2008
5 * Copyright Dell MessageOne 2008
8 * Anthony Liguori <aliguori@us.ibm.com>
9 * Charles Duffy <charles_duffy@messageone.com>
11 * This work is licensed under the terms of the GNU GPL, version 2. See
12 * the COPYING file in the top-level directory.
14 * Contributions after 2012-01-13 are licensed under the terms of the
15 * GNU GPL, version 2 or (at your option) any later version.
18 #include "qemu-common.h"
19 #include "qemu/sockets.h"
20 #include "migration/migration.h"
21 #include "migration/qemu-file.h"
22 #include "block/block.h"
23 #include <sys/types.h>
26 //#define DEBUG_MIGRATION_EXEC
28 #ifdef DEBUG_MIGRATION_EXEC
29 #define DPRINTF(fmt, ...) \
30 do { printf("migration-exec: " fmt, ## __VA_ARGS__); } while (0)
32 #define DPRINTF(fmt, ...) \
36 static int file_errno(MigrationState
*s
)
41 static int file_write(MigrationState
*s
, const void * buf
, size_t size
)
43 return write(s
->fd
, buf
, size
);
46 static int exec_close(MigrationState
*s
)
49 DPRINTF("exec_close\n");
50 ret
= qemu_fclose(s
->opaque
);
56 void exec_start_outgoing_migration(MigrationState
*s
, const char *command
, Error
**errp
)
59 f
= qemu_popen_cmd(command
, "w");
61 error_setg_errno(errp
, errno
, "failed to popen the migration target");
66 s
->fd
= qemu_get_fd(f
);
69 s
->close
= exec_close
;
70 s
->get_error
= file_errno
;
71 s
->write
= file_write
;
73 migrate_fd_connect(s
);
76 static void exec_accept_incoming_migration(void *opaque
)
80 qemu_set_fd_handler2(qemu_get_fd(f
), NULL
, NULL
, NULL
, NULL
);
81 process_incoming_migration(f
);
84 void exec_start_incoming_migration(const char *command
, Error
**errp
)
88 DPRINTF("Attempting to start an incoming migration\n");
89 f
= qemu_popen_cmd(command
, "r");
91 error_setg_errno(errp
, errno
, "failed to popen the migration source");
95 qemu_set_fd_handler2(qemu_get_fd(f
), NULL
,
96 exec_accept_incoming_migration
, NULL
, f
);