diff options
Diffstat (limited to 'rpc/rpc-transport/socket')
| -rw-r--r-- | rpc/rpc-transport/socket/src/socket.c | 9 |
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)); |