[libvirt] [PATCH v4 3/7] virnetdaemon: Store servers in a hash table
Erik Skultety
eskultet at redhat.com
Fri Feb 12 10:08:04 UTC 2016
Since the daemon can manage and add (at fresh start) multiple servers,
we also should be able to add them from a JSON state file in case of a
daemon restart, so post exec restart support for multiple servers is also
provided. Patch also updates virnetdaemontest accordingly.
Signed-off-by: Erik Skultety <eskultet at redhat.com>
Signed-off-by: Martin Kletzander <mkletzan at redhat.com>
---
daemon/libvirtd.c | 4 +-
src/locking/lock_daemon.c | 7 +-
src/logging/log_daemon.c | 3 +-
src/lxc/lxc_controller.c | 2 +-
src/rpc/virnetdaemon.c | 186 ++++++++++------
src/rpc/virnetdaemon.h | 7 +-
.../input-data-admin-server-names.json | 129 +++++++++++
.../virnetdaemondata/output-data-admin-nomdns.json | 8 +-
.../output-data-admin-server-names.json | 126 +++++++++++
.../virnetdaemondata/output-data-anon-clients.json | 6 +-
.../output-data-initial-nomdns.json | 6 +-
tests/virnetdaemondata/output-data-initial.json | 6 +-
.../output-data-no-keepalive-required.json | 242 +++++++++++----------
tests/virnetdaemontest.c | 63 +++---
14 files changed, 561 insertions(+), 234 deletions(-)
create mode 100644 tests/virnetdaemondata/input-data-admin-server-names.json
create mode 100644 tests/virnetdaemondata/output-data-admin-server-names.json
diff --git a/daemon/libvirtd.c b/daemon/libvirtd.c
index 250094b..a747553 100644
--- a/daemon/libvirtd.c
+++ b/daemon/libvirtd.c
@@ -1399,7 +1399,7 @@ int main(int argc, char **argv) {
}
if (!(dmn = virNetDaemonNew()) ||
- virNetDaemonAddServer(dmn, srv) < 0) {
+ virNetDaemonAddServer(dmn, "libvirtd", srv) < 0) {
ret = VIR_DAEMON_ERR_INIT;
goto cleanup;
}
@@ -1472,7 +1472,7 @@ int main(int argc, char **argv) {
goto cleanup;
}
- if (virNetDaemonAddServer(dmn, srvAdm) < 0) {
+ if (virNetDaemonAddServer(dmn, "admin", srvAdm) < 0) {
ret = VIR_DAEMON_ERR_INIT;
goto cleanup;
}
diff --git a/src/locking/lock_daemon.c b/src/locking/lock_daemon.c
index 23f52b5..cd70aa9 100644
--- a/src/locking/lock_daemon.c
+++ b/src/locking/lock_daemon.c
@@ -170,7 +170,7 @@ virLockDaemonNew(virLockDaemonConfigPtr config, bool privileged)
goto error;
if (!(lockd->dmn = virNetDaemonNew()) ||
- virNetDaemonAddServer(lockd->dmn, srv) < 0)
+ virNetDaemonAddServer(lockd->dmn, "virtlockd", srv) < 0)
goto error;
if (!(lockd->lockspaces = virHashCreate(VIR_LOCK_DAEMON_NUM_LOCKSPACES,
@@ -267,6 +267,7 @@ virLockDaemonNewPostExecRestart(virJSONValuePtr object, bool privileged)
goto error;
if (!(srv = virNetDaemonAddServerPostExec(lockd->dmn,
+ "virtlockd",
virLockDaemonClientNew,
virLockDaemonClientNewPostExecRestart,
virLockDaemonClientPreExecRestart,
@@ -1369,7 +1370,7 @@ int main(int argc, char **argv) {
goto cleanup;
}
- srv = virNetDaemonGetServer(lockDaemon->dmn, 0);
+ srv = virNetDaemonGetServer(lockDaemon->dmn, "virtlockd");
if ((rv = virLockDaemonSetupNetworkingSystemD(srv) < 0)) {
ret = VIR_LOCK_DAEMON_ERR_NETWORK;
goto cleanup;
@@ -1382,7 +1383,7 @@ int main(int argc, char **argv) {
goto cleanup;
}
} else if (rv == 1) {
- srv = virNetDaemonGetServer(lockDaemon->dmn, 0);
+ srv = virNetDaemonGetServer(lockDaemon->dmn, "virtlockd");
}
if (timeout != -1) {
diff --git a/src/logging/log_daemon.c b/src/logging/log_daemon.c
index 6da5876..07a03c2 100644
--- a/src/logging/log_daemon.c
+++ b/src/logging/log_daemon.c
@@ -160,7 +160,7 @@ virLogDaemonNew(virLogDaemonConfigPtr config, bool privileged)
goto error;
if (!(logd->dmn = virNetDaemonNew()) ||
- virNetDaemonAddServer(logd->dmn, logd->srv) < 0)
+ virNetDaemonAddServer(logd->dmn, "virtlogd", logd->srv) < 0)
goto error;
if (!(logd->handler = virLogHandlerNew(privileged,
@@ -209,6 +209,7 @@ virLogDaemonNewPostExecRestart(virJSONValuePtr object, bool privileged)
goto error;
if (!(logd->srv = virNetDaemonAddServerPostExec(logd->dmn,
+ "virtlogd",
virLogDaemonClientNew,
virLogDaemonClientNewPostExecRestart,
virLogDaemonClientPreExecRestart,
diff --git a/src/lxc/lxc_controller.c b/src/lxc/lxc_controller.c
index 438103a..76bef82 100644
--- a/src/lxc/lxc_controller.c
+++ b/src/lxc/lxc_controller.c
@@ -967,7 +967,7 @@ static int virLXCControllerSetupServer(virLXCControllerPtr ctrl)
goto error;
if (!(ctrl->daemon = virNetDaemonNew()) ||
- virNetDaemonAddServer(ctrl->daemon, srv) < 0)
+ virNetDaemonAddServer(ctrl->daemon, "LXC", srv) < 0)
goto error;
virNetDaemonUpdateServices(ctrl->daemon, true);
diff --git a/src/rpc/virnetdaemon.c b/src/rpc/virnetdaemon.c
index 18c962c..9210de4 100644
--- a/src/rpc/virnetdaemon.c
+++ b/src/rpc/virnetdaemon.c
@@ -37,6 +37,7 @@
#include "virnetserver.h"
#include "virnetservermdns.h"
#include "virdbus.h"
+#include "virhash.h"
#include "virstring.h"
#include "virsystemd.h"
@@ -69,8 +70,7 @@ struct _virNetDaemon {
int sigwrite;
int sigwatch;
- size_t nservers;
- virNetServerPtr *servers;
+ virHashTablePtr servers;
virJSONValuePtr srvObject;
bool quit;
@@ -102,9 +102,7 @@ virNetDaemonDispose(void *obj)
if (dmn->sigwatch > 0)
virEventRemoveHandle(dmn->sigwatch);
- for (i = 0; i < dmn->nservers; i++)
- virObjectUnref(dmn->servers[i]);
- VIR_FREE(dmn->servers);
+ virHashFree(dmn->servers);
virJSONValueFree(dmn->srvObject);
}
@@ -136,6 +134,9 @@ virNetDaemonNew(void)
if (!(dmn = virObjectLockableNew(virNetDaemonClass)))
return NULL;
+ if (!(dmn->servers = virHashCreate(5, virObjectFreeHashData)))
+ goto error;
+
dmn->sigwrite = dmn->sigread = -1;
dmn->privileged = geteuid() == 0;
dmn->autoShutdownInhibitFd = -1;
@@ -156,49 +157,34 @@ virNetDaemonNew(void)
int
-virNetDaemonAddServer(virNetDaemonPtr dmn, virNetServerPtr srv)
+virNetDaemonAddServer(virNetDaemonPtr dmn,
+ const char *serverName,
+ virNetServerPtr srv)
{
int ret = -1;
virObjectLock(dmn);
- if (VIR_APPEND_ELEMENT_COPY(dmn->servers, dmn->nservers, srv) < 0)
+ if (virHashAddEntry(dmn->servers, serverName, srv) < 0)
goto cleanup;
virObjectRef(srv);
- ret = dmn->nservers - 1;
+
+ ret = 0;
cleanup:
virObjectUnlock(dmn);
return ret;
}
-/*
- * 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]);
-}
-
virNetServerPtr
virNetDaemonGetServer(virNetDaemonPtr dmn,
- int subServerID)
+ const char *serverName)
{
virNetServerPtr srv = NULL;
virObjectLock(dmn);
- srv = virNetDaemonGetServerInternal(dmn, subServerID);
+ srv = virObjectRef(virHashLookup(dmn->servers, serverName));
virObjectUnlock(dmn);
return srv;
@@ -206,6 +192,7 @@ virNetDaemonGetServer(virNetDaemonPtr dmn,
virNetServerPtr
virNetDaemonAddServerPostExec(virNetDaemonPtr dmn,
+ const char *serverName,
virNetServerClientPrivNew clientPrivNew,
virNetServerClientPrivNewPostExecRestart clientPrivNewPostExecRestart,
virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
@@ -230,9 +217,23 @@ virNetDaemonAddServerPostExec(virNetDaemonPtr dmn,
virJSONValueFree(dmn->srvObject);
dmn->srvObject = NULL;
}
- } else {
+ } else if (virJSONValueObjectGetByType(dmn->srvObject,
+ "min_workers",
+ VIR_JSON_TYPE_NUMBER)) {
object = dmn->srvObject;
dmn->srvObject = NULL;
+ } else {
+ int ret = virJSONValueObjectRemoveKey(dmn->srvObject,
+ serverName,
+ &object);
+ if (ret != 1) {
+ if (ret == 0) {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("Server '%s' not found in JSON"), serverName);
+ }
+ goto error;
+ }
+
}
srv = virNetServerNewPostExecRestart(object,
@@ -242,7 +243,10 @@ virNetDaemonAddServerPostExec(virNetDaemonPtr dmn,
clientPrivFree,
clientPrivOpaque);
- if (!srv || VIR_APPEND_ELEMENT_COPY(dmn->servers, dmn->nservers, srv) < 0)
+ if (!srv)
+ goto error;
+
+ if (virHashAddEntry(dmn->servers, serverName, srv) < 0)
goto error;
virJSONValueFree(object);
@@ -283,29 +287,51 @@ virNetDaemonNewPostExecRestart(virJSONValuePtr object)
}
+static int
+daemonServerCompare(const virHashKeyValuePair *a, const virHashKeyValuePair *b)
+{
+ const char *as = a->key;
+ const char *bs = b->key;
+
+ return strcmp(as, bs);
+}
+
virJSONValuePtr
virNetDaemonPreExecRestart(virNetDaemonPtr dmn)
{
- virJSONValuePtr object, srvArray = NULL;
- size_t i;
+ size_t i = 0;
+ virJSONValuePtr object = NULL;
+ virJSONValuePtr srvObj = NULL;
+ virHashKeyValuePairPtr srvArray = NULL;
virObjectLock(dmn);
if (!(object = virJSONValueNewObject()))
goto error;
- if (!(srvArray = virJSONValueNewArray()) ||
- virJSONValueObjectAppend(object, "servers", srvArray) < 0)
+ if (!(srvObj = virJSONValueNewObject()))
goto error;
- for (i = 0; i < dmn->nservers; i++) {
- virJSONValuePtr srvJSON = NULL;
- srvJSON = virNetServerPreExecRestart(dmn->servers[i]);
+ if (virJSONValueObjectAppend(object, "servers", srvObj) < 0) {
+ virJSONValueFree(srvObj);
+ goto error;
+ }
+
+ if (!(srvArray = virHashGetItems(dmn->servers, daemonServerCompare)))
+ goto error;
+
+ for (i = 0; srvArray[i].key; i++) {
+ virNetServerPtr server = virHashLookup(dmn->servers, srvArray[i].key);
+ virJSONValuePtr srvJSON;
+ if (!server)
+ goto error;
+
+ srvJSON = virNetServerPreExecRestart(server);
if (!srvJSON)
goto error;
- if (virJSONValueArrayAppend(srvArray, srvJSON) < 0) {
+ if (virJSONValueObjectAppend(srvObj, srvArray[i].key, srvJSON) < 0) {
virJSONValueFree(srvJSON);
goto error;
}
@@ -316,8 +342,8 @@ virNetDaemonPreExecRestart(virNetDaemonPtr dmn)
return object;
error:
+ VIR_FREE(srvArray);
virJSONValueFree(object);
- virJSONValueFree(srvArray);
virObjectUnlock(dmn);
return NULL;
}
@@ -627,24 +653,53 @@ virNetDaemonAutoShutdownTimer(int timerid ATTRIBUTE_UNUSED,
virObjectUnlock(dmn);
}
+static int
+daemonServerUpdateServices(void *payload,
+ const void *key ATTRIBUTE_UNUSED,
+ void *opaque)
+{
+ bool *enable = opaque;
+ virNetServerPtr srv = payload;
+
+ virNetServerUpdateServices(srv, *enable);
+ return 0;
+}
+
void
virNetDaemonUpdateServices(virNetDaemonPtr dmn,
bool enabled)
{
- size_t i;
-
virObjectLock(dmn);
- for (i = 0; i < dmn->nservers; i++)
- virNetServerUpdateServices(dmn->servers[i], enabled);
+ virHashForEach(dmn->servers, daemonServerUpdateServices, &enabled);
virObjectUnlock(dmn);
}
+static int
+daemonServerRun(void *payload,
+ const void *key ATTRIBUTE_UNUSED,
+ void *opaque ATTRIBUTE_UNUSED)
+{
+ virNetServerPtr srv = payload;
+
+ return virNetServerStart(srv);
+};
+
+static int
+daemonServerProcessClients(void *payload,
+ const void *key ATTRIBUTE_UNUSED,
+ void *opaque ATTRIBUTE_UNUSED)
+{
+ virNetServerPtr srv = payload;
+
+ virNetServerProcessClients(srv);
+ return 0;
+}
+
void
virNetDaemonRun(virNetDaemonPtr dmn)
{
int timerid = -1;
bool timerActive = false;
- size_t i;
virObjectLock(dmn);
@@ -654,10 +709,8 @@ virNetDaemonRun(virNetDaemonPtr dmn)
goto cleanup;
}
- for (i = 0; i < dmn->nservers; i++) {
- if (virNetServerStart(dmn->servers[i]) < 0)
- goto cleanup;
- }
+ if (virHashForEach(dmn->servers, daemonServerRun, NULL) < 0)
+ goto cleanup;
dmn->quit = false;
@@ -705,8 +758,7 @@ virNetDaemonRun(virNetDaemonPtr dmn)
}
virObjectLock(dmn);
- for (i = 0; i < dmn->nservers; i++)
- virNetServerProcessClients(dmn->servers[i]);
+ virHashForEach(dmn->servers, daemonServerProcessClients, NULL);
}
cleanup:
@@ -725,32 +777,42 @@ virNetDaemonQuit(virNetDaemonPtr dmn)
virObjectUnlock(dmn);
}
+static int
+daemonServerClose(void *payload,
+ const void *key ATTRIBUTE_UNUSED,
+ void *opaque ATTRIBUTE_UNUSED)
+{
+ virNetServerPtr srv = payload;
+
+ virNetServerClose(srv);
+ return 0;
+}
void
virNetDaemonClose(virNetDaemonPtr dmn)
{
- size_t i;
-
if (!dmn)
return;
virObjectLock(dmn);
- for (i = 0; i < dmn->nservers; i++)
- virNetServerClose(dmn->servers[i]);
+ virHashForEach(dmn->servers, daemonServerClose, NULL);
virObjectUnlock(dmn);
}
-bool
-virNetDaemonHasClients(virNetDaemonPtr dmn)
+static int
+daemonServerHasClients(void *payload,
+ const void *key ATTRIBUTE_UNUSED,
+ void *opaque ATTRIBUTE_UNUSED)
{
- size_t i = 0;
+ virNetServerPtr srv = payload;
- for (i = 0; i < dmn->nservers; i++) {
- if (virNetServerHasClients(dmn->servers[i]))
- return true;
- }
+ return virNetServerHasClients(srv);
+}
- return false;
+bool
+virNetDaemonHasClients(virNetDaemonPtr dmn)
+{
+ return virHashForEach(dmn->servers, daemonServerHasClients, NULL) > 0;
}
diff --git a/src/rpc/virnetdaemon.h b/src/rpc/virnetdaemon.h
index bb32053..968708b 100644
--- a/src/rpc/virnetdaemon.h
+++ b/src/rpc/virnetdaemon.h
@@ -37,9 +37,12 @@
virNetDaemonPtr virNetDaemonNew(void);
-int virNetDaemonAddServer(virNetDaemonPtr dmn, virNetServerPtr);
+int virNetDaemonAddServer(virNetDaemonPtr dmn,
+ const char *serverName,
+ virNetServerPtr srv);
virNetServerPtr virNetDaemonAddServerPostExec(virNetDaemonPtr dmn,
+ const char *serverName,
virNetServerClientPrivNew clientPrivNew,
virNetServerClientPrivNewPostExecRestart clientPrivNewPostExecRestart,
virNetServerClientPrivPreExecRestart clientPrivPreExecRestart,
@@ -79,6 +82,6 @@ void virNetDaemonClose(virNetDaemonPtr dmn);
bool virNetDaemonHasClients(virNetDaemonPtr dmn);
virNetServerPtr virNetDaemonGetServer(virNetDaemonPtr dmn,
- int subServerID);
+ const char *serverName);
#endif /* __VIR_NET_DAEMON_H__ */
diff --git a/tests/virnetdaemondata/input-data-admin-server-names.json b/tests/virnetdaemondata/input-data-admin-server-names.json
new file mode 100644
index 0000000..94fba61
--- /dev/null
+++ b/tests/virnetdaemondata/input-data-admin-server-names.json
@@ -0,0 +1,129 @@
+{
+ "servers":
+ {
+ "testServer0":
+ {
+ "min_workers": 10,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "keepaliveRequired": true,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
+ ]
+ },
+ "testServer1":
+ {
+ "min_workers": 2,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "keepaliveRequired": true,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
+ ]
+ }
+ }
+}
diff --git a/tests/virnetdaemondata/output-data-admin-nomdns.json b/tests/virnetdaemondata/output-data-admin-nomdns.json
index a814aeb..8827c04 100644
--- a/tests/virnetdaemondata/output-data-admin-nomdns.json
+++ b/tests/virnetdaemondata/output-data-admin-nomdns.json
@@ -1,6 +1,6 @@
{
- "servers": [
- {
+ "servers": {
+ "testServer0": {
"min_workers": 10,
"max_workers": 50,
"priority_workers": 5,
@@ -61,7 +61,7 @@
}
]
},
- {
+ "testServer1": {
"min_workers": 2,
"max_workers": 50,
"priority_workers": 5,
@@ -122,5 +122,5 @@
}
]
}
- ]
+ }
}
diff --git a/tests/virnetdaemondata/output-data-admin-server-names.json b/tests/virnetdaemondata/output-data-admin-server-names.json
new file mode 100644
index 0000000..8827c04
--- /dev/null
+++ b/tests/virnetdaemondata/output-data-admin-server-names.json
@@ -0,0 +1,126 @@
+{
+ "servers": {
+ "testServer0": {
+ "min_workers": 10,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "max_anonymous_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
+ ]
+ },
+ "testServer1": {
+ "min_workers": 2,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "max_anonymous_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
+ ]
+ }
+ }
+}
diff --git a/tests/virnetdaemondata/output-data-anon-clients.json b/tests/virnetdaemondata/output-data-anon-clients.json
index 05fc0ae..df93e3b 100644
--- a/tests/virnetdaemondata/output-data-anon-clients.json
+++ b/tests/virnetdaemondata/output-data-anon-clients.json
@@ -1,6 +1,6 @@
{
- "servers": [
- {
+ "servers": {
+ "testServer0": {
"min_workers": 10,
"max_workers": 50,
"priority_workers": 5,
@@ -61,5 +61,5 @@
}
]
}
- ]
+ }
}
diff --git a/tests/virnetdaemondata/output-data-initial-nomdns.json b/tests/virnetdaemondata/output-data-initial-nomdns.json
index 400e47b..154962b 100644
--- a/tests/virnetdaemondata/output-data-initial-nomdns.json
+++ b/tests/virnetdaemondata/output-data-initial-nomdns.json
@@ -1,6 +1,6 @@
{
- "servers": [
- {
+ "servers": {
+ "testServer0": {
"min_workers": 10,
"max_workers": 50,
"priority_workers": 5,
@@ -61,5 +61,5 @@
}
]
}
- ]
+ }
}
diff --git a/tests/virnetdaemondata/output-data-initial.json b/tests/virnetdaemondata/output-data-initial.json
index e875cff..b7c27df 100644
--- a/tests/virnetdaemondata/output-data-initial.json
+++ b/tests/virnetdaemondata/output-data-initial.json
@@ -1,6 +1,6 @@
{
- "servers": [
- {
+ "servers": {
+ "testServer0": {
"min_workers": 10,
"max_workers": 50,
"priority_workers": 5,
@@ -62,5 +62,5 @@
}
]
}
- ]
+ }
}
diff --git a/tests/virnetdaemondata/output-data-no-keepalive-required.json b/tests/virnetdaemondata/output-data-no-keepalive-required.json
index df282ed..a8ba828 100644
--- a/tests/virnetdaemondata/output-data-no-keepalive-required.json
+++ b/tests/virnetdaemondata/output-data-no-keepalive-required.json
@@ -1,124 +1,126 @@
{
- "servers": [
- {
- "min_workers": 10,
- "max_workers": 50,
- "priority_workers": 5,
- "max_clients": 100,
- "keepaliveInterval": 120,
- "keepaliveCount": 5,
- "services": [
- {
- "auth": 0,
- "readonly": true,
- "nrequests_client_max": 2,
- "socks": [
- {
- "fd": 100,
- "errfd": -1,
- "pid": 0,
- "isClient": false
- }
+ "servers": {
+ "testServer0": {
+ "min_workers": 10,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
]
- },
- {
- "auth": 2,
- "readonly": false,
- "nrequests_client_max": 5,
- "socks": [
- {
- "fd": 101,
- "errfd": -1,
- "pid": 0,
- "isClient": false
- }
- ]
- }
- ],
- "clients": [
- {
- "auth": 1,
- "readonly": true,
- "nrequests_max": 15,
- "sock": {
- "fd": 102,
- "errfd": -1,
- "pid": -1,
- "isClient": true
- }
- },
- {
- "auth": 2,
- "readonly": true,
- "nrequests_max": 66,
- "sock": {
- "fd": 103,
- "errfd": -1,
- "pid": -1,
- "isClient": true
- }
- }
- ]
- },
- {
- "min_workers": 2,
- "max_workers": 50,
- "priority_workers": 5,
- "max_clients": 100,
- "keepaliveInterval": 120,
- "keepaliveCount": 5,
- "services": [
- {
- "auth": 0,
- "readonly": true,
- "nrequests_client_max": 2,
- "socks": [
- {
- "fd": 100,
- "errfd": -1,
- "pid": 0,
- "isClient": false
- }
- ]
- },
- {
- "auth": 2,
- "readonly": false,
- "nrequests_client_max": 5,
- "socks": [
- {
- "fd": 101,
- "errfd": -1,
- "pid": 0,
- "isClient": false
- }
- ]
- }
- ],
- "clients": [
- {
- "auth": 1,
- "readonly": true,
- "nrequests_max": 15,
- "sock": {
- "fd": 102,
- "errfd": -1,
- "pid": -1,
- "isClient": true
- }
- },
- {
- "auth": 2,
- "readonly": true,
- "nrequests_max": 66,
- "sock": {
- "fd": 103,
- "errfd": -1,
- "pid": -1,
- "isClient": true
- }
- }
- ]
+ },
+ "testServer1": {
+ {
+ "min_workers": 2,
+ "max_workers": 50,
+ "priority_workers": 5,
+ "max_clients": 100,
+ "keepaliveInterval": 120,
+ "keepaliveCount": 5,
+ "services": [
+ {
+ "auth": 0,
+ "readonly": true,
+ "nrequests_client_max": 2,
+ "socks": [
+ {
+ "fd": 100,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ },
+ {
+ "auth": 2,
+ "readonly": false,
+ "nrequests_client_max": 5,
+ "socks": [
+ {
+ "fd": 101,
+ "errfd": -1,
+ "pid": 0,
+ "isClient": false
+ }
+ ]
+ }
+ ],
+ "clients": [
+ {
+ "auth": 1,
+ "readonly": true,
+ "nrequests_max": 15,
+ "sock": {
+ "fd": 102,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ },
+ {
+ "auth": 2,
+ "readonly": true,
+ "nrequests_max": 66,
+ "sock": {
+ "fd": 103,
+ "errfd": -1,
+ "pid": -1,
+ "isClient": true
+ }
+ }
+ ]
+ }
+ }
}
- ]
}
diff --git a/tests/virnetdaemontest.c b/tests/virnetdaemontest.c
index e5d09a3..2f855fd 100644
--- a/tests/virnetdaemontest.c
+++ b/tests/virnetdaemontest.c
@@ -135,7 +135,7 @@ testCreateServer(const char *host, int family)
goto cleanup;
}
-static char *testGenerateJSON(void)
+static char *testGenerateJSON(const char *server_name)
{
virNetDaemonPtr dmn = NULL;
virNetServerPtr srv = NULL;
@@ -155,15 +155,14 @@ static char *testGenerateJSON(void)
if (!has_ipv4 && !has_ipv6)
return NULL;
- if (!(srv = testCreateServer(
- has_ipv4 ? "127.0.0.1" : "::1",
- has_ipv4 ? AF_INET : AF_INET6)))
+ if (!(srv = testCreateServer(has_ipv4 ? "127.0.0.1" : "::1",
+ has_ipv4 ? AF_INET : AF_INET6)))
goto cleanup;
if (!(dmn = virNetDaemonNew()))
goto cleanup;
- if (virNetDaemonAddServer(dmn, srv) < 0)
+ if (virNetDaemonAddServer(dmn, server_name, srv) < 0)
goto cleanup;
if (!(json = virNetDaemonPreExecRestart(dmn)))
@@ -186,6 +185,7 @@ static char *testGenerateJSON(void)
struct testExecRestartData {
const char *jsonfile;
+ const char **serverNames;
int nservers;
bool pass;
};
@@ -241,7 +241,7 @@ static int testExecRestart(const void *opaque)
goto cleanup;
for (i = 0; i < data->nservers; i++) {
- if (!(srv = virNetDaemonAddServerPostExec(dmn,
+ if (!(srv = virNetDaemonAddServerPostExec(dmn, data->serverNames[i],
NULL, NULL, NULL,
NULL, NULL)))
goto cleanup;
@@ -257,18 +257,18 @@ static int testExecRestart(const void *opaque)
if (virtTestCompareToFile(outjsonstr, outfile) < 0)
goto cleanup;
- if (!data->pass) {
- virReportError(VIR_ERR_INTERNAL_ERROR, "%s", "Test should've failed");
- goto cleanup;
- }
-
ret = 0;
cleanup:
if (ret < 0) {
- if (!data->pass)
+ if (!data->pass) {
+ VIR_TEST_DEBUG("Got expected error: %s\n",
+ virGetLastErrorMessage());
+ virResetLastError();
ret = 0;
- else
- virDispatchError(NULL);
+ }
+ } else if (!data->pass) {
+ VIR_TEST_DEBUG("Test should have failed\n");
+ ret = -1;
}
VIR_FREE(infile);
VIR_FREE(outfile);
@@ -289,6 +289,7 @@ static int
mymain(void)
{
int ret = 0;
+ const char *server_names[] = { "testServer0", "testServer1" };
if (virInitialize() < 0 ||
virEventRegisterDefaultImpl() < 0) {
@@ -302,7 +303,7 @@ mymain(void)
* numbers with 100, 101, 102, 103.
*/
if (getenv("VIR_GENERATE_JSON")) {
- char *json = testGenerateJSON();
+ char *json = testGenerateJSON(server_names[0]);
if (!json)
return EXIT_FAILURE;
@@ -311,26 +312,28 @@ mymain(void)
return ret;
}
-# define EXEC_RESTART_TEST_FULL(file, servers, pass) \
- do { \
- struct testExecRestartData data = { \
- file, servers, pass \
- }; \
- if (virtTestRun("ExecRestart " file, \
- testExecRestart, &data) < 0) \
- ret = -1; \
+# define EXEC_RESTART_TEST_FULL(file, nservers, pass) \
+ do { \
+ struct testExecRestartData data = { \
+ file, server_names, nservers, pass \
+ }; \
+ if (virtTestRun("ExecRestart " file, \
+ testExecRestart, &data) < 0) \
+ ret = -1; \
} while (0)
-# define EXEC_RESTART_TEST(file) EXEC_RESTART_TEST_FULL(file, 1, true)
+# define EXEC_RESTART_TEST(file, N) EXEC_RESTART_TEST_FULL(file, N, true)
+# define EXEC_RESTART_TEST_FAIL(file, N) EXEC_RESTART_TEST_FULL(file, N, false)
+
# ifdef WITH_AVAHI
- EXEC_RESTART_TEST("initial");
+ EXEC_RESTART_TEST("initial", 1);
# endif
- EXEC_RESTART_TEST("initial-nomdns");
- EXEC_RESTART_TEST("anon-clients");
-
- EXEC_RESTART_TEST_FULL("anon-clients", 2, false);
- EXEC_RESTART_TEST_FULL("admin-nomdns", 2, true);
+ EXEC_RESTART_TEST("initial-nomdns", 1);
+ EXEC_RESTART_TEST("anon-clients", 1);
+ EXEC_RESTART_TEST("admin-nomdns", 2);
+ EXEC_RESTART_TEST("admin-server-names", 2);
+ EXEC_RESTART_TEST_FAIL("anon-clients", 2);
return ret == 0 ? EXIT_SUCCESS : EXIT_FAILURE;
}
--
2.4.3
More information about the libvir-list
mailing list