libvirt/src/driver.c

272 lines
6.7 KiB
C
Raw Normal View History

2008-11-21 12:16:08 +00:00
/*
* driver.c: Helpers for loading drivers
*
* Copyright (C) 2006-2011 Red Hat, Inc.
2008-11-21 12:16:08 +00:00
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library. If not, see
* <http://www.gnu.org/licenses/>.
2008-11-21 12:16:08 +00:00
*
*/
#include <config.h>
#include <unistd.h>
#include "driver.h"
2012-12-12 18:06:53 +00:00
#include "viralloc.h"
#include "virfile.h"
2012-12-12 17:59:27 +00:00
#include "virlog.h"
#include "virmodule.h"
#include "virthread.h"
maint: use gnulib configmake rather than open-coding things * bootstrap.conf (gnulib_modules): Add configmake. * daemon/Makefile.am (libvirtd_CFLAGS): Drop defines provided by gnulib. * src/Makefile.am (INCLUDES): Likewise. * tests/Makefile.am (INCLUDES): Likewise. * tools/Makefile.am (virsh_CFLAGS): Likewise. * daemon/libvirtd.c (qemudInitPaths, usage, main): Update clients. * src/cpu/cpu_map.c (CPUMAPFILE): Likewise. * src/driver.c (DEFAULT_DRIVER_DIR): Likewise. * src/internal.h (_): Likewise. * src/libvirt.c (virInitialize): Likewise. * src/lxc/lxc_conf.h (LXC_CONFIG_DIR, LXC_STATE_DIR, LXC_LOG_DIR): Likewise. * src/lxc/lxc_conf.c (lxcCapsInit, lxcLoadDriverConfig): Likewise. * src/network/bridge_driver.c (NETWORK_PID_DIR) (NETWORK_STATE_DIR, DNSMASQ_STATE_DIR, networkStartup): Likewise. * src/nwfilter/nwfilter_driver.c (nwfilterDriverStartup): Likewise. * src/qemu/qemu_conf.c (qemudLoadDriverConfig): Likewise. * src/qemu/qemu_driver.c (qemudStartup): Likewise. * src/remote/remote_driver.h (LIBVIRTD_PRIV_UNIX_SOCKET) (LIBVIRTD_PRIV_UNIX_SOCKET_RO, LIBVIRTD_CONFIGURATION_FILE) (LIBVIRT_PKI_DIR): Likewise. * src/secret/secret_driver.c (secretDriverStartup): Likewise. * src/security/security_apparmor.c (VIRT_AA_HELPER): Likewise. * src/security/virt-aa-helper.c (main): Likewise. * src/storage/storage_backend_disk.c (PARTHELPER): Likewise. * src/storage/storage_driver.c (storageDriverStartup): Likewise. * src/uml/uml_driver.c (TEMPDIR, umlStartup): Likewise. * src/util/hooks.c (LIBVIRT_HOOK_DIR): Likewise. * tools/virsh.c (main): Likewise. * docs/hooks.html.in: Likewise.
2010-11-16 14:54:17 +00:00
#include "configmake.h"
2008-11-21 12:16:08 +00:00
VIR_LOG_INIT("driver");
#define VIR_FROM_THIS VIR_FROM_NONE
2008-11-21 12:16:08 +00:00
/* XXX re-implement this for other OS, or use libtools helper lib ? */
#define DEFAULT_DRIVER_DIR LIBDIR "/libvirt/connection-driver"
2008-11-21 12:16:08 +00:00
int
virDriverLoadModule(const char *name,
const char *regfunc,
bool required)
2008-11-21 12:16:08 +00:00
{
char *modfile = NULL;
int ret;
2008-11-21 12:16:08 +00:00
VIR_DEBUG("Module load %s", name);
2008-11-21 12:16:08 +00:00
if (!(modfile = virFileFindResourceFull(name,
"libvirt_driver_",
".so",
abs_top_builddir "/src/.libs",
DEFAULT_DRIVER_DIR,
"LIBVIRT_DRIVER_DIR")))
return -1;
2008-11-21 12:16:08 +00:00
ret = virModuleLoad(modfile, regfunc, required);
2008-11-21 12:16:08 +00:00
VIR_FREE(modfile);
return ret;
2008-11-21 12:16:08 +00:00
}
/* XXX unload modules, but we can't until we can unregister libvirt drivers */
virThreadLocal connectInterface;
virThreadLocal connectNetwork;
virThreadLocal connectNWFilter;
virThreadLocal connectNodeDev;
virThreadLocal connectSecret;
virThreadLocal connectStorage;
static int
virConnectCacheOnceInit(void)
{
if (virThreadLocalInit(&connectInterface, NULL) < 0)
return -1;
if (virThreadLocalInit(&connectNetwork, NULL) < 0)
return -1;
if (virThreadLocalInit(&connectNWFilter, NULL) < 0)
return -1;
if (virThreadLocalInit(&connectNodeDev, NULL) < 0)
return -1;
if (virThreadLocalInit(&connectSecret, NULL) < 0)
return -1;
if (virThreadLocalInit(&connectStorage, NULL) < 0)
return -1;
return 0;
}
VIR_ONCE_GLOBAL_INIT(virConnectCache);
virConnectPtr virGetConnectInterface(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectInterface);
if (conn) {
VIR_DEBUG("Return cached interface connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "interface:///system" : "interface:///session");
VIR_DEBUG("Opened new interface connection %p", conn);
}
return conn;
}
virConnectPtr virGetConnectNetwork(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectNetwork);
if (conn) {
VIR_DEBUG("Return cached network connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "network:///system" : "network:///session");
VIR_DEBUG("Opened new network connection %p", conn);
}
return conn;
}
virConnectPtr virGetConnectNWFilter(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectNWFilter);
if (conn) {
VIR_DEBUG("Return cached nwfilter connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "nwfilter:///system" : "nwfilter:///session");
VIR_DEBUG("Opened new nwfilter connection %p", conn);
}
return conn;
}
virConnectPtr virGetConnectNodeDev(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectNodeDev);
if (conn) {
VIR_DEBUG("Return cached nodedev connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "nodedev:///system" : "nodedev:///session");
VIR_DEBUG("Opened new nodedev connection %p", conn);
}
return conn;
}
virConnectPtr virGetConnectSecret(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectSecret);
if (conn) {
VIR_DEBUG("Return cached secret connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "secret:///system" : "secret:///session");
VIR_DEBUG("Opened new secret connection %p", conn);
}
return conn;
}
virConnectPtr virGetConnectStorage(void)
{
virConnectPtr conn;
if (virConnectCacheInitialize() < 0)
return NULL;
conn = virThreadLocalGet(&connectStorage);
if (conn) {
VIR_DEBUG("Return cached storage connection %p", conn);
virObjectRef(conn);
} else {
conn = virConnectOpen(geteuid() == 0 ? "storage:///system" : "storage:///session");
VIR_DEBUG("Opened new storage connection %p", conn);
}
return conn;
}
int
virSetConnectInterface(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override interface connection with %p", conn);
return virThreadLocalSet(&connectInterface, conn);
}
int
virSetConnectNetwork(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override network connection with %p", conn);
return virThreadLocalSet(&connectNetwork, conn);
}
int
virSetConnectNWFilter(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override nwfilter connection with %p", conn);
return virThreadLocalSet(&connectNWFilter, conn);
}
int
virSetConnectNodeDev(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override nodedev connection with %p", conn);
return virThreadLocalSet(&connectNodeDev, conn);
}
int
virSetConnectSecret(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override secret connection with %p", conn);
return virThreadLocalSet(&connectSecret, conn);
}
int
virSetConnectStorage(virConnectPtr conn)
{
if (virConnectCacheInitialize() < 0)
return -1;
VIR_DEBUG("Override storage connection with %p", conn);
return virThreadLocalSet(&connectStorage, conn);
}