Re: [libvirt] [PATCH 1/8] qemu: bulk stats: extend internal collection API

Future patches which will implement more bulk stats groups for QEMU will need to access the connection object. To accomodate that, a few changes are needed: * enrich internal prototype to pass connection object. * add per-group flag to mark if one collector needs monitor access or not. * if at least one collector of the requested stats needs monitor access, thus we must start a query job for each domain. The specific collectors will run nested monitor jobs inside that. Signed-off-by: Francesco Romani <fromani(a)redhat.com&gt; --- src/qemu/qemu_driver.c | 51 ++++++++++++++++++++++++++++++++++++++++++-------- 1 file changed, 43 insertions(+), 8 deletions(-) diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c index d724eeb..2950a4b 100644 --- a/src/qemu/qemu_driver.c +++ b/src/qemu/qemu_driver.c

@@ -17338,7 +17339,8 @@ qemuDomainGetStatsState(virDomainObjPtr dom, typedef int -(*qemuDomainGetStatsFunc)(virDomainObjPtr dom, +(*qemuDomainGetStatsFunc)(virConnectPtr conn,

+ virDomainObjPtr dom, virDomainStatsRecordPtr record, int *maxparams, unsigned int flags);

@@ -17483,11 +17503,21 @@ qemuConnectGetAllDomainStats(virConnectPtr conn, !virConnectGetAllDomainStatsCheckACL(conn, dom->def)) continue; - if (qemuDomainGetStats(conn, dom, stats, &tmp, flags) < 0) + if (needmon && qemuDomainObjBeginJob(driver, dom, QEMU_JOB_QUERY) < 0) goto cleanup; - if (tmp) - tmpstats[nstats++] = tmp; + if ((needmon && virDomainObjIsActive(dom)) || !needmon) {

+ if (qemuDomainGetStats(conn, dom, stats, &tmp, flags) < 0) + goto endjob; + + if (tmp) + tmpstats[nstats++] = tmp; + } + + if (needmon && !qemuDomainObjEndJob(driver, dom)) { + dom = NULL; + goto cleanup; + } virObjectUnlock(dom); dom = NULL;