qemu

FORK: QEMU emulator
git clone https://git.neptards.moe/neptards/qemu.git
Log | Files | Refs | Submodules | LICENSE

exec.c (2270B)

      1 /*
      2  * QEMU live migration
      3  *
      4  * Copyright IBM, Corp. 2008
      5  * Copyright Dell MessageOne 2008
      6  * Copyright Red Hat, Inc. 2015-2016
      7  *
      8  * Authors:
      9  *  Anthony Liguori   <aliguori@us.ibm.com>
     10  *  Charles Duffy     <charles_duffy@messageone.com>
     11  *  Daniel P. Berrange <berrange@redhat.com>
     12  *
     13  * This work is licensed under the terms of the GNU GPL, version 2.  See
     14  * the COPYING file in the top-level directory.
     15  *
     16  * Contributions after 2012-01-13 are licensed under the terms of the
     17  * GNU GPL, version 2 or (at your option) any later version.
     18  */
     19 
     20 #include "qemu/osdep.h"
     21 #include "channel.h"
     22 #include "exec.h"
     23 #include "migration.h"
     24 #include "io/channel-command.h"
     25 #include "trace.h"
     26 
     27 
     28 void exec_start_outgoing_migration(MigrationState *s, const char *command, Error **errp)
     29 {
     30     QIOChannel *ioc;
     31     const char *argv[] = { "/bin/sh", "-c", command, NULL };
     32 
     33     trace_migration_exec_outgoing(command);
     34     ioc = QIO_CHANNEL(qio_channel_command_new_spawn(argv,
     35                                                     O_RDWR,
     36                                                     errp));
     37     if (!ioc) {
     38         return;
     39     }
     40 
     41     qio_channel_set_name(ioc, "migration-exec-outgoing");
     42     migration_channel_connect(s, ioc, NULL, NULL);
     43     object_unref(OBJECT(ioc));
     44 }
     45 
     46 static gboolean exec_accept_incoming_migration(QIOChannel *ioc,
     47                                                GIOCondition condition,
     48                                                gpointer opaque)
     49 {
     50     migration_channel_process_incoming(ioc);
     51     object_unref(OBJECT(ioc));
     52     return G_SOURCE_REMOVE;
     53 }
     54 
     55 void exec_start_incoming_migration(const char *command, Error **errp)
     56 {
     57     QIOChannel *ioc;
     58     const char *argv[] = { "/bin/sh", "-c", command, NULL };
     59 
     60     trace_migration_exec_incoming(command);
     61     ioc = QIO_CHANNEL(qio_channel_command_new_spawn(argv,
     62                                                     O_RDWR,
     63                                                     errp));
     64     if (!ioc) {
     65         return;
     66     }
     67 
     68     qio_channel_set_name(ioc, "migration-exec-incoming");
     69     qio_channel_add_watch_full(ioc, G_IO_IN,
     70                                exec_accept_incoming_migration,
     71                                NULL, NULL,
     72                                g_main_context_get_thread_default());
     73 }