提交 f994b258 编写于 作者: M Markus Armbruster

monitor: Turn int command_mode into bool in_command_mode

While there, inline the pointless qmp_cmd_mode() wrapper.
Signed-off-by: NMarkus Armbruster <armbru@redhat.com>
Reviewed-by: NEric Blake <eblake@redhat.com>
Reviewed-by: NLuiz Capitulino <lcapitulino@redhat.com>
上级 6a50636f
...@@ -164,7 +164,12 @@ struct MonFdset { ...@@ -164,7 +164,12 @@ struct MonFdset {
typedef struct { typedef struct {
QObject *id; QObject *id;
JSONMessageParser parser; JSONMessageParser parser;
int command_mode; /*
* When a client connects, we're in capabilities negotiation mode.
* When command qmp_capabilities succeeds, we go into command
* mode.
*/
bool in_command_mode; /* are we in command mode? */
} MonitorQMP; } MonitorQMP;
/* /*
...@@ -226,11 +231,6 @@ Monitor *default_mon; ...@@ -226,11 +231,6 @@ Monitor *default_mon;
static void monitor_command_cb(void *opaque, const char *cmdline, static void monitor_command_cb(void *opaque, const char *cmdline,
void *readline_opaque); void *readline_opaque);
static inline int qmp_cmd_mode(const Monitor *mon)
{
return mon->qmp.command_mode;
}
/* Return true if in control mode, false otherwise */ /* Return true if in control mode, false otherwise */
static inline int monitor_ctrl_mode(const Monitor *mon) static inline int monitor_ctrl_mode(const Monitor *mon)
{ {
...@@ -446,7 +446,7 @@ static void monitor_qapi_event_emit(QAPIEvent event, QObject *data) ...@@ -446,7 +446,7 @@ static void monitor_qapi_event_emit(QAPIEvent event, QObject *data)
trace_monitor_protocol_event_emit(event, data); trace_monitor_protocol_event_emit(event, data);
QLIST_FOREACH(mon, &mon_list, entry) { QLIST_FOREACH(mon, &mon_list, entry) {
if (monitor_ctrl_mode(mon) && qmp_cmd_mode(mon)) { if (monitor_ctrl_mode(mon) && mon->qmp.in_command_mode) {
monitor_json_emitter(mon, data); monitor_json_emitter(mon, data);
} }
} }
...@@ -566,7 +566,7 @@ static void monitor_qapi_event_init(void) ...@@ -566,7 +566,7 @@ static void monitor_qapi_event_init(void)
static int do_qmp_capabilities(Monitor *mon, const QDict *params, static int do_qmp_capabilities(Monitor *mon, const QDict *params,
QObject **ret_data) QObject **ret_data)
{ {
mon->qmp.command_mode = 1; mon->qmp.in_command_mode = true;
return 0; return 0;
} }
...@@ -4702,13 +4702,14 @@ static bool invalid_qmp_mode(const Monitor *mon, const mon_cmd_t *cmd, ...@@ -4702,13 +4702,14 @@ static bool invalid_qmp_mode(const Monitor *mon, const mon_cmd_t *cmd,
Error **errp) Error **errp)
{ {
bool is_cap = cmd->mhandler.cmd_new == do_qmp_capabilities; bool is_cap = cmd->mhandler.cmd_new == do_qmp_capabilities;
if (is_cap && qmp_cmd_mode(mon)) {
if (is_cap && mon->qmp.in_command_mode) {
error_set(errp, ERROR_CLASS_COMMAND_NOT_FOUND, error_set(errp, ERROR_CLASS_COMMAND_NOT_FOUND,
"Capabilities negotiation is already complete, command " "Capabilities negotiation is already complete, command "
"'%s' ignored", cmd->name); "'%s' ignored", cmd->name);
return true; return true;
} }
if (!is_cap && !qmp_cmd_mode(mon)) { if (!is_cap && !mon->qmp.in_command_mode) {
error_set(errp, ERROR_CLASS_COMMAND_NOT_FOUND, error_set(errp, ERROR_CLASS_COMMAND_NOT_FOUND,
"Expecting capabilities negotiation with " "Expecting capabilities negotiation with "
"'qmp_capabilities' before command '%s'", cmd->name); "'qmp_capabilities' before command '%s'", cmd->name);
...@@ -5110,7 +5111,7 @@ static void monitor_qmp_event(void *opaque, int event) ...@@ -5110,7 +5111,7 @@ static void monitor_qmp_event(void *opaque, int event)
switch (event) { switch (event) {
case CHR_EVENT_OPENED: case CHR_EVENT_OPENED:
mon->qmp.command_mode = 0; mon->qmp.in_command_mode = false;
data = get_qmp_greeting(); data = get_qmp_greeting();
monitor_json_emitter(mon, data); monitor_json_emitter(mon, data);
qobject_decref(data); qobject_decref(data);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册