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
);
53 if (ret
>= 0 && !(WIFEXITED(ret
) && WEXITSTATUS(ret
) == 0)) {
54 /* close succeeded, but non-zero exit code: */
55 ret
= -EIO
; /* fake errno value */
60 void exec_start_outgoing_migration(MigrationState
*s
, const char *command
, Error
**errp
)
64 f
= popen(command
, "w");
66 error_setg_errno(errp
, errno
, "failed to popen the migration target");
73 s
->opaque
= qemu_popen(f
, "w");
75 s
->close
= exec_close
;
76 s
->get_error
= file_errno
;
77 s
->write
= file_write
;
79 migrate_fd_connect(s
);
82 static void exec_accept_incoming_migration(void *opaque
)
86 qemu_set_fd_handler2(qemu_get_fd(f
), NULL
, NULL
, NULL
, NULL
);
87 process_incoming_migration(f
);
90 void exec_start_incoming_migration(const char *command
, Error
**errp
)
94 DPRINTF("Attempting to start an incoming migration\n");
95 f
= qemu_popen_cmd(command
, "r");
97 error_setg_errno(errp
, errno
, "failed to popen the migration source");
101 qemu_set_fd_handler2(qemu_get_fd(f
), NULL
,
102 exec_accept_incoming_migration
, NULL
, f
);