mirror of
https://gitlab.com/libvirt/libvirt.git
synced 2024-08-28 19:41:16 +00:00
Expose a public API to retrieve some identity and connection information about a client connected to the specified server on daemon. The identity info retrieved is mostly connection transport dependent, i.e. there won't be any socket address returned for a local (UNIX socket) connection, while on the other hand, when connected through TLS or unencrypted TCP, obviously no UNIX process identification will be present in the returned data. All supported values that can be returned in typed params are exposed and documented in include/libvirt/libvirt-admin.h Signed-off-by: Erik Skultety <eskultet@redhat.com>
306 lines
9.4 KiB
C
306 lines
9.4 KiB
C
/*
|
|
* admin_server.c: admin methods to manage daemons and clients
|
|
*
|
|
* Copyright (C) 2016 Red Hat, Inc.
|
|
*
|
|
* 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/>.
|
|
*
|
|
* Authors: Erik Skultety <eskultet@redhat.com>
|
|
* Martin Kletzander <mkletzan@redhat.com>
|
|
*/
|
|
|
|
#include <config.h>
|
|
|
|
#include "admin_server.h"
|
|
#include "datatypes.h"
|
|
#include "viralloc.h"
|
|
#include "virerror.h"
|
|
#include "viridentity.h"
|
|
#include "virlog.h"
|
|
#include "virnetdaemon.h"
|
|
#include "virnetserver.h"
|
|
#include "virstring.h"
|
|
#include "virthreadpool.h"
|
|
#include "virtypedparam.h"
|
|
|
|
#define VIR_FROM_THIS VIR_FROM_ADMIN
|
|
|
|
VIR_LOG_INIT("daemon.admin_server");
|
|
|
|
int
|
|
adminConnectListServers(virNetDaemonPtr dmn,
|
|
virNetServerPtr **servers,
|
|
unsigned int flags)
|
|
{
|
|
int ret = -1;
|
|
virNetServerPtr *srvs = NULL;
|
|
|
|
virCheckFlags(0, -1);
|
|
|
|
if ((ret = virNetDaemonGetServers(dmn, &srvs)) < 0)
|
|
goto cleanup;
|
|
|
|
if (servers) {
|
|
*servers = srvs;
|
|
srvs = NULL;
|
|
}
|
|
cleanup:
|
|
if (ret > 0)
|
|
virObjectListFreeCount(srvs, ret);
|
|
return ret;
|
|
}
|
|
|
|
virNetServerPtr
|
|
adminConnectLookupServer(virNetDaemonPtr dmn,
|
|
const char *name,
|
|
unsigned int flags)
|
|
{
|
|
virCheckFlags(flags, NULL);
|
|
|
|
return virNetDaemonGetServer(dmn, name);
|
|
}
|
|
|
|
int
|
|
adminServerGetThreadPoolParameters(virNetServerPtr srv,
|
|
virTypedParameterPtr *params,
|
|
int *nparams,
|
|
unsigned int flags)
|
|
{
|
|
int ret = -1;
|
|
int maxparams = 0;
|
|
size_t minWorkers;
|
|
size_t maxWorkers;
|
|
size_t nWorkers;
|
|
size_t freeWorkers;
|
|
size_t nPrioWorkers;
|
|
size_t jobQueueDepth;
|
|
virTypedParameterPtr tmpparams = NULL;
|
|
|
|
virCheckFlags(0, -1);
|
|
|
|
if (virNetServerGetThreadPoolParameters(srv, &minWorkers, &maxWorkers,
|
|
&nWorkers, &freeWorkers,
|
|
&nPrioWorkers,
|
|
&jobQueueDepth) < 0) {
|
|
virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
|
|
_("Unable to retrieve threadpool parameters"));
|
|
goto cleanup;
|
|
}
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_WORKERS_MIN,
|
|
minWorkers) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_WORKERS_MAX,
|
|
maxWorkers) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_WORKERS_CURRENT,
|
|
nWorkers) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_WORKERS_FREE,
|
|
freeWorkers) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_WORKERS_PRIORITY,
|
|
nPrioWorkers) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddUInt(&tmpparams, nparams,
|
|
&maxparams, VIR_THREADPOOL_JOB_QUEUE_DEPTH,
|
|
jobQueueDepth) < 0)
|
|
goto cleanup;
|
|
|
|
*params = tmpparams;
|
|
tmpparams = NULL;
|
|
ret = 0;
|
|
|
|
cleanup:
|
|
virTypedParamsFree(tmpparams, *nparams);
|
|
return ret;
|
|
}
|
|
|
|
int
|
|
adminServerSetThreadPoolParameters(virNetServerPtr srv,
|
|
virTypedParameterPtr params,
|
|
int nparams,
|
|
unsigned int flags)
|
|
{
|
|
long long int minWorkers = -1;
|
|
long long int maxWorkers = -1;
|
|
long long int prioWorkers = -1;
|
|
virTypedParameterPtr param = NULL;
|
|
|
|
virCheckFlags(0, -1);
|
|
|
|
if (virTypedParamsValidate(params, nparams,
|
|
VIR_THREADPOOL_WORKERS_MIN,
|
|
VIR_TYPED_PARAM_UINT,
|
|
VIR_THREADPOOL_WORKERS_MAX,
|
|
VIR_TYPED_PARAM_UINT,
|
|
VIR_THREADPOOL_WORKERS_PRIORITY,
|
|
VIR_TYPED_PARAM_UINT,
|
|
NULL) < 0)
|
|
return -1;
|
|
|
|
if ((param = virTypedParamsGet(params, nparams,
|
|
VIR_THREADPOOL_WORKERS_MIN)))
|
|
minWorkers = param->value.ui;
|
|
|
|
if ((param = virTypedParamsGet(params, nparams,
|
|
VIR_THREADPOOL_WORKERS_MAX)))
|
|
maxWorkers = param->value.ui;
|
|
|
|
if ((param = virTypedParamsGet(params, nparams,
|
|
VIR_THREADPOOL_WORKERS_PRIORITY)))
|
|
prioWorkers = param->value.ui;
|
|
|
|
if (virNetServerSetThreadPoolParameters(srv, minWorkers,
|
|
maxWorkers, prioWorkers) < 0)
|
|
return -1;
|
|
|
|
return 0;
|
|
}
|
|
|
|
int
|
|
adminServerListClients(virNetServerPtr srv,
|
|
virNetServerClientPtr **clients,
|
|
unsigned int flags)
|
|
{
|
|
int ret = -1;
|
|
virNetServerClientPtr *clts;
|
|
|
|
virCheckFlags(0, -1);
|
|
|
|
if ((ret = virNetServerGetClients(srv, &clts)) < 0)
|
|
goto cleanup;
|
|
|
|
if (clients) {
|
|
*clients = clts;
|
|
clts = NULL;
|
|
}
|
|
|
|
cleanup:
|
|
virObjectListFreeCount(clts, ret);
|
|
return ret;
|
|
}
|
|
|
|
virNetServerClientPtr
|
|
adminServerLookupClient(virNetServerPtr srv,
|
|
unsigned long long id,
|
|
unsigned int flags)
|
|
{
|
|
virCheckFlags(0, NULL);
|
|
|
|
return virNetServerGetClient(srv, id);
|
|
}
|
|
|
|
int
|
|
adminClientGetInfo(virNetServerClientPtr client,
|
|
virTypedParameterPtr *params,
|
|
int *nparams,
|
|
unsigned int flags)
|
|
{
|
|
int ret = -1;
|
|
int maxparams = 0;
|
|
bool readonly;
|
|
const char *sock_addr = NULL;
|
|
const char *attr = NULL;
|
|
virTypedParameterPtr tmpparams = NULL;
|
|
virIdentityPtr identity = NULL;
|
|
|
|
virCheckFlags(0, -1);
|
|
|
|
if (virNetServerClientGetInfo(client, &readonly,
|
|
&sock_addr, &identity) < 0)
|
|
goto cleanup;
|
|
|
|
if (virTypedParamsAddBoolean(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_READONLY,
|
|
readonly) < 0)
|
|
goto cleanup;
|
|
|
|
if (!virNetServerClientIsLocal(client)) {
|
|
if (virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_SOCKET_ADDR,
|
|
sock_addr) < 0)
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetSASLUserName(identity, &attr) < 0 ||
|
|
(attr &&
|
|
virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_SASL_USER_NAME,
|
|
attr) < 0))
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetX509DName(identity, &attr) < 0 ||
|
|
(attr &&
|
|
virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_X509_DISTINGUISHED_NAME,
|
|
attr) < 0))
|
|
goto cleanup;
|
|
} else {
|
|
pid_t pid;
|
|
uid_t uid;
|
|
gid_t gid;
|
|
if (virIdentityGetUNIXUserID(identity, &uid) < 0 ||
|
|
virTypedParamsAddInt(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_UNIX_USER_ID, uid) < 0)
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetUNIXUserName(identity, &attr) < 0 ||
|
|
virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_UNIX_USER_NAME,
|
|
attr) < 0)
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetUNIXGroupID(identity, &gid) < 0 ||
|
|
virTypedParamsAddInt(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_UNIX_GROUP_ID, gid) < 0)
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetUNIXGroupName(identity, &attr) < 0 ||
|
|
virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_UNIX_GROUP_NAME,
|
|
attr) < 0)
|
|
goto cleanup;
|
|
|
|
if (virIdentityGetUNIXProcessID(identity, &pid) < 0 ||
|
|
virTypedParamsAddInt(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_UNIX_PROCESS_ID, pid) < 0)
|
|
goto cleanup;
|
|
}
|
|
|
|
if (virIdentityGetSELinuxContext(identity, &attr) < 0 ||
|
|
(attr &&
|
|
virTypedParamsAddString(&tmpparams, nparams, &maxparams,
|
|
VIR_CLIENT_INFO_SELINUX_CONTEXT, attr) < 0))
|
|
goto cleanup;
|
|
|
|
*params = tmpparams;
|
|
tmpparams = NULL;
|
|
ret = 0;
|
|
|
|
cleanup:
|
|
virObjectUnref(identity);
|
|
return ret;
|
|
}
|