summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--rpc/rpc-transport/socket/src/socket.c9
1 files changed, 9 insertions, 0 deletions
diff --git a/rpc/rpc-transport/socket/src/socket.c b/rpc/rpc-transport/socket/src/socket.c
index da9a6d64b6c..6d2d584d111 100644
--- a/rpc/rpc-transport/socket/src/socket.c
+++ b/rpc/rpc-transport/socket/src/socket.c
@@ -396,6 +396,10 @@ __socket_reset (rpc_transport_t *this)
iobuf_unref (priv->incoming.iobuf);
}
+ if (priv->incoming.request_info != NULL) {
+ GF_FREE (priv->incoming.request_info);
+ }
+
memset (&priv->incoming, 0, sizeof (priv->incoming));
event_unregister (this->ctx->event_pool, priv->sock, priv->idx);
@@ -1313,6 +1317,11 @@ void __socket_reset_priv (socket_private_t *priv)
iobuf_unref (priv->incoming.iobuf);
}
+ if (priv->incoming.request_info != NULL) {
+ GF_FREE (priv->incoming.request_info);
+ priv->incoming.request_info = NULL;
+ }
+
memset (&priv->incoming.payload_vector, 0,
sizeof (priv->incoming.payload_vector));