]> xenbits.xensource.com Git - libvirt.git/commitdiff
rpc: Add virNetMessageClearPayload
authorCole Robinson <crobinso@redhat.com>
Wed, 27 Apr 2016 21:47:34 +0000 (17:47 -0400)
committerCole Robinson <crobinso@redhat.com>
Thu, 5 May 2016 18:28:19 +0000 (14:28 -0400)
Handles freeing the buffer and fds, but not the message details.
Use it to drop some duplicate code.

src/rpc/virnetmessage.c

index 5c57128c13ab1e3944c35e180ef9a430f9d78b09..3df502ae88b12caab6865252e22434a7a8b3b23d 100644 (file)
@@ -49,17 +49,25 @@ virNetMessagePtr virNetMessageNew(bool tracked)
 }
 
 
-void virNetMessageClear(virNetMessagePtr msg)
+static void
+virNetMessageClearPayload(virNetMessagePtr msg)
 {
-    bool tracked = msg->tracked;
     size_t i;
 
-    VIR_DEBUG("msg=%p nfds=%zu", msg, msg->nfds);
-
     for (i = 0; i < msg->nfds; i++)
         VIR_FORCE_CLOSE(msg->fds[i]);
     VIR_FREE(msg->fds);
     VIR_FREE(msg->buffer);
+}
+
+
+void virNetMessageClear(virNetMessagePtr msg)
+{
+    bool tracked = msg->tracked;
+
+    VIR_DEBUG("msg=%p nfds=%zu", msg, msg->nfds);
+
+    virNetMessageClearPayload(msg);
     memset(msg, 0, sizeof(*msg));
     msg->tracked = tracked;
 }
@@ -67,7 +75,6 @@ void virNetMessageClear(virNetMessagePtr msg)
 
 void virNetMessageFree(virNetMessagePtr msg)
 {
-    size_t i;
     if (!msg)
         return;
 
@@ -76,10 +83,7 @@ void virNetMessageFree(virNetMessagePtr msg)
     if (msg->cb)
         msg->cb(msg, msg->opaque);
 
-    for (i = 0; i < msg->nfds; i++)
-        VIR_FORCE_CLOSE(msg->fds[i]);
-    VIR_FREE(msg->buffer);
-    VIR_FREE(msg->fds);
+    virNetMessageClearPayload(msg);
     VIR_FREE(msg);
 }