提交 148bed8e 编写于 作者: A Anya Harter 提交者: Ján Tomko

events: remove libxlDomainEventQueue wrapper func

And replace all calls with virObjectEventStateQueue such that:

    libxlDomainEventQueue(driver, event);

becomes:

    virObjectEventStateQueue(driver->domainEventState, event);

And remove NULL checking from all callers.
Signed-off-by: NAnya Harter <aharter@redhat.com>
Reviewed-by: NJán Tomko <jtomko@redhat.com>
Signed-off-by: NJán Tomko <jtomko@redhat.com>
上级 0e145a4f
...@@ -526,10 +526,8 @@ libxlDomainShutdownThread(void *opaque) ...@@ -526,10 +526,8 @@ libxlDomainShutdownThread(void *opaque)
} }
destroy: destroy:
if (dom_event) { virObjectEventStateQueue(driver->domainEventState, dom_event);
libxlDomainEventQueue(driver, dom_event); dom_event = NULL;
dom_event = NULL;
}
libxlDomainDestroyInternal(driver, vm); libxlDomainDestroyInternal(driver, vm);
libxlDomainCleanup(driver, vm); libxlDomainCleanup(driver, vm);
if (!vm->persistent) if (!vm->persistent)
...@@ -538,10 +536,8 @@ libxlDomainShutdownThread(void *opaque) ...@@ -538,10 +536,8 @@ libxlDomainShutdownThread(void *opaque)
goto endjob; goto endjob;
restart: restart:
if (dom_event) { virObjectEventStateQueue(driver->domainEventState, dom_event);
libxlDomainEventQueue(driver, dom_event); dom_event = NULL;
dom_event = NULL;
}
libxlDomainDestroyInternal(driver, vm); libxlDomainDestroyInternal(driver, vm);
libxlDomainCleanup(driver, vm); libxlDomainCleanup(driver, vm);
if (libxlDomainStartNew(driver, vm, false) < 0) { if (libxlDomainStartNew(driver, vm, false) < 0) {
...@@ -554,8 +550,7 @@ libxlDomainShutdownThread(void *opaque) ...@@ -554,8 +550,7 @@ libxlDomainShutdownThread(void *opaque)
cleanup: cleanup:
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (dom_event) virObjectEventStateQueue(driver->domainEventState, dom_event);
libxlDomainEventQueue(driver, dom_event);
libxl_event_free(cfg->ctx, ev); libxl_event_free(cfg->ctx, ev);
VIR_FREE(shutdown_info); VIR_FREE(shutdown_info);
virObjectUnref(cfg); virObjectUnref(cfg);
...@@ -616,12 +611,6 @@ libxlDomainEventHandler(void *data, VIR_LIBXL_EVENT_CONST libxl_event *event) ...@@ -616,12 +611,6 @@ libxlDomainEventHandler(void *data, VIR_LIBXL_EVENT_CONST libxl_event *event)
VIR_FREE(shutdown_info); VIR_FREE(shutdown_info);
} }
void
libxlDomainEventQueue(libxlDriverPrivatePtr driver, virObjectEventPtr event)
{
virObjectEventStateQueue(driver->domainEventState, event);
}
char * char *
libxlDomainManagedSavePath(libxlDriverPrivatePtr driver, virDomainObjPtr vm) libxlDomainManagedSavePath(libxlDriverPrivatePtr driver, virDomainObjPtr vm)
{ {
...@@ -1394,8 +1383,7 @@ libxlDomainStart(libxlDriverPrivatePtr driver, ...@@ -1394,8 +1383,7 @@ libxlDomainStart(libxlDriverPrivatePtr driver,
restore_fd < 0 ? restore_fd < 0 ?
VIR_DOMAIN_EVENT_STARTED_BOOTED : VIR_DOMAIN_EVENT_STARTED_BOOTED :
VIR_DOMAIN_EVENT_STARTED_RESTORED); VIR_DOMAIN_EVENT_STARTED_RESTORED);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
ret = 0; ret = 0;
goto cleanup; goto cleanup;
......
...@@ -95,10 +95,6 @@ int ...@@ -95,10 +95,6 @@ int
libxlDomainJobUpdateTime(struct libxlDomainJobObj *job) libxlDomainJobUpdateTime(struct libxlDomainJobObj *job)
ATTRIBUTE_RETURN_CHECK; ATTRIBUTE_RETURN_CHECK;
void
libxlDomainEventQueue(libxlDriverPrivatePtr driver,
virObjectEventPtr event);
char * char *
libxlDomainManagedSavePath(libxlDriverPrivatePtr driver, libxlDomainManagedSavePath(libxlDriverPrivatePtr driver,
virDomainObjPtr vm); virDomainObjPtr vm);
......
...@@ -1179,8 +1179,7 @@ libxlDomainSuspend(virDomainPtr dom) ...@@ -1179,8 +1179,7 @@ libxlDomainSuspend(virDomainPtr dom)
cleanup: cleanup:
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
...@@ -1234,8 +1233,7 @@ libxlDomainResume(virDomainPtr dom) ...@@ -1234,8 +1233,7 @@ libxlDomainResume(virDomainPtr dom)
cleanup: cleanup:
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
...@@ -1394,8 +1392,7 @@ libxlDomainDestroyFlags(virDomainPtr dom, ...@@ -1394,8 +1392,7 @@ libxlDomainDestroyFlags(virDomainPtr dom,
cleanup: cleanup:
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
...@@ -1734,8 +1731,7 @@ libxlDoDomainSave(libxlDriverPrivatePtr driver, ...@@ -1734,8 +1731,7 @@ libxlDoDomainSave(libxlDriverPrivatePtr driver,
VIR_FREE(xml); VIR_FREE(xml);
if (VIR_CLOSE(fd) < 0) if (VIR_CLOSE(fd) < 0)
virReportSystemError(errno, "%s", _("cannot close file")); virReportSystemError(errno, "%s", _("cannot close file"));
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
...@@ -1950,8 +1946,7 @@ libxlDomainCoreDump(virDomainPtr dom, const char *to, unsigned int flags) ...@@ -1950,8 +1946,7 @@ libxlDomainCoreDump(virDomainPtr dom, const char *to, unsigned int flags)
cleanup: cleanup:
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
...@@ -2755,8 +2750,7 @@ libxlDomainDefineXMLFlags(virConnectPtr conn, const char *xml, unsigned int flag ...@@ -2755,8 +2750,7 @@ libxlDomainDefineXMLFlags(virConnectPtr conn, const char *xml, unsigned int flag
virDomainDefFree(def); virDomainDefFree(def);
virDomainDefFree(oldDef); virDomainDefFree(oldDef);
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return dom; return dom;
} }
...@@ -2827,8 +2821,7 @@ libxlDomainUndefineFlags(virDomainPtr dom, ...@@ -2827,8 +2821,7 @@ libxlDomainUndefineFlags(virDomainPtr dom,
cleanup: cleanup:
VIR_FREE(name); VIR_FREE(name);
virDomainObjEndAPI(&vm); virDomainObjEndAPI(&vm);
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
......
...@@ -1284,10 +1284,8 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn, ...@@ -1284,10 +1284,8 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn,
VIR_DOMAIN_EVENT_SUSPENDED_PAUSED); VIR_DOMAIN_EVENT_SUSPENDED_PAUSED);
} }
if (event) { virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event); event = NULL;
event = NULL;
}
if (flags & VIR_MIGRATE_PERSIST_DEST) { if (flags & VIR_MIGRATE_PERSIST_DEST) {
unsigned int oldPersist = vm->persistent; unsigned int oldPersist = vm->persistent;
...@@ -1306,10 +1304,8 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn, ...@@ -1306,10 +1304,8 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn,
oldPersist ? oldPersist ?
VIR_DOMAIN_EVENT_DEFINED_UPDATED : VIR_DOMAIN_EVENT_DEFINED_UPDATED :
VIR_DOMAIN_EVENT_DEFINED_ADDED); VIR_DOMAIN_EVENT_DEFINED_ADDED);
if (event) { virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event); event = NULL;
event = NULL;
}
} }
if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm, cfg->caps) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm, cfg->caps) < 0)
...@@ -1329,8 +1325,7 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn, ...@@ -1329,8 +1325,7 @@ libxlDomainMigrationDstFinish(virConnectPtr dconn,
virDomainObjListRemove(driver->domains, vm); virDomainObjListRemove(driver->domains, vm);
} }
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return dom; return dom;
} }
...@@ -1384,8 +1379,7 @@ libxlDomainMigrationSrcConfirm(libxlDriverPrivatePtr driver, ...@@ -1384,8 +1379,7 @@ libxlDomainMigrationSrcConfirm(libxlDriverPrivatePtr driver,
ret = 0; ret = 0;
cleanup: cleanup:
if (event) virObjectEventStateQueue(driver->domainEventState, event);
libxlDomainEventQueue(driver, event);
virObjectUnref(cfg); virObjectUnref(cfg);
return ret; return ret;
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册