]> xenbits.xensource.com Git - libvirt.git/commitdiff
remote: push check for conn down into remoteClientFreePrivateCallbacks
authorDaniel P. Berrangé <berrange@redhat.com>
Thu, 5 Apr 2018 10:40:55 +0000 (11:40 +0100)
committerDaniel P. Berrangé <berrange@redhat.com>
Mon, 9 Apr 2018 14:24:18 +0000 (15:24 +0100)
There will shortly be many connection objects, so we should not assume a
single check against priv->conn is sufficient.

Reviewed-by: John Ferlan <jferlan@redhat.com>
Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
src/remote/remote_daemon_dispatch.c

index 121d114ae380cb65e1455d005041459f490d2187..853e63901b82d6799c7ac70dd922f0234a8bd78e 100644 (file)
@@ -1673,6 +1673,11 @@ void remoteRelayConnectionClosedEvent(virConnectPtr conn ATTRIBUTE_UNUSED, int r
 #define DEREG_CB(conn, eventCallbacks, neventCallbacks, deregFcn, name) \
     do { \
         size_t i; \
+        if (neventCallbacks && !conn) { \
+            VIR_WARN("Have %zu %s event callbacks but no connection", \
+                     neventCallbacks, name); \
+            break; \
+        } \
         for (i = 0; i < neventCallbacks; i++) { \
             int callbackID = eventCallbacks[i]->callbackID; \
             if (callbackID < 0) { \
@@ -1715,7 +1720,7 @@ remoteClientFreePrivateCallbacks(struct daemonClientPrivate *priv)
              priv->nqemuEventCallbacks,
              virConnectDomainQemuMonitorEventDeregister, "qemu monitor");
 
-    if (priv->closeRegistered) {
+    if (priv->closeRegistered && priv->conn) {
         if (virConnectUnregisterCloseCallback(priv->conn,
                                               remoteRelayConnectionClosedEvent) < 0)
             VIR_WARN("unexpected close callback event deregister failure");
@@ -1751,9 +1756,7 @@ static void remoteClientCloseFunc(virNetServerClientPtr client)
 
     daemonRemoveAllClientStreams(priv->streams);
 
-    /* Deregister event delivery callback */
-    if (priv->conn)
-        remoteClientFreePrivateCallbacks(priv);
+    remoteClientFreePrivateCallbacks(priv);
 }