@@ -23,9 +23,14 @@ typedef struct JSONToken {
char str[];
} JSONToken;
+struct JSONMessageParser;
+typedef void (*JSONMessageEmitFunc)(struct JSONMessageParser *parser,
+ GQueue *tokens, void *opaque);
+
typedef struct JSONMessageParser
{
- void (*emit)(struct JSONMessageParser *parser, GQueue *tokens);
+ JSONMessageEmitFunc emit;
+ void *opaque;
JSONLexer lexer;
int brace_count;
int bracket_count;
@@ -34,7 +39,8 @@ typedef struct JSONMessageParser
} JSONMessageParser;
void json_message_parser_init(JSONMessageParser *parser,
- void (*func)(JSONMessageParser *, GQueue *));
+ JSONMessageEmitFunc func,
+ void *opaque);
int json_message_parser_feed(JSONMessageParser *parser,
const char *buffer, size_t size);
@@ -3808,7 +3808,8 @@ static int monitor_can_read(void *opaque)
return (mon->suspend_cnt == 0) ? 1 : 0;
}
-static void handle_qmp_command(JSONMessageParser *parser, GQueue *tokens)
+static void handle_qmp_command(JSONMessageParser *parser, GQueue *tokens,
+ void *opaque)
{
QObject *req, *rsp = NULL, *id = NULL;
QDict *qdict = NULL;
@@ -3955,7 +3956,7 @@ static void monitor_qmp_event(void *opaque, int event)
break;
case CHR_EVENT_CLOSED:
json_message_parser_destroy(&mon->qmp.parser);
- json_message_parser_init(&mon->qmp.parser, handle_qmp_command);
+ json_message_parser_init(&mon->qmp.parser, handle_qmp_command, NULL);
mon_refcount--;
monitor_fdsets_cleanup();
break;
@@ -4105,7 +4106,7 @@ void monitor_init(Chardev *chr, int flags)
qemu_chr_fe_set_handlers(&mon->chr, monitor_can_read, monitor_qmp_read,
monitor_qmp_event, NULL, mon, NULL, true);
qemu_chr_fe_set_echo(&mon->chr, true);
- json_message_parser_init(&mon->qmp.parser, handle_qmp_command);
+ json_message_parser_init(&mon->qmp.parser, handle_qmp_command, NULL);
} else {
qemu_chr_fe_set_handlers(&mon->chr, monitor_can_read, monitor_read,
monitor_event, NULL, mon, NULL, true);
@@ -593,7 +593,8 @@ static void process_command(GAState *s, QDict *req)
}
/* handle requests/control events coming in over the channel */
-static void process_event(JSONMessageParser *parser, GQueue *tokens)
+static void process_event(JSONMessageParser *parser, GQueue *tokens,
+ void *opaque)
{
GAState *s = container_of(parser, GAState, parser);
QDict *qdict;
@@ -1320,7 +1321,7 @@ static int run_agent(GAState *s, GAConfig *config, int socket_activation)
s->command_state = ga_command_state_new();
ga_command_state_init(s, s->command_state);
ga_command_state_init_all(s->command_state);
- json_message_parser_init(&s->parser, process_event);
+ json_message_parser_init(&s->parser, process_event, NULL);
#ifndef _WIN32
if (!register_signal_handlers()) {
@@ -102,18 +102,20 @@ out_emit:
*/
tokens = parser->tokens;
parser->tokens = g_queue_new();
- parser->emit(parser, tokens);
+ parser->emit(parser, tokens, parser->opaque);
parser->token_size = 0;
}
void json_message_parser_init(JSONMessageParser *parser,
- void (*func)(JSONMessageParser *, GQueue *))
+ JSONMessageEmitFunc func,
+ void *opaque)
{
parser->emit = func;
parser->brace_count = 0;
parser->bracket_count = 0;
parser->tokens = g_queue_new();
parser->token_size = 0;
+ parser->opaque = opaque;
json_lexer_init(&parser->lexer, json_message_process_token);
}
@@ -28,7 +28,8 @@ typedef struct JSONParsingState
Error *err;
} JSONParsingState;
-static void parse_json(JSONMessageParser *parser, GQueue *tokens)
+static void parse_json(JSONMessageParser *parser, GQueue *tokens,
+ void *opaque)
{
JSONParsingState *s = container_of(parser, JSONParsingState, parser);
@@ -41,7 +42,7 @@ QObject *qobject_from_jsonv(const char *string, va_list *ap, Error **errp)
state.ap = ap;
- json_message_parser_init(&state.parser, parse_json);
+ json_message_parser_init(&state.parser, parse_json, NULL);
json_message_parser_feed(&state.parser, string, strlen(string));
json_message_parser_flush(&state.parser);
json_message_parser_destroy(&state.parser);
@@ -412,7 +412,8 @@ typedef struct {
QDict *response;
} QMPResponseParser;
-static void qmp_response(JSONMessageParser *parser, GQueue *tokens)
+static void qmp_response(JSONMessageParser *parser, GQueue *tokens,
+ void *opaque)
{
QMPResponseParser *qmp = container_of(parser, QMPResponseParser, parser);
QObject *obj;
@@ -434,7 +435,7 @@ QDict *qmp_fd_receive(int fd)
bool log = getenv("QTEST_LOG") != NULL;
qmp.response = NULL;
- json_message_parser_init(&qmp.parser, qmp_response);
+ json_message_parser_init(&qmp.parser, qmp_response, NULL);
while (!qmp.response) {
ssize_t len;
char c;