1 /* 2 * migration yank functions 3 * 4 * Copyright (c) Lukas Straub <lukasstraub2@web.de> 5 * 6 * This work is licensed under the terms of the GNU GPL, version 2 or later. 7 * See the COPYING file in the top-level directory. 8 */ 9 10 #include "qemu/osdep.h" 11 #include "qapi/error.h" 12 #include "io/channel.h" 13 #include "yank_functions.h" 14 #include "qemu/yank.h" 15 #include "io/channel-socket.h" 16 #include "io/channel-tls.h" 17 #include "qemu-file.h" 18 19 void migration_yank_iochannel(void *opaque) 20 { 21 QIOChannel *ioc = QIO_CHANNEL(opaque); 22 23 qio_channel_shutdown(ioc, QIO_CHANNEL_SHUTDOWN_BOTH, NULL); 24 } 25 26 /* Return whether yank is supported on this ioc */ 27 static bool migration_ioc_yank_supported(QIOChannel *ioc) 28 { 29 return object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_SOCKET) || 30 object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_TLS); 31 } 32 33 void migration_ioc_register_yank(QIOChannel *ioc) 34 { 35 if (migration_ioc_yank_supported(ioc)) { 36 yank_register_function(MIGRATION_YANK_INSTANCE, 37 migration_yank_iochannel, 38 QIO_CHANNEL(ioc)); 39 } 40 } 41 42 void migration_ioc_unregister_yank(QIOChannel *ioc) 43 { 44 if (migration_ioc_yank_supported(ioc)) { 45 yank_unregister_function(MIGRATION_YANK_INSTANCE, 46 migration_yank_iochannel, 47 QIO_CHANNEL(ioc)); 48 } 49 } 50 51 void migration_ioc_unregister_yank_from_file(QEMUFile *file) 52 { 53 QIOChannel *ioc = qemu_file_get_ioc(file); 54 55 if (ioc) { 56 /* 57 * For migration qemufiles, we'll always reach here. Though we'll skip 58 * calls from e.g. savevm/loadvm as they don't use yank. 59 */ 60 migration_ioc_unregister_yank(ioc); 61 } 62 } 63