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()
264 mon = req_obj->mon; in monitor_qmp_dispatcher_co()
308 if (req_obj->req) { in monitor_qmp_dispatcher_co()
310 QDict *qdict = qobject_to(QDict, req_obj->req); in monitor_qmp_dispatcher_co()
318 monitor_qmp_dispatch(mon, req_obj->req); in monitor_qmp_dispatcher_co()
320 assert(req_obj->err); in monitor_qmp_dispatcher_co()
321 trace_monitor_qmp_err_in_band(error_get_pretty(req_obj->err)); in monitor_qmp_dispatcher_co()
322 rsp = qmp_error_response(req_obj->err); in monitor_qmp_dispatcher_co()
323 req_obj->err = NULL; in monitor_qmp_dispatcher_co()
332 qmp_request_free(req_obj); in monitor_qmp_dispatcher_co()
349 QMPRequest *req_obj; in handle_qmp_command() local
374 req_obj = g_new0(QMPRequest, 1); in handle_qmp_command()
375 req_obj->mon = mon; in handle_qmp_command()
376 req_obj->req = req; in handle_qmp_command()
377 req_obj->err = err; in handle_qmp_command()
399 trace_monitor_qmp_in_band_enqueue(req_obj, mon, in handle_qmp_command()
402 g_queue_push_tail(mon->qmp_requests, req_obj); in handle_qmp_command()