[libvirt] [PATCH 02/13] Move daemon-related parts of virNetServer to virNetDaemon
Michal Privoznik
mprivozn at redhat.com
Wed May 20 16:11:14 UTC 2015
On 20.05.2015 07:19, Martin Kletzander wrote:
> This allows to have more servers in one daemon which helps isolating
> some resources.
>
> Signed-off-by: Martin Kletzander <mkletzan at redhat.com>
> ---
> daemon/libvirtd.c | 101 ++---
> docs/internals.html.in | 4 +-
> docs/internals/rpc.html.in | 7 +
> po/POTFILES.in | 1 +
> src/Makefile.am | 1 +
> src/libvirt_remote.syms | 28 +-
> src/locking/lock_daemon.c | 63 ++--
> src/locking/lock_daemon_config.c | 2 +-
> src/locking/lock_daemon_dispatch.c | 4 +-
> src/lxc/lxc_controller.c | 65 ++--
> src/rpc/virnetdaemon.c | 746 +++++++++++++++++++++++++++++++++++++
> src/rpc/virnetdaemon.h | 82 ++++
> src/rpc/virnetserver.c | 526 ++++----------------------
> src/rpc/virnetserver.h | 46 +--
> src/rpc/virnetserverprogram.h | 3 +
> 15 files changed, 1074 insertions(+), 605 deletions(-)
> create mode 100644 src/rpc/virnetdaemon.c
> create mode 100644 src/rpc/virnetdaemon.h
>
> diff --git a/src/rpc/virnetdaemon.c b/src/rpc/virnetdaemon.c
> new file mode 100644
> index 0000000..8d42638
> --- /dev/null
> +++ b/src/rpc/virnetdaemon.c
> +
> +
> +static virClassPtr virNetDaemonClass;
> +
> +void
static
> +virNetDaemonDispose(void *obj)
> +{
> + virNetDaemonPtr dmn = obj;
> + size_t i;
> +
> + VIR_FORCE_CLOSE(dmn->autoShutdownInhibitFd);
> +
> + for (i = 0; i < dmn->nsignals; i++) {
> + sigaction(dmn->signals[i]->signum, &dmn->signals[i]->oldaction, NULL);
> + VIR_FREE(dmn->signals[i]);
> + }
> + VIR_FREE(dmn->signals);
> + VIR_FORCE_CLOSE(dmn->sigread);
> + VIR_FORCE_CLOSE(dmn->sigwrite);
> + if (dmn->sigwatch > 0)
> + virEventRemoveHandle(dmn->sigwatch);
> +
> + for (i = 0; i < dmn->nservers; i++)
> + virObjectUnref(dmn->servers[i]);
> + VIR_FREE(dmn->servers);
> +
> + virJSONValueFree(dmn->srvObject);
> +}
> +
> +static int
> +virNetDaemonOnceInit(void)
> +{
> + if (!(virNetDaemonClass = virClassNew(virClassForObjectLockable(),
> + "virNetDaemon",
> + sizeof(virNetDaemon),
> + virNetDaemonDispose)))
> + return -1;
> +
> + return 0;
> +}
> +/*
> + * Separate function merely for the purpose of unified error
> + * reporting.
> + */
> +static virNetServerPtr
> +virNetDaemonGetServerInternal(virNetDaemonPtr dmn,
> + int subServerID)
> +{
> + if (subServerID < 0 || subServerID >= dmn->nservers) {
> + virReportError(VIR_ERR_INVALID_ARG,
> + _("Invalid server ID: %d"),
> + subServerID);
> + return NULL;
> + }
> +
> + return virObjectRef(dmn->servers[subServerID]);
> +}
> +
> +/*
> + * The server is locked after this function.
No, it's not.
> + */
> +virNetServerPtr
> +virNetDaemonGetServer(virNetDaemonPtr dmn,
> + int subServerID)
> +{
> + virNetServerPtr srv = NULL;
> +
> + virObjectLock(dmn);
> + srv = virNetDaemonGetServerInternal(dmn, subServerID);
Did you forget virObjectLock(srv) here?
> + virObjectUnlock(dmn);
> +
> + return srv;
> +}
> +
> +void
> +virNetDaemonUpdateServices(virNetDaemonPtr dmn,
> + bool enabled)
> +{
> + size_t i;
> +
> + virObjectLock(dmn);
> + for (i = 0; i < dmn->nservers; i++)
> + virNetServerUpdateServices(dmn->servers[i], enabled);
> + virObjectUnlock(dmn);
Hm... I guess we need something slightly different. While we may want
one service to stop accepting new clients, we may want the other one to
still accept new ones. But since this is a big split, and so far a
daemon will have only one server, it can be saved for a follow up patch.
> +}
> +
Besides Dan's finding, looking okay. ACK.
Michal
More information about the libvir-list
mailing list