yank_functions.c (1728B)
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 19void 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 */ 27static 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 33void 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 42void 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 51void 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}