activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Martin Carpella (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQCPP-286) Memory leak when adding connection.sendTimeout=3000 to a failover transport
Date Fri, 12 Feb 2010 13:03:36 GMT
Memory leak when adding connection.sendTimeout=3000 to a failover transport
---------------------------------------------------------------------------

                 Key: AMQCPP-286
                 URL: https://issues.apache.org/activemq/browse/AMQCPP-286
             Project: ActiveMQ C++ Client
          Issue Type: Bug
          Components: Transports
    Affects Versions: 3.1
         Environment: Ubuntu 9.10 with self-compiled ActiveMQ-CPP 3.1.0
            Reporter: Martin Carpella
            Assignee: Timothy Bish


When adding a connection.sendTimeout to a failover transport, a memory leak will occur. 

In the sample program provided on the homepage, the following broker caused the problem:
std::string brokerURI = "failover://(tcp://localhost:61616)?connection.sendTimeout=3000";

Valgrind reports the following losses (only parts with "definitely lost" included):
==20454== 800 bytes in 100 blocks are definitely lost in loss record 26 of 39
==20454==    at 0x4025390: operator new(unsigned int) (vg_replace_malloc.c:214)
==20454==    by 0x4317196: activemq::core::ActiveMQSession::send(cms::Message*, activemq::core::ActiveMQProducer*,
activemq::util::Usage*) (Pointer.h:45)
==20454==    by 0x430BBBE: activemq::core::ActiveMQProducer::send(cms::Destination const*,
cms::Message*, int, int, long long) (ActiveMQProducer.cpp:197)
==20454==    by 0x430A512: activemq::core::ActiveMQProducer::send(cms::Message*, int, int,
long long) (ActiveMQProducer.cpp:118)
==20454==    by 0x8049CB2: SimpleProducer::run() (main.cpp:139)
==20454==    by 0x80492FE: main (main.cpp:264)


==20454== 86,887 (35,600 direct, 51,287 indirect) bytes in 100 blocks are definitely lost
in loss record 39 of 39
==20454==    at 0x4025390: operator new(unsigned int) (vg_replace_malloc.c:214)
==20454==    by 0x4281245: activemq::commands::ActiveMQTextMessage::cloneDataStructure() const
(ActiveMQTextMessage.cpp:54)
==20454==    by 0x42840A0: covariant return thunk to activemq::commands::ActiveMQTextMessage::cloneDataStructure()
const (ActiveMQTextMessage.cpp:189)
==20454==    by 0x4317188: activemq::core::ActiveMQSession::send(cms::Message*, activemq::core::ActiveMQProducer*,
activemq::util::Usage*) (ActiveMQSession.cpp:708)
==20454==    by 0x430BBBE: activemq::core::ActiveMQProducer::send(cms::Destination const*,
cms::Message*, int, int, long long) (ActiveMQProducer.cpp:197)
==20454==    by 0x430A512: activemq::core::ActiveMQProducer::send(cms::Message*, int, int,
long long) (ActiveMQProducer.cpp:118)
==20454==    by 0x8049CB2: SimpleProducer::run() (main.cpp:139)
==20454==    by 0x80492FE: main (main.cpp:264)

Using the URI
std::string brokerURI = "failover://(tcp://localhost:61616)";
doesn't produce any "definitly lost" or "indirectly lost" records.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message