1 /* 2 * QEMU Management Protocol commands 3 * 4 * Copyright IBM, Corp. 2011 5 * 6 * Authors: 7 * Anthony Liguori <aliguori@us.ibm.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/osdep.h" 17 #include "qemu/sockets.h" 18 #include "monitor-internal.h" 19 #include "monitor/qdev.h" 20 #include "monitor/qmp-helpers.h" 21 #include "sysemu/sysemu.h" 22 #include "sysemu/kvm.h" 23 #include "sysemu/runstate.h" 24 #include "sysemu/runstate-action.h" 25 #include "sysemu/block-backend.h" 26 #include "qapi/error.h" 27 #include "qapi/qapi-init-commands.h" 28 #include "qapi/qapi-commands-control.h" 29 #include "qapi/qapi-commands-misc.h" 30 #include "qapi/qmp/qerror.h" 31 #include "qapi/type-helpers.h" 32 #include "hw/mem/memory-device.h" 33 #include "hw/intc/intc.h" 34 35 NameInfo *qmp_query_name(Error **errp) 36 { 37 NameInfo *info = g_malloc0(sizeof(*info)); 38 39 info->name = g_strdup(qemu_name); 40 return info; 41 } 42 43 void qmp_quit(Error **errp) 44 { 45 shutdown_action = SHUTDOWN_ACTION_POWEROFF; 46 qemu_system_shutdown_request(SHUTDOWN_CAUSE_HOST_QMP_QUIT); 47 } 48 49 void qmp_stop(Error **errp) 50 { 51 /* if there is a dump in background, we should wait until the dump 52 * finished */ 53 if (qemu_system_dump_in_progress()) { 54 error_setg(errp, "There is a dump in process, please wait."); 55 return; 56 } 57 58 if (runstate_check(RUN_STATE_INMIGRATE)) { 59 autostart = 0; 60 } else { 61 vm_stop(RUN_STATE_PAUSED); 62 } 63 } 64 65 void qmp_cont(Error **errp) 66 { 67 BlockBackend *blk; 68 BlockJob *job; 69 Error *local_err = NULL; 70 71 /* if there is a dump in background, we should wait until the dump 72 * finished */ 73 if (qemu_system_dump_in_progress()) { 74 error_setg(errp, "There is a dump in process, please wait."); 75 return; 76 } 77 78 if (runstate_needs_reset()) { 79 error_setg(errp, "Resetting the Virtual Machine is required"); 80 return; 81 } else if (runstate_check(RUN_STATE_SUSPENDED)) { 82 return; 83 } else if (runstate_check(RUN_STATE_FINISH_MIGRATE)) { 84 error_setg(errp, "Migration is not finalized yet"); 85 return; 86 } 87 88 for (blk = blk_next(NULL); blk; blk = blk_next(blk)) { 89 blk_iostatus_reset(blk); 90 } 91 92 WITH_JOB_LOCK_GUARD() { 93 for (job = block_job_next_locked(NULL); job; 94 job = block_job_next_locked(job)) { 95 block_job_iostatus_reset_locked(job); 96 } 97 } 98 99 /* Continuing after completed migration. Images have been inactivated to 100 * allow the destination to take control. Need to get control back now. 101 * 102 * If there are no inactive block nodes (e.g. because the VM was just 103 * paused rather than completing a migration), bdrv_inactivate_all() simply 104 * doesn't do anything. */ 105 bdrv_activate_all(&local_err); 106 if (local_err) { 107 error_propagate(errp, local_err); 108 return; 109 } 110 111 if (runstate_check(RUN_STATE_INMIGRATE)) { 112 autostart = 1; 113 } else { 114 vm_start(); 115 } 116 } 117 118 void qmp_add_client(const char *protocol, const char *fdname, 119 bool has_skipauth, bool skipauth, bool has_tls, bool tls, 120 Error **errp) 121 { 122 static const struct { 123 const char *name; 124 bool (*add_client)(int fd, bool has_skipauth, bool skipauth, 125 bool has_tls, bool tls, Error **errp); 126 } protocol_table[] = { 127 { "spice", qmp_add_client_spice }, 128 #ifdef CONFIG_VNC 129 { "vnc", qmp_add_client_vnc }, 130 #endif 131 #ifdef CONFIG_DBUS_DISPLAY 132 { "@dbus-display", qmp_add_client_dbus_display }, 133 #endif 134 }; 135 int fd, i; 136 137 fd = monitor_get_fd(monitor_cur(), fdname, errp); 138 if (fd < 0) { 139 return; 140 } 141 142 if (!fd_is_socket(fd)) { 143 error_setg(errp, "parameter @fdname must name a socket"); 144 close(fd); 145 return; 146 } 147 148 for (i = 0; i < ARRAY_SIZE(protocol_table); i++) { 149 if (!strcmp(protocol, protocol_table[i].name)) { 150 if (!protocol_table[i].add_client(fd, has_skipauth, skipauth, 151 has_tls, tls, errp)) { 152 close(fd); 153 } 154 return; 155 } 156 } 157 158 if (!qmp_add_client_char(fd, has_skipauth, skipauth, has_tls, tls, 159 protocol, errp)) { 160 close(fd); 161 } 162 } 163 164 char *qmp_human_monitor_command(const char *command_line, bool has_cpu_index, 165 int64_t cpu_index, Error **errp) 166 { 167 char *output = NULL; 168 MonitorHMP hmp = {}; 169 170 monitor_data_init(&hmp.common, false, true, false); 171 172 if (has_cpu_index) { 173 int ret = monitor_set_cpu(&hmp.common, cpu_index); 174 if (ret < 0) { 175 error_setg(errp, QERR_INVALID_PARAMETER_VALUE, "cpu-index", 176 "a CPU number"); 177 goto out; 178 } 179 } 180 181 handle_hmp_command(&hmp, command_line); 182 183 WITH_QEMU_LOCK_GUARD(&hmp.common.mon_lock) { 184 output = g_strdup(hmp.common.outbuf->str); 185 } 186 187 out: 188 monitor_data_destroy(&hmp.common); 189 return output; 190 } 191 192 static void __attribute__((__constructor__)) monitor_init_qmp_commands(void) 193 { 194 /* 195 * Two command lists: 196 * - qmp_commands contains all QMP commands 197 * - qmp_cap_negotiation_commands contains just 198 * "qmp_capabilities", to enforce capability negotiation 199 */ 200 201 qmp_init_marshal(&qmp_commands); 202 203 qmp_register_command(&qmp_commands, "device_add", 204 qmp_device_add, 0, 0); 205 206 QTAILQ_INIT(&qmp_cap_negotiation_commands); 207 qmp_register_command(&qmp_cap_negotiation_commands, "qmp_capabilities", 208 qmp_marshal_qmp_capabilities, 209 QCO_ALLOW_PRECONFIG, 0); 210 } 211