1 /* 2 * QEMU live migration via generic fd 3 * 4 * Copyright Red Hat, Inc. 2009 5 * 6 * Authors: 7 * Chris Lalancette <clalance@redhat.com> 8 * 9 * This work is licensed under the terms of the GNU GPL, version 2. See 10 * the COPYING file in the top-level directory. 11 * 12 * Contributions after 2012-01-13 are licensed under the terms of the 13 * GNU GPL, version 2 or (at your option) any later version. 14 */ 15 16 #include "qemu-common.h" 17 #include "qemu/main-loop.h" 18 #include "qemu/sockets.h" 19 #include "migration/migration.h" 20 #include "monitor/monitor.h" 21 #include "migration/qemu-file.h" 22 #include "block/block.h" 23 24 //#define DEBUG_MIGRATION_FD 25 26 #ifdef DEBUG_MIGRATION_FD 27 #define DPRINTF(fmt, ...) \ 28 do { printf("migration-fd: " fmt, ## __VA_ARGS__); } while (0) 29 #else 30 #define DPRINTF(fmt, ...) \ 31 do { } while (0) 32 #endif 33 34 void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) 35 { 36 int fd = monitor_get_fd(cur_mon, fdname, errp); 37 if (fd == -1) { 38 return; 39 } 40 s->file = qemu_fdopen(fd, "wb"); 41 42 migrate_fd_connect(s); 43 } 44 45 static void fd_accept_incoming_migration(void *opaque) 46 { 47 QEMUFile *f = opaque; 48 49 qemu_set_fd_handler2(qemu_get_fd(f), NULL, NULL, NULL, NULL); 50 process_incoming_migration(f); 51 } 52 53 void fd_start_incoming_migration(const char *infd, Error **errp) 54 { 55 int fd; 56 QEMUFile *f; 57 58 DPRINTF("Attempting to start an incoming migration via fd\n"); 59 60 fd = strtol(infd, NULL, 0); 61 f = qemu_fdopen(fd, "rb"); 62 if(f == NULL) { 63 error_setg_errno(errp, errno, "failed to open the source descriptor"); 64 return; 65 } 66 67 qemu_set_fd_handler2(fd, NULL, fd_accept_incoming_migration, NULL, f); 68 } 69