Lines Matching refs:req_obj

177     QMPRequest *req_obj = NULL;  in monitor_qmp_requests_pop_any_with_lock()  local
190 req_obj = g_queue_pop_head(qmp_mon->qmp_requests); in monitor_qmp_requests_pop_any_with_lock()
191 if (req_obj) { in monitor_qmp_requests_pop_any_with_lock()
198 if (req_obj) { in monitor_qmp_requests_pop_any_with_lock()
207 return req_obj; in monitor_qmp_requests_pop_any_with_lock()
212 QMPRequest *req_obj = NULL; in monitor_qmp_dispatcher_co() local
232 while (!(req_obj = monitor_qmp_requests_pop_any_with_lock())) { in monitor_qmp_dispatcher_co()
257 trace_monitor_qmp_in_band_dequeue(req_obj, in monitor_qmp_dispatcher_co()
258 req_obj->mon->qmp_requests->length); in monitor_qmp_dispatcher_co()
282 mon = req_obj->mon; in monitor_qmp_dispatcher_co()
304 if (req_obj->req) { in monitor_qmp_dispatcher_co()
306 QDict *qdict = qobject_to(QDict, req_obj->req); in monitor_qmp_dispatcher_co()
314 monitor_qmp_dispatch(mon, req_obj->req); in monitor_qmp_dispatcher_co()
316 assert(req_obj->err); in monitor_qmp_dispatcher_co()
317 trace_monitor_qmp_err_in_band(error_get_pretty(req_obj->err)); in monitor_qmp_dispatcher_co()
318 rsp = qmp_error_response(req_obj->err); in monitor_qmp_dispatcher_co()
319 req_obj->err = NULL; in monitor_qmp_dispatcher_co()
328 qmp_request_free(req_obj); in monitor_qmp_dispatcher_co()
345 QMPRequest *req_obj; in handle_qmp_command() local
370 req_obj = g_new0(QMPRequest, 1); in handle_qmp_command()
371 req_obj->mon = mon; in handle_qmp_command()
372 req_obj->req = req; in handle_qmp_command()
373 req_obj->err = err; in handle_qmp_command()
395 trace_monitor_qmp_in_band_enqueue(req_obj, mon, in handle_qmp_command()
398 g_queue_push_tail(mon->qmp_requests, req_obj); in handle_qmp_command()