[rabbitmq-discuss] Fwd: RabbitMQ Memory Leak

Tue May 15 14:48:16 BST 2012

That should've gone to the whole list:

---------- Forwarded message ----------
From: Alan Antonuk <alan.antonuk at gmail.com>
Date: Tue, May 15, 2012 at 9:43 AM
Subject: Re: [rabbitmq-discuss] RabbitMQ Memory Leak
To: Rakesh <rmadhwan at gmail.com>

After stewing about this a bit more, I suspect you're never calling
amqp_maybe_release_buffers(), which is what releases memory allocated when
receiving frames from the broker.  You should do this after you have used
the data in the amqp_frame_t's you get from amqp_simple_wait_frame().

amqp_destroy_connection() should also release all memory associated with a
amqp_connection_state_t object

If the above is not helpful, could you post the minimum code required to
reproduce the memory leaks you're seeing.

-Alan

On Fri, May 11, 2012 at 8:51 AM, Rakesh <rmadhwan at gmail.com> wrote:

> We are using RabbitMQ in our project and while running PurifyPlus on
> the application, I found memory leaks in librabbitmq.
> How do I submit the fixes for this?
>
>
> MLK: 47579136 bytes leaked in 363 blocks
>  * This memory was allocated from:
>        calloc         [rtlib.o]
>        amqp_pool_alloc [amqp_mem.c:140]
>        amqp_handle_input [amqp_connection.c:197]
>        wait_frame_inner [amqp_socket.c:168]
>        amqp_simple_rpc [amqp_socket.c:286]
>        amqp_simple_rpc_decoded [amqp_socket.c:353]
>        amqp_basic_qos [amqp_framing.c:2006]
>        CRabbitQueueReader::readMessage(int&) [RabbitQueueReader.cpp:204]
>  * Block of 131072 bytes (363 times); last block at 0x18269dc8
>
> MLK: 262144 bytes leaked in 2 blocks
>  * This memory was allocated from:
>        calloc         [rtlib.o]
>        amqp_pool_alloc [amqp_mem.c:140]
>        amqp_decode_method [amqp_framing.c:187]
>        amqp_handle_input [amqp_connection.c:272]
>        wait_frame_inner [amqp_socket.c:168]
>        amqp_simple_wait_method [amqp_socket.c:218]
>        amqp_login     [amqp_socket.c:383]
>        CRabbitQueueWriter::openConnection() [RabbitQueueWriter.cpp:78]
>  * Block of 131072 bytes (2 times); last block at 0xa135df8
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120515/cf4ca3a4/attachment.htm>