提交 b464fd7e 编写于 作者: M Michal Privoznik

test_driver: Drop testDriverLock() from almost everywhere

Well, if 'everywhere' is defined as that part of the driver code
that serves virNetwork* APIs. Again, we lower layers already have
their locks, so there's no point doing big lock.
Signed-off-by: NMichal Privoznik <mprivozn@redhat.com>
上级 af338d5f
...@@ -3495,10 +3495,7 @@ static virNetworkPtr testNetworkLookupByUUID(virConnectPtr conn, ...@@ -3495,10 +3495,7 @@ static virNetworkPtr testNetworkLookupByUUID(virConnectPtr conn,
virNetworkObjPtr net; virNetworkObjPtr net;
virNetworkPtr ret = NULL; virNetworkPtr ret = NULL;
testDriverLock(privconn);
net = virNetworkObjFindByUUID(privconn->networks, uuid); net = virNetworkObjFindByUUID(privconn->networks, uuid);
testDriverUnlock(privconn);
if (net == NULL) { if (net == NULL) {
virReportError(VIR_ERR_NO_NETWORK, NULL); virReportError(VIR_ERR_NO_NETWORK, NULL);
goto cleanup; goto cleanup;
...@@ -3518,10 +3515,7 @@ static virNetworkPtr testNetworkLookupByName(virConnectPtr conn, ...@@ -3518,10 +3515,7 @@ static virNetworkPtr testNetworkLookupByName(virConnectPtr conn,
virNetworkObjPtr net; virNetworkObjPtr net;
virNetworkPtr ret = NULL; virNetworkPtr ret = NULL;
testDriverLock(privconn);
net = virNetworkObjFindByName(privconn->networks, name); net = virNetworkObjFindByName(privconn->networks, name);
testDriverUnlock(privconn);
if (net == NULL) { if (net == NULL) {
virReportError(VIR_ERR_NO_NETWORK, NULL); virReportError(VIR_ERR_NO_NETWORK, NULL);
goto cleanup; goto cleanup;
...@@ -3540,11 +3534,8 @@ static int testConnectNumOfNetworks(virConnectPtr conn) ...@@ -3540,11 +3534,8 @@ static int testConnectNumOfNetworks(virConnectPtr conn)
testConnPtr privconn = conn->privateData; testConnPtr privconn = conn->privateData;
int numActive; int numActive;
testDriverLock(privconn);
numActive = virNetworkObjListNumOfNetworks(privconn->networks, numActive = virNetworkObjListNumOfNetworks(privconn->networks,
true, NULL, conn); true, NULL, conn);
testDriverUnlock(privconn);
return numActive; return numActive;
} }
...@@ -3552,11 +3543,8 @@ static int testConnectListNetworks(virConnectPtr conn, char **const names, int n ...@@ -3552,11 +3543,8 @@ static int testConnectListNetworks(virConnectPtr conn, char **const names, int n
testConnPtr privconn = conn->privateData; testConnPtr privconn = conn->privateData;
int n; int n;
testDriverLock(privconn);
n = virNetworkObjListGetNames(privconn->networks, n = virNetworkObjListGetNames(privconn->networks,
true, names, nnames, NULL, conn); true, names, nnames, NULL, conn);
testDriverUnlock(privconn);
return n; return n;
} }
...@@ -3565,11 +3553,8 @@ static int testConnectNumOfDefinedNetworks(virConnectPtr conn) ...@@ -3565,11 +3553,8 @@ static int testConnectNumOfDefinedNetworks(virConnectPtr conn)
testConnPtr privconn = conn->privateData; testConnPtr privconn = conn->privateData;
int numInactive; int numInactive;
testDriverLock(privconn);
numInactive = virNetworkObjListNumOfNetworks(privconn->networks, numInactive = virNetworkObjListNumOfNetworks(privconn->networks,
false, NULL, conn); false, NULL, conn);
testDriverUnlock(privconn);
return numInactive; return numInactive;
} }
...@@ -3577,11 +3562,8 @@ static int testConnectListDefinedNetworks(virConnectPtr conn, char **const names ...@@ -3577,11 +3562,8 @@ static int testConnectListDefinedNetworks(virConnectPtr conn, char **const names
testConnPtr privconn = conn->privateData; testConnPtr privconn = conn->privateData;
int n; int n;
testDriverLock(privconn);
n = virNetworkObjListGetNames(privconn->networks, n = virNetworkObjListGetNames(privconn->networks,
false, names, nnames, NULL, conn); false, names, nnames, NULL, conn);
testDriverUnlock(privconn);
return n; return n;
} }
...@@ -3591,15 +3573,10 @@ testConnectListAllNetworks(virConnectPtr conn, ...@@ -3591,15 +3573,10 @@ testConnectListAllNetworks(virConnectPtr conn,
unsigned int flags) unsigned int flags)
{ {
testConnPtr privconn = conn->privateData; testConnPtr privconn = conn->privateData;
int ret = -1;
virCheckFlags(VIR_CONNECT_LIST_NETWORKS_FILTERS_ALL, -1); virCheckFlags(VIR_CONNECT_LIST_NETWORKS_FILTERS_ALL, -1);
testDriverLock(privconn); return virNetworkObjListExport(conn, privconn->networks, nets, NULL, flags);
ret = virNetworkObjListExport(conn, privconn->networks, nets, NULL, flags);
testDriverUnlock(privconn);
return ret;
} }
static int testNetworkIsActive(virNetworkPtr net) static int testNetworkIsActive(virNetworkPtr net)
...@@ -3608,9 +3585,7 @@ static int testNetworkIsActive(virNetworkPtr net) ...@@ -3608,9 +3585,7 @@ static int testNetworkIsActive(virNetworkPtr net)
virNetworkObjPtr obj; virNetworkObjPtr obj;
int ret = -1; int ret = -1;
testDriverLock(privconn);
obj = virNetworkObjFindByUUID(privconn->networks, net->uuid); obj = virNetworkObjFindByUUID(privconn->networks, net->uuid);
testDriverUnlock(privconn);
if (!obj) { if (!obj) {
virReportError(VIR_ERR_NO_NETWORK, NULL); virReportError(VIR_ERR_NO_NETWORK, NULL);
goto cleanup; goto cleanup;
...@@ -3628,9 +3603,7 @@ static int testNetworkIsPersistent(virNetworkPtr net) ...@@ -3628,9 +3603,7 @@ static int testNetworkIsPersistent(virNetworkPtr net)
virNetworkObjPtr obj; virNetworkObjPtr obj;
int ret = -1; int ret = -1;
testDriverLock(privconn);
obj = virNetworkObjFindByUUID(privconn->networks, net->uuid); obj = virNetworkObjFindByUUID(privconn->networks, net->uuid);
testDriverUnlock(privconn);
if (!obj) { if (!obj) {
virReportError(VIR_ERR_NO_NETWORK, NULL); virReportError(VIR_ERR_NO_NETWORK, NULL);
goto cleanup; goto cleanup;
...@@ -3651,7 +3624,6 @@ static virNetworkPtr testNetworkCreateXML(virConnectPtr conn, const char *xml) ...@@ -3651,7 +3624,6 @@ static virNetworkPtr testNetworkCreateXML(virConnectPtr conn, const char *xml)
virNetworkPtr ret = NULL; virNetworkPtr ret = NULL;
virObjectEventPtr event = NULL; virObjectEventPtr event = NULL;
testDriverLock(privconn);
if ((def = virNetworkDefParseString(xml)) == NULL) if ((def = virNetworkDefParseString(xml)) == NULL)
goto cleanup; goto cleanup;
...@@ -3671,7 +3643,6 @@ static virNetworkPtr testNetworkCreateXML(virConnectPtr conn, const char *xml) ...@@ -3671,7 +3643,6 @@ static virNetworkPtr testNetworkCreateXML(virConnectPtr conn, const char *xml)
if (event) if (event)
testObjectEventQueue(privconn, event); testObjectEventQueue(privconn, event);
virNetworkObjEndAPI(&net); virNetworkObjEndAPI(&net);
testDriverUnlock(privconn);
return ret; return ret;
} }
...@@ -3684,7 +3655,6 @@ virNetworkPtr testNetworkDefineXML(virConnectPtr conn, const char *xml) ...@@ -3684,7 +3655,6 @@ virNetworkPtr testNetworkDefineXML(virConnectPtr conn, const char *xml)
virNetworkPtr ret = NULL; virNetworkPtr ret = NULL;
virObjectEventPtr event = NULL; virObjectEventPtr event = NULL;
testDriverLock(privconn);
if ((def = virNetworkDefParseString(xml)) == NULL) if ((def = virNetworkDefParseString(xml)) == NULL)
goto cleanup; goto cleanup;
...@@ -3703,7 +3673,6 @@ virNetworkPtr testNetworkDefineXML(virConnectPtr conn, const char *xml) ...@@ -3703,7 +3673,6 @@ virNetworkPtr testNetworkDefineXML(virConnectPtr conn, const char *xml)
if (event) if (event)
testObjectEventQueue(privconn, event); testObjectEventQueue(privconn, event);
virNetworkObjEndAPI(&net); virNetworkObjEndAPI(&net);
testDriverUnlock(privconn);
return ret; return ret;
} }
...@@ -3714,7 +3683,6 @@ static int testNetworkUndefine(virNetworkPtr network) ...@@ -3714,7 +3683,6 @@ static int testNetworkUndefine(virNetworkPtr network)
int ret = -1; int ret = -1;
virObjectEventPtr event = NULL; virObjectEventPtr event = NULL;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
if (privnet == NULL) { if (privnet == NULL) {
...@@ -3739,7 +3707,6 @@ static int testNetworkUndefine(virNetworkPtr network) ...@@ -3739,7 +3707,6 @@ static int testNetworkUndefine(virNetworkPtr network)
if (event) if (event)
testObjectEventQueue(privconn, event); testObjectEventQueue(privconn, event);
virNetworkObjEndAPI(&privnet); virNetworkObjEndAPI(&privnet);
testDriverUnlock(privconn);
return ret; return ret;
} }
...@@ -3759,8 +3726,6 @@ testNetworkUpdate(virNetworkPtr net, ...@@ -3759,8 +3726,6 @@ testNetworkUpdate(virNetworkPtr net,
VIR_NETWORK_UPDATE_AFFECT_CONFIG, VIR_NETWORK_UPDATE_AFFECT_CONFIG,
-1); -1);
testDriverLock(privconn);
network = virNetworkObjFindByUUID(privconn->networks, net->uuid); network = virNetworkObjFindByUUID(privconn->networks, net->uuid);
if (!network) { if (!network) {
virReportError(VIR_ERR_NO_NETWORK, virReportError(VIR_ERR_NO_NETWORK,
...@@ -3788,7 +3753,6 @@ testNetworkUpdate(virNetworkPtr net, ...@@ -3788,7 +3753,6 @@ testNetworkUpdate(virNetworkPtr net,
ret = 0; ret = 0;
cleanup: cleanup:
virNetworkObjEndAPI(&network); virNetworkObjEndAPI(&network);
testDriverUnlock(privconn);
return ret; return ret;
} }
...@@ -3799,10 +3763,7 @@ static int testNetworkCreate(virNetworkPtr network) ...@@ -3799,10 +3763,7 @@ static int testNetworkCreate(virNetworkPtr network)
int ret = -1; int ret = -1;
virObjectEventPtr event = NULL; virObjectEventPtr event = NULL;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
testDriverUnlock(privconn);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
...@@ -3834,9 +3795,7 @@ static int testNetworkDestroy(virNetworkPtr network) ...@@ -3834,9 +3795,7 @@ static int testNetworkDestroy(virNetworkPtr network)
int ret = -1; int ret = -1;
virObjectEventPtr event = NULL; virObjectEventPtr event = NULL;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
...@@ -3855,7 +3814,6 @@ static int testNetworkDestroy(virNetworkPtr network) ...@@ -3855,7 +3814,6 @@ static int testNetworkDestroy(virNetworkPtr network)
if (event) if (event)
testObjectEventQueue(privconn, event); testObjectEventQueue(privconn, event);
virNetworkObjEndAPI(&privnet); virNetworkObjEndAPI(&privnet);
testDriverUnlock(privconn);
return ret; return ret;
} }
...@@ -3868,10 +3826,7 @@ static char *testNetworkGetXMLDesc(virNetworkPtr network, ...@@ -3868,10 +3826,7 @@ static char *testNetworkGetXMLDesc(virNetworkPtr network,
virCheckFlags(0, NULL); virCheckFlags(0, NULL);
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
testDriverUnlock(privconn);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
...@@ -3889,10 +3844,7 @@ static char *testNetworkGetBridgeName(virNetworkPtr network) { ...@@ -3889,10 +3844,7 @@ static char *testNetworkGetBridgeName(virNetworkPtr network) {
char *bridge = NULL; char *bridge = NULL;
virNetworkObjPtr privnet; virNetworkObjPtr privnet;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
testDriverUnlock(privconn);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
...@@ -3919,10 +3871,7 @@ static int testNetworkGetAutostart(virNetworkPtr network, ...@@ -3919,10 +3871,7 @@ static int testNetworkGetAutostart(virNetworkPtr network,
virNetworkObjPtr privnet; virNetworkObjPtr privnet;
int ret = -1; int ret = -1;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
testDriverUnlock(privconn);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
...@@ -3943,10 +3892,7 @@ static int testNetworkSetAutostart(virNetworkPtr network, ...@@ -3943,10 +3892,7 @@ static int testNetworkSetAutostart(virNetworkPtr network,
virNetworkObjPtr privnet; virNetworkObjPtr privnet;
int ret = -1; int ret = -1;
testDriverLock(privconn);
privnet = virNetworkObjFindByName(privconn->networks, network->name); privnet = virNetworkObjFindByName(privconn->networks, network->name);
testDriverUnlock(privconn);
if (privnet == NULL) { if (privnet == NULL) {
virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__); virReportError(VIR_ERR_INVALID_ARG, __FUNCTION__);
goto cleanup; goto cleanup;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册