You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by et3w503 <et...@yahoo.com> on 2011/08/04 10:21:04 UTC
Memory leak in QPID C++ Broker
Dear all:
I found a memory leak issue in QPID C++ broker using valgrind.
My qpidd broker is the rpm version from Redhat ftp.
ftp://ftp.redhat.com/pub/redhat/linux/enterprise/5Server/en/RHEMRG/SRPMS/qpidc-0.5.752581-34.el5.src.rpm
==4485== Memcheck, a memory error detector
==4485== Copyright (C) 2002-2009, and GNU GPL'd, by Julian Seward et al.
==4485== Using Valgrind-3.5.0 and LibVEX; rerun with -h for copyright info
==4485== Command: /usr/sbin/qpidd --pid-dir /var/run/qpidd --data-dir
/var/lib/qpidd --worker-threads 4 --max-connections 10000 -w 300
--num-jfiles 64 --jfile-size-pgs 192 --default-queue-limit 419430400
--acl-file /var/lib/qpidd/qpidd.acl
==4485==
==4485==
==4485== HEAP SUMMARY:
==4485== in use at exit: 5,788 bytes in 31 blocks
==4485== total heap usage: 4,973 allocs, 4,942 frees, 249,726 bytes
allocated
==4485==
==4485== LEAK SUMMARY:
==4485== definitely lost: 0 bytes in 0 blocks
==4485== indirectly lost: 0 bytes in 0 blocks
==4485== possibly lost: 0 bytes in 0 blocks
==4485== still reachable: 5,788 bytes in 31 blocks
==4485== suppressed: 0 bytes in 0 blocks
==4485== Reachable blocks (those to which a pointer was found) are not
shown.
==4485== To see them, rerun with: --leak-check=full --show-reachable=yes
==4485==
==4485== For counts of detected and suppressed errors, rerun with: -v
==4485== ERROR SUMMARY: 0 errors from 0 contexts (suppressed: 53 from 13)
==4485==
==4485== HEAP SUMMARY:
==4485== in use at exit: 14,862,010 bytes in 142,226 blocks
==4485== total heap usage: 472,436 allocs, 330,210 frees, 108,966,602
bytes allocated
==4485==
==4485== 2 bytes in 1 blocks are possibly lost in loss record 1 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44A6A1D: std::vector<unsigned short,
std::allocator<unsigned short>
>::_M_insert_aux(__gnu_cxx::__normal_iterator<unsigned short*,
std::vector<unsigned short, std::allocator<unsigned short> > >, unsigned
short const&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44C5036:
mrg::journal::jinf::get_normalized_pfid_list(std::vector<unsigned short,
std::allocator<unsigned short> >&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0E11:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 16 bytes in 1 blocks are possibly lost in loss record 13 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x60227D: qpid::broker::QueueRegistry::declare(std::string
const&, bool, bool, qpid::broker::OwnershipToken const*) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58219C:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 19 bytes in 1 blocks are possibly lost in loss record 33 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21CF34: ??? (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21D146: std::basic_string<char,
std::char_traits<char>, std::allocator<char> >::basic_string(char
const*, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x5F9999: ??? (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x669B45: ??? (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5113C4: ??? (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0xA593F2: call_init (in /lib/ld-2.5.so)
==4485== by 0xA59502: _dl_init (in /lib/ld-2.5.so)
==4485== by 0xA4B84E: ??? (in /lib/ld-2.5.so)
==4485==
==4485== 23 bytes in 1 blocks are possibly lost in loss record 37 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x576B81:
qpid::broker::Exchange::decode(qpid::broker::ExchangeRegistry&,
qpid::framing::Buffer&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604ABF:
qpid::broker::RecoveryManagerImpl::recoverExchange(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44659CD:
mrg::msgstore::MessageStoreImpl::recoverExchanges(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableExchange>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableExchange> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483079:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 24 bytes in 1 blocks are possibly lost in loss record 38 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21CF34: ??? (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21D146: std::basic_string<char,
std::char_traits<char>, std::allocator<char> >::basic_string(char
const*, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x447746E:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 24 bytes in 1 blocks are possibly lost in loss record 39 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x446ED91:
mrg::msgstore::MessageStoreImpl::recoverBindings(mrg::msgstore::TxnCtxt&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableExchange>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableExchange> > > >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x448309C:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 26 bytes in 1 blocks are possibly lost in loss record 42 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x58216B:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 26 bytes in 1 blocks are possibly lost in loss record 43 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21CF34: ??? (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21D146: std::basic_string<char,
std::char_traits<char>, std::allocator<char> >::basic_string(char
const*, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x447740E:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 26 bytes in 1 blocks are possibly lost in loss record 44 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x38004E:
qpid::framing::MessageSubscribeBody::decodeStructBody(qpid::framing::Buffer&,
unsigned int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x38010B:
qpid::framing::MessageSubscribeBody::decode(qpid::framing::Buffer&, unsigned
int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FC436:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x55C486: qpid::amqp_0_10::Connection::decode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60E4F3: qpid::broker::SecureConnection::decode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x426BE5:
qpid::sys::AsynchIOHandler::readbuff(qpid::sys::AsynchIO&,
qpid::sys::AsynchIOBufferBase*) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485==
==4485== 28 bytes in 1 blocks are possibly lost in loss record 45 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44A67A9: std::_Rb_tree<unsigned long long,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct>,
std::_Select1st<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >, std::less<unsigned long
long>, std::allocator<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >
>::_M_insert(std::_Rb_tree_node_base*, std::_Rb_tree_node_base*,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A6946: std::_Rb_tree<unsigned long long,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct>,
std::_Select1st<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >, std::less<unsigned long
long>, std::allocator<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >
>::insert_unique(std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A4397: mrg::journal::enq_map::insert_pfid(unsigned long
long, unsigned short, bool) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A494A: mrg::journal::enq_map::insert_pfid(unsigned long
long, unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B048C: mrg::journal::jcntl::rcvr_get_next_record(unsigned
short&, std::basic_ifstream<char, std::char_traits<char> >*, bool&,
mrg::journal::rcvdat&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0F45:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 32 bytes in 1 blocks are possibly lost in loss record 49 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x58D5FB: std::_Deque_base<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_initialize_map(unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x57FD70: qpid::broker::Queue::Queue(std::string const&,
bool, qpid::broker::MessageStore*, qpid::broker::OwnershipToken const*,
qpid::management::Manageable*) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x602271: qpid::broker::QueueRegistry::declare(std::string
const&, bool, bool, qpid::broker::OwnershipToken const*) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58219C:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 32 bytes in 1 blocks are possibly lost in loss record 50 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CCDD3: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*> >::_M_initialize_map(unsigned
int) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D88FA: mrg::journal::wmgr::wmgr(mrg::journal::jcntl*,
mrg::journal::enq_map&, mrg::journal::txn_map&, mrg::journal::wrfc&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44AE86C: mrg::journal::jcntl::jcntl(std::string const&,
std::string const&, std::string const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445A7BA:
mrg::msgstore::JournalImpl::JournalImpl(std::string const&, std::string
const&, std::string const&, qpid::sys::Duration, qpid::sys::Duration) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44774C6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 40 bytes in 1 blocks are possibly lost in loss record 60 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x5FA9F4:
qpid::broker::QueuePolicy::createQueuePolicy(std::string const&, unsigned
int, unsigned long long, std::string const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5FAB00:
qpid::broker::QueuePolicy::createQueuePolicy(std::string const&,
qpid::framing::FieldTable const&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58124E:
qpid::broker::Queue::configure(qpid::framing::FieldTable const&, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5821D6:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 56 bytes in 1 blocks are possibly lost in loss record 70 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x804CCEE: char*
std::string::_S_construct<char*>(char*, char*, std::allocator<char>
const&, std::forward_iterator_tag) (in /usr/sbin/qpidd)
==4485== by 0x44750BD:
mrg::msgstore::MessageStoreImpl::getJrnlDir(std::string const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447744F:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 64 bytes in 1 blocks are possibly lost in loss record 74 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB3DE:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CF3A8:
mrg::journal::rmgr::initialize(mrg::journal::aio_callback*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DB2: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 64 bytes in 1 blocks are possibly lost in loss record 75 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x5F21DB: std::vector<qpid::broker::QueueBinding,
std::allocator<qpid::broker::QueueBinding>
>::_M_insert_aux(__gnu_cxx::__normal_iterator<qpid::broker::QueueBinding*,
std::vector<qpid::broker::QueueBinding,
std::allocator<qpid::broker::QueueBinding> > >,
qpid::broker::QueueBinding const&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5F1C1C: qpid::broker::QueueBindings::add(std::string
const&, std::string const&, qpid::framing::FieldTable const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x57C916: qpid::broker::Queue::bound(std::string const&,
std::string const&, qpid::framing::FieldTable const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x605A3C: RecoverableExchangeImpl::bind(std::string&,
std::string&, qpid::framing::FieldTable&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x446EFDA:
mrg::msgstore::MessageStoreImpl::recoverBindings(mrg::msgstore::TxnCtxt&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableExchange>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableExchange> > > >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x448309C:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 84 bytes in 1 blocks are possibly lost in loss record 78 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x445A8C1:
mrg::msgstore::JournalImpl::JournalImpl(std::string const&, std::string
const&, std::string const&, qpid::sys::Duration, qpid::sys::Duration) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44774C6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485== by 0xA7FE9B: (below main) (in /lib/libc-2.5.so)
==4485==
==4485== 128 bytes in 1 blocks are possibly lost in loss record 80 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB3DE:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 160 bytes in 1 blocks are possibly lost in loss record 88 of 158
==4485== at 0x4004C42: calloc (vg_replace_malloc.c:418)
==4485== by 0xA5BF09: _dl_allocate_tls (in /lib/ld-2.5.so)
==4485== by 0xBFCF5C: pthread_create@@GLIBC_2.1 (in
/lib/libpthread-2.5.so)
==4485== by 0xBFD6E7: pthread_create@GLIBC_2.0 (in
/lib/libpthread-2.5.so)
==4485== by 0x3CD48A:
qpid::sys::ThreadPrivate::ThreadPrivate(qpid::sys::Runnable*) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3CD279: qpid::sys::Thread::Thread(qpid::sys::Runnable*) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x640753: qpid::broker::Timer::start() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x642A29: qpid::broker::Timer::Timer() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x445B80D:
mrg::msgstore::JournalImpl::JournalImpl(std::string const&, std::string
const&, std::string const&, qpid::sys::Duration, qpid::sys::Duration) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4479B90: mrg::msgstore::MessageStoreImpl::init() (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447C315: mrg::msgstore::MessageStoreImpl::init(std::string
const&, unsigned short, unsigned int, bool, unsigned int, unsigned short,
unsigned int, unsigned int, bool, unsigned short) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447CF20:
mrg::msgstore::MessageStoreImpl::init(qpid::Options const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485==
==4485== 252 bytes in 3 blocks are possibly lost in loss record 92 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x445A95A:
mrg::msgstore::JournalImpl::JournalImpl(std::string const&, std::string
const&, std::string const&, qpid::sys::Duration, qpid::sys::Duration) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44774C6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485== by 0xA7FE9B: (below main) (in /lib/libc-2.5.so)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 93 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44B562E: std::vector<unsigned int, std::allocator<unsigned
int> >::_M_fill_insert(__gnu_cxx::__normal_iterator<unsigned int*,
std::vector<unsigned int, std::allocator<unsigned int> > >, unsigned int,
unsigned int const&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C78: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 94 of 158
==4485== at 0x4005D2D: operator new[](unsigned int)
(vg_replace_malloc.c:258)
==4485== by 0x44A04DD: mrg::journal::arr_cnt::set_size(unsigned short)
(in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A3DD7: mrg::journal::enq_map::set_num_jfiles(unsigned
short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0BD3:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 95 of 158
==4485== at 0x4005D2D: operator new[](unsigned int)
(vg_replace_malloc.c:258)
==4485== by 0x44A04DD: mrg::journal::arr_cnt::set_size(unsigned short)
(in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D2B87: mrg::journal::txn_map::set_num_jfiles(unsigned
short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0BF1:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 96 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CA858: std::vector<mrg::journal::fcntl*,
std::allocator<mrg::journal::fcntl*> >::reserve(unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44C9F84: mrg::journal::lpmgr::recover(mrg::journal::rcvdat
const&, mrg::journal::jcntl*, mrg::journal::fcntl* (*)(mrg::journal::jcntl*,
unsigned short, unsigned short, mrg::journal::rcvdat const*)) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1D20: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 97 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44DD114:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 256 bytes in 1 blocks are possibly lost in loss record 98 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44DD137:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 256 bytes in 64 blocks are possibly lost in loss record 99 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44A051A: mrg::journal::arr_cnt::set_size(unsigned short)
(in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A3DD7: mrg::journal::enq_map::set_num_jfiles(unsigned
short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0BD3:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 256 bytes in 64 blocks are possibly lost in loss record 100 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44A051A: mrg::journal::arr_cnt::set_size(unsigned short)
(in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D2B87: mrg::journal::txn_map::set_num_jfiles(unsigned
short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0BF1:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 364 bytes in 1 blocks are possibly lost in loss record 103 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x602224: qpid::broker::QueueRegistry::declare(std::string
const&, bool, bool, qpid::broker::OwnershipToken const*) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58219C:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 504 bytes in 1 blocks are possibly lost in loss record 104 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x58D54B: std::_Deque_base<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_create_nodes(qpid::broker::QueuedMessage**,
qpid::broker::QueuedMessage**) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58D61D: std::_Deque_base<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_initialize_map(unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x57FD70: qpid::broker::Queue::Queue(std::string const&,
bool, qpid::broker::MessageStore*, qpid::broker::OwnershipToken const*,
qpid::management::Manageable*) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x602271: qpid::broker::QueueRegistry::declare(std::string
const&, bool, bool, qpid::broker::OwnershipToken const*) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58219C:
qpid::broker::Queue::decode(qpid::broker::QueueRegistry&,
qpid::framing::Buffer&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604737:
qpid::broker::RecoveryManagerImpl::recoverQueue(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44773C4:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 504 bytes in 1 blocks are possibly lost in loss record 105 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x5B3FAB: std::_Deque_base<qpid::broker::DeliveryRecord,
std::allocator<qpid::broker::DeliveryRecord>
>::_M_create_nodes(qpid::broker::DeliveryRecord**,
qpid::broker::DeliveryRecord**) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5B407D: std::_Deque_base<qpid::broker::DeliveryRecord,
std::allocator<qpid::broker::DeliveryRecord>
>::_M_initialize_map(unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6157D9:
qpid::broker::SemanticState::SemanticState(qpid::broker::DeliveryAdapter&,
qpid::broker::SessionContext&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x637B8F:
qpid::broker::SessionState::SessionState(qpid::broker::Broker&,
qpid::broker::SessionHandler&, qpid::SessionId const&,
qpid::SessionState::Configuration const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x63B8E7:
qpid::broker::SessionManager::attach(qpid::broker::SessionHandler&,
qpid::SessionId const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x63D95A: qpid::broker::SessionHandler::setState(std::string
const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x3F4C58: qpid::amqp_0_10::SessionHandler::attach(std::string
const&, bool) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x347A72:
qpid::framing::AMQP_AllOperations::SessionHandler::Invoker::visit(qpid::framing::SessionAttachBody
const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3765C7:
qpid::framing::SessionAttachBody::accept(qpid::framing::MethodBodyConstVisitor&)
const (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F98A6: qpid::framing::Invoker::Result
qpid::framing::invoke<qpid::amqp_0_10::SessionHandler>(qpid::amqp_0_10::SessionHandler&,
qpid::framing::AMQMethodBody const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F43BF:
qpid::amqp_0_10::SessionHandler::invoke(qpid::framing::AMQMethodBody const&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485==
==4485== 512 bytes in 1 blocks are possibly lost in loss record 110 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CCD2B: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*>
>::_M_create_nodes(mrg::journal::data_tok***, mrg::journal::data_tok***) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CCDF5: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*> >::_M_initialize_map(unsigned
int) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D88FA: mrg::journal::wmgr::wmgr(mrg::journal::jcntl*,
mrg::journal::enq_map&, mrg::journal::txn_map&, mrg::journal::wrfc&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44AE86C: mrg::journal::jcntl::jcntl(std::string const&,
std::string const&, std::string const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445A7BA:
mrg::msgstore::JournalImpl::JournalImpl(std::string const&, std::string
const&, std::string const&, qpid::sys::Duration, qpid::sys::Duration) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44774C6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 1,024 bytes in 32 blocks are possibly lost in loss record 122 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CCDD3: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*> >::_M_initialize_map(unsigned
int) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CB526:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 1,280 bytes in 1 blocks are possibly lost in loss record 125 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB3FE:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 1,280 bytes in 32 blocks are possibly lost in loss record 126 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CB4C9:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 1,348 bytes in 1 blocks are possibly lost in loss record 127 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x447747A:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485== by 0xA7FE9B: (below main) (in /lib/libc-2.5.so)
==4485==
==4485== 2,048 bytes in 1 blocks are possibly lost in loss record 128 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB43E:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 2,552 bytes in 1 blocks are possibly lost in loss record 129 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x58D2D0: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_reallocate_map(unsigned int, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58DC4E: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_push_back_aux(qpid::broker::QueuedMessage const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58A6D6:
qpid::broker::Queue::push(boost::intrusive_ptr<qpid::broker::Message>&,
bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58B684:
qpid::broker::Queue::recover(boost::intrusive_ptr<qpid::broker::Message>&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604168:
RecoverableMessageImpl::recover(boost::shared_ptr<qpid::broker::Queue>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604C3A:
RecoverableQueueImpl::recover(boost::shared_ptr<qpid::broker::RecoverableMessage>)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44754D9:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 2,560 bytes in 1 blocks are possibly lost in loss record 130 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB5EF:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CF3A8:
mrg::journal::rmgr::initialize(mrg::journal::aio_callback*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DB2: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 3,072 bytes in 1 blocks are possibly lost in loss record 132 of 158
==4485== at 0x4005903: malloc (vg_replace_malloc.c:195)
==4485== by 0x44CB5EF:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 4,032 bytes in 8 blocks are possibly lost in loss record 133 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x58DE3A: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_push_front_aux(qpid::broker::QueuedMessage const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58F2F7: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_insert_aux(std::_Deque_iterator<qpid::broker::QueuedMessage,
qpid::broker::QueuedMessage&, qpid::broker::QueuedMessage*>,
qpid::broker::QueuedMessage const&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58F3F1: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::insert(std::_Deque_iterator<qpid::broker::QueuedMessage,
qpid::broker::QueuedMessage&, qpid::broker::QueuedMessage*>,
qpid::broker::QueuedMessage const&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x588CF0:
qpid::broker::Queue::requeue(qpid::broker::QueuedMessage const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5AB0C7: qpid::broker::DeliveryRecord::release(bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F521:
qpid::broker::SemanticState::release(qpid::framing::SequenceNumber,
qpid::framing::SequenceNumber, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6320C6:
boost::detail::function::void_function_obj_invoker2<boost::_bi::bind_t<void,
boost::_mfi::mf3<void, qpid::broker::SemanticState,
qpid::framing::SequenceNumber, qpid::framing::SequenceNumber, bool>,
boost::_bi::list4<boost::_bi::value<qpid::broker::SemanticState*>,
boost::arg<1>, boost::arg<2>, boost::_bi::value<bool> > >, void,
qpid::framing::SequenceNumber,
qpid::framing::SequenceNumber>::invoke(boost::detail::function::any_pointer,
qpid::framing::SequenceNumber, qpid::framing::SequenceNumber) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x63311A: boost::function2<void,
qpid::framing::SequenceNumber, qpid::framing::SequenceNumber,
std::allocator<void> >::operator()(qpid::framing::SequenceNumber,
qpid::framing::SequenceNumber) const (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x622CBE:
qpid::broker::SessionAdapter::MessageHandlerImpl::release(qpid::framing::SequenceSet
const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x33E1D2:
qpid::framing::AMQP_ServerOperations::MessageHandler::Invoker::visit(qpid::framing::MessageReleaseBody
const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x37E82A:
qpid::framing::MessageReleaseBody::accept(qpid::framing::MethodBodyConstVisitor&)
const (in /usr/lib/libqpidcommon.so.0.1.0)
==4485==
==4485== 4,096 bytes in 64 blocks are possibly lost in loss record 134 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44DD1AF:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 10,232 bytes in 1 blocks are possibly lost in loss record 137 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x5B4210: std::deque<qpid::broker::DeliveryRecord,
std::allocator<qpid::broker::DeliveryRecord>
>::_M_reallocate_map(unsigned int, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5B4B70: std::deque<qpid::broker::DeliveryRecord,
std::allocator<qpid::broker::DeliveryRecord>
>::_M_push_back_aux(qpid::broker::DeliveryRecord const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F306:
qpid::broker::SemanticState::record(qpid::broker::DeliveryRecord const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F3E9:
qpid::broker::SemanticState::ConsumerImpl::deliver(qpid::broker::QueuedMessage&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x587562:
qpid::broker::Queue::dispatch(boost::shared_ptr<qpid::broker::Consumer>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x617B85:
qpid::broker::SemanticState::ConsumerImpl::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x61A6D1: qpid::broker::SemanticState::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x59DB8C: qpid::broker::Connection::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x55B780: qpid::amqp_0_10::Connection::encode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 16,384 bytes in 32 blocks are possibly lost in loss record 138 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44CCD2B: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*>
>::_M_create_nodes(mrg::journal::data_tok***, mrg::journal::data_tok***) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CCDF5: std::_Deque_base<mrg::journal::data_tok*,
std::allocator<mrg::journal::data_tok*> >::_M_initialize_map(unsigned
int) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44CB526:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 32,768 bytes in 1 blocks are possibly lost in loss record 139 of
158
==4485== at 0x4004B11: memalign (vg_replace_malloc.c:532)
==4485== by 0x4004B6B: posix_memalign (vg_replace_malloc.c:660)
==4485== by 0x44DCED5:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 131,072 bytes in 2 blocks are possibly lost in loss record 140 of
158
==4485== at 0x4005D2D: operator new[](unsigned int)
(vg_replace_malloc.c:258)
==4485== by 0x4251DB:
qpid::sys::AsynchIOHandler::init(qpid::sys::AsynchIO*, int) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x6663D7:
qpid::sys::AsynchIOProtocolFactory::established(boost::shared_ptr<qpid::sys::Poller>,
qpid::sys::Socket const&, qpid::sys::ConnectionCodec::Factory*, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x668544:
boost::detail::function::void_function_obj_invoker1<boost::_bi::bind_t<void,
boost::_mfi::mf4<void, qpid::sys::AsynchIOProtocolFactory,
boost::shared_ptr<qpid::sys::Poller>, qpid::sys::Socket const&,
qpid::sys::ConnectionCodec::Factory*, bool>,
boost::_bi::list5<boost::_bi::value<qpid::sys::AsynchIOProtocolFactory*>,
boost::_bi::value<boost::shared_ptr<qpid::sys::Poller> >,
boost::arg<1>,
boost::_bi::value<qpid::sys::ConnectionCodec::Factory*>,
boost::_bi::value<bool> > >, void, qpid::sys::Socket
const&>::invoke(boost::detail::function::any_pointer, qpid::sys::Socket
const&) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x3CA073: boost::function1<void, qpid::sys::Socket
const&, std::allocator<boost::function_base>
>::operator()(qpid::sys::Socket const&) const (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3C557E:
qpid::sys::AsynchAcceptorPrivate::readable(qpid::sys::DispatchHandle&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3C71CC:
boost::detail::function::void_function_obj_invoker1<boost::_bi::bind_t<void,
boost::_mfi::mf1<void, qpid::sys::AsynchAcceptorPrivate,
qpid::sys::DispatchHandle&>,
boost::_bi::list2<boost::_bi::value<qpid::sys::AsynchAcceptorPrivate*>,
boost::arg<1> > >, void,
qpid::sys::DispatchHandle&>::invoke(boost::detail::function::any_pointer,
qpid::sys::DispatchHandle&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x42AF13: boost::function1<void,
qpid::sys::DispatchHandle&, std::allocator<boost::function_base>
>::operator()(qpid::sys::DispatchHandle&) const (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x42A5F8:
qpid::sys::DispatchHandle::processEvent(qpid::sys::Poller::EventType) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3D7933: qpid::sys::Poller::run() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x4278D3: qpid::sys::Dispatcher::run() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3CC870: ??? (in /usr/lib/libqpidcommon.so.0.1.0)
==4485==
==4485== 135,576 bytes in 269 blocks are possibly lost in loss record 142 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x58DBA9: std::deque<qpid::broker::QueuedMessage,
std::allocator<qpid::broker::QueuedMessage>
>::_M_push_back_aux(qpid::broker::QueuedMessage const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58A6D6:
qpid::broker::Queue::push(boost::intrusive_ptr<qpid::broker::Message>&,
bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58B684:
qpid::broker::Queue::recover(boost::intrusive_ptr<qpid::broker::Message>&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604168:
RecoverableMessageImpl::recover(boost::shared_ptr<qpid::broker::Queue>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604C3A:
RecoverableQueueImpl::recover(boost::shared_ptr<qpid::broker::RecoverableMessage>)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44754D9:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 144,000 bytes in 12,000 blocks are possibly lost in loss record 143
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x3FAE95: qpid::framing::AMQContentBody::clone() const (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FB499:
qpid::framing::AMQFrame::AMQFrame(qpid::framing::AMQBody const&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5BC1:
qpid::broker::Message::decodeContent(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6041C6:
RecoverableMessageImpl::decodeContent(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B89:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 144,243 (872 direct, 143,371 indirect) bytes in 1 blocks are
definitely lost in loss record 144 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x63B8C1:
qpid::broker::SessionManager::attach(qpid::broker::SessionHandler&,
qpid::SessionId const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x63D95A: qpid::broker::SessionHandler::setState(std::string
const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x3F4C58: qpid::amqp_0_10::SessionHandler::attach(std::string
const&, bool) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x347A72:
qpid::framing::AMQP_AllOperations::SessionHandler::Invoker::visit(qpid::framing::SessionAttachBody
const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3765C7:
qpid::framing::SessionAttachBody::accept(qpid::framing::MethodBodyConstVisitor&)
const (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F98A6: qpid::framing::Invoker::Result
qpid::framing::invoke<qpid::amqp_0_10::SessionHandler>(qpid::amqp_0_10::SessionHandler&,
qpid::framing::AMQMethodBody const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F43BF:
qpid::amqp_0_10::SessionHandler::invoke(qpid::framing::AMQMethodBody const&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F82C6:
qpid::amqp_0_10::SessionHandler::handleIn(qpid::framing::AMQFrame&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x63A26A:
qpid::framing::Handler<qpid::framing::AMQFrame&>::MemFunRef<qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface,
&(qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface::handleIn(qpid::framing::AMQFrame&))>::handle(qpid::framing::AMQFrame&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x599D6F:
qpid::broker::Connection::received(qpid::framing::AMQFrame&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x55C46E: qpid::amqp_0_10::Connection::decode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 192,000 bytes in 12,000 blocks are possibly lost in loss record 145
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x592240:
qpid::broker::PersistableMessage::addToSyncList(boost::shared_ptr<qpid::broker::PersistableQueue>,
qpid::broker::MessageStore*) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x58B6E7:
qpid::broker::Queue::recover(boost::intrusive_ptr<qpid::broker::Message>&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604168:
RecoverableMessageImpl::recover(boost::shared_ptr<qpid::broker::Queue>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x604C3A:
RecoverableQueueImpl::recover(boost::shared_ptr<qpid::broker::RecoverableMessage>)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x44754D9:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 240,000 bytes in 12,000 blocks are possibly lost in loss record 146
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x3B0E0D: qpid::framing::MethodBodyFactory::create(unsigned
char, unsigned char) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FC3C5:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5CD4:
qpid::broker::Message::decodeHeader(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6044E4:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 276,000 bytes in 12,000 blocks are possibly lost in loss record 147
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x37D0BF:
qpid::framing::MessageTransferBody::decodeStructBody(qpid::framing::Buffer&,
unsigned int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x37D0FB:
qpid::framing::MessageTransferBody::decode(qpid::framing::Buffer&, unsigned
int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FC436:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5CD4:
qpid::broker::Message::decodeHeader(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6044E4:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485==
==4485== 276,000 bytes in 12,000 blocks are possibly lost in loss record 148
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3690C3:
qpid::framing::DeliveryProperties::decodeStructBody(qpid::framing::Buffer&,
unsigned int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FD23B:
qpid::framing::AMQHeaderBody::decode(qpid::framing::Buffer&, unsigned int)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FC436:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5D36:
qpid::broker::Message::decodeHeader(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6044E4:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485==
==4485== 288,000 bytes in 12,000 blocks are possibly lost in loss record 149
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x402705: qpid::framing::Buffer::getShortString(std::string&)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3690AE:
qpid::framing::DeliveryProperties::decodeStructBody(qpid::framing::Buffer&,
unsigned int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FD23B:
qpid::framing::AMQHeaderBody::decode(qpid::framing::Buffer&, unsigned int)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FC436:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5D36:
qpid::broker::Message::decodeHeader(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6044E4:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485==
==4485== 335,972 bytes in 11,999 blocks are possibly lost in loss record 150
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x44A67A9: std::_Rb_tree<unsigned long long,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct>,
std::_Select1st<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >, std::less<unsigned long
long>, std::allocator<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >
>::_M_insert(std::_Rb_tree_node_base*, std::_Rb_tree_node_base*,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A6909: std::_Rb_tree<unsigned long long,
std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct>,
std::_Select1st<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >, std::less<unsigned long
long>, std::allocator<std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> >
>::insert_unique(std::pair<unsigned long long const,
mrg::journal::enq_map::emap_data_struct> const&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A4397: mrg::journal::enq_map::insert_pfid(unsigned long
long, unsigned short, bool) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44A494A: mrg::journal::enq_map::insert_pfid(unsigned long
long, unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B048C: mrg::journal::jcntl::rcvr_get_next_record(unsigned
short&, std::basic_ifstream<char, std::char_traits<char> >*, bool&,
mrg::journal::rcvdat&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B0F45:
mrg::journal::jcntl::rcvr_janalyze(mrg::journal::rcvdat&,
std::vector<std::string, std::allocator<std::string> > const*) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1C8E: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 400,320 bytes in 20,016 blocks are possibly lost in loss record 151
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x37D3C8: qpid::framing::MessageTransferBody::clone() const
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FB499:
qpid::framing::AMQFrame::AMQFrame(qpid::framing::AMQBody const&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5A952B:
qpid::broker::DeliveryRecord::deliver(qpid::framing::Handler<qpid::framing::AMQFrame&>&,
qpid::framing::SequenceNumber, unsigned short) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x634E53:
qpid::broker::SessionState::deliver(qpid::broker::DeliveryRecord&, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60ECA1:
qpid::broker::SemanticState::deliver(qpid::broker::DeliveryRecord&, bool)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F3C8:
qpid::broker::SemanticState::ConsumerImpl::deliver(qpid::broker::QueuedMessage&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x587562:
qpid::broker::Queue::dispatch(boost::shared_ptr<qpid::broker::Consumer>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x617B85:
qpid::broker::SemanticState::ConsumerImpl::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x61A6D1: qpid::broker::SemanticState::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485==
==4485== 720,216 bytes in 1,429 blocks are possibly lost in loss record 152
of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x5B4A53: std::deque<qpid::broker::DeliveryRecord,
std::allocator<qpid::broker::DeliveryRecord>
>::_M_push_back_aux(qpid::broker::DeliveryRecord const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F306:
qpid::broker::SemanticState::record(qpid::broker::DeliveryRecord const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F3E9:
qpid::broker::SemanticState::ConsumerImpl::deliver(qpid::broker::QueuedMessage&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x587562:
qpid::broker::Queue::dispatch(boost::shared_ptr<qpid::broker::Consumer>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x617B85:
qpid::broker::SemanticState::ConsumerImpl::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x61A6D1: qpid::broker::SemanticState::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x424D38: qpid::sys::AggregateOutput::doOutput() (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x59DB8C: qpid::broker::Connection::doOutput() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x55B780: qpid::amqp_0_10::Connection::encode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60E558: qpid::broker::SecureConnection::encode(char const*,
unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 1,048,576 bytes in 1 blocks are possibly lost in loss record 154 of
158
==4485== at 0x4004B11: memalign (vg_replace_malloc.c:532)
==4485== by 0x4004B6B: posix_memalign (vg_replace_malloc.c:660)
==4485== by 0x44CB1E6:
mrg::journal::pmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44DCE87:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44D83E9:
mrg::journal::wmgr::initialize(mrg::journal::aio_callback*, unsigned int,
unsigned short, unsigned int, unsigned int, unsigned int) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44B1DFA: mrg::journal::jcntl::recover(unsigned short, bool,
unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*, std::vector<std::string,
std::allocator<std::string> > const*, unsigned long long&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x445747E: mrg::msgstore::JournalImpl::recover(unsigned
short, bool, unsigned short, unsigned int, unsigned short, unsigned int,
mrg::journal::aio_callback*,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >*, unsigned long
long&, unsigned long long) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x447776D:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 1,048,576 bytes in 1 blocks are possibly lost in loss record 155 of
158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x3EFF1A: std::vector<qpid::framing::AMQFrame,
std::allocator<qpid::framing::AMQFrame>
>::_M_insert_aux(__gnu_cxx::__normal_iterator<qpid::framing::AMQFrame*,
std::vector<qpid::framing::AMQFrame,
std::allocator<qpid::framing::AMQFrame> > >, qpid::framing::AMQFrame
const&) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3EC52F:
qpid::SessionState::senderRecord(qpid::framing::AMQFrame const&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3F9333:
qpid::amqp_0_10::SessionHandler::handleOut(qpid::framing::AMQFrame&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x63A24A:
qpid::framing::Handler<qpid::framing::AMQFrame&>::MemFunRef<qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface,
&(qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface::handleOut(qpid::framing::AMQFrame&))>::handle(qpid::framing::AMQFrame&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x415F77:
qpid::framing::SendContent::operator()(qpid::framing::AMQFrame const&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E849D:
qpid::broker::Message::sendContent(qpid::broker::Queue const&,
qpid::framing::Handler<qpid::framing::AMQFrame&>&, unsigned short)
const (in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x5A95B4:
qpid::broker::DeliveryRecord::deliver(qpid::framing::Handler<qpid::framing::AMQFrame&>&,
qpid::framing::SequenceNumber, unsigned short) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x634E53:
qpid::broker::SessionState::deliver(qpid::broker::DeliveryRecord&, bool) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60ECA1:
qpid::broker::SemanticState::deliver(qpid::broker::DeliveryRecord&, bool)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x60F3C8:
qpid::broker::SemanticState::ConsumerImpl::deliver(qpid::broker::QueuedMessage&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x587562:
qpid::broker::Queue::dispatch(boost::shared_ptr<qpid::broker::Consumer>) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485==
==4485== 1,824,000 bytes in 12,000 blocks are possibly lost in loss record
156 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x3FC584:
qpid::framing::AMQFrame::decode(qpid::framing::Buffer&) (in
/usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5D36:
qpid::broker::Message::decodeHeader(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6044E4:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485==
==4485== 2,854,680 bytes in 12,000 blocks are possibly lost in loss record
157 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x21C13A: std::string::_Rep::_S_create(unsigned int, unsigned
int, std::allocator<char> const&) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21DE67: std::string::_M_mutate(unsigned int, unsigned int,
unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E009: std::string::_M_replace_safe(unsigned int, unsigned
int, char const*, unsigned int) (in /usr/lib/libstdc++.so.6.0.8)
==4485== by 0x21E0A4: std::string::assign(char const*, unsigned int) (in
/usr/lib/libstdc++.so.6.0.8)
==4485== by 0x4029FA: qpid::framing::Buffer::getRawData(std::string&,
unsigned int) (in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x3FAAFD:
qpid::framing::AMQContentBody::decode(qpid::framing::Buffer&, unsigned int)
(in /usr/lib/libqpidcommon.so.0.1.0)
==4485== by 0x5E5C00:
qpid::broker::Message::decodeContent(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x6041C6:
RecoverableMessageImpl::decodeContent(qpid::framing::Buffer&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B89:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485==
==4485== 3,648,000 bytes in 12,000 blocks are possibly lost in loss record
158 of 158
==4485== at 0x40060D5: operator new(unsigned int)
(vg_replace_malloc.c:214)
==4485== by 0x6044AA:
qpid::broker::RecoveryManagerImpl::recoverMessage(qpid::framing::Buffer&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x4475B1C:
mrg::msgstore::MessageStoreImpl::recoverMessages(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&,
boost::shared_ptr<qpid::broker::RecoverableQueue>&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&, long&,
long&) (in /usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x44777D6:
mrg::msgstore::MessageStoreImpl::recoverQueues(mrg::msgstore::TxnCtxt&,
qpid::broker::RecoveryManager&, std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableQueue>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableQueue> > > >&,
boost::ptr_list<mrg::msgstore::PreparedTransaction,
boost::heap_clone_allocator, std::allocator<void*> >&,
std::map<unsigned long long,
boost::shared_ptr<qpid::broker::RecoverableMessage>, std::less<unsigned
long long>, std::allocator<std::pair<unsigned long long const,
boost::shared_ptr<qpid::broker::RecoverableMessage> > > >&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x4483053:
mrg::msgstore::MessageStoreImpl::recover(qpid::broker::RecoveryManager&) (in
/usr/lib/qpid/daemon/msgstore.so)
==4485== by 0x5EEC12:
qpid::broker::MessageStoreModule::recover(qpid::broker::RecoveryManager&)
(in /usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x567583:
qpid::broker::Broker::Broker(qpid::broker::Broker::Options const&) (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x8050660: ??? (in /usr/sbin/qpidd)
==4485== by 0x5A563F: qpid::broker::Daemon::fork() (in
/usr/lib/libqpidbroker.so.0.1.0)
==4485== by 0x804DE10: ??? (in /usr/sbin/qpidd)
==4485== by 0x804C6C6: ??? (in /usr/sbin/qpidd)
==4485== by 0xA7FE9B: (below main) (in /lib/libc-2.5.so)
==4485==
==4485== LEAK SUMMARY:
==4485== definitely lost: 872 bytes in 1 blocks
==4485== indirectly lost: 143,371 bytes in 75 blocks
==4485== possibly lost: 13,650,722 bytes in 142,053 blocks
==4485== still reachable: 1,067,045 bytes in 97 blocks
==4485== suppressed: 0 bytes in 0 blocks
==4485== Reachable blocks (those to which a pointer was found) are not
shown.
==4485== To see them, rerun with: --leak-check=full --show-reachable=yes
==4485==
==4485== For counts of detected and suppressed errors, rerun with: -v
==4485== ERROR SUMMARY: 62 errors from 62 contexts (suppressed: 93 from 13)
--
View this message in context: http://apache-qpid-developers.2158895.n2.nabble.com/Memory-leak-in-QPID-C-Broker-tp6651794p6651794.html
Sent from the Apache Qpid developers mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
Re: Memory leak in QPID C++ Broker
Posted by et3w503 <et...@yahoo.com>.
I traced the call stack
"qpid::broker::SessionManager::attach(qpid::broker::SessionHandler&,qpid::SessionId
const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0) "
in
http://svn.apache.org/viewvc/qpid/tags/0.5/qpid/cpp/src/qpid/broker/SessionManager.cpp?view=markup
line 61:line state.reset(new SessionState(broker, h, id, config));
will new a SessionState object, then the instance will assign to
http://svn.apache.org/viewvc/qpid/tags/0.5/qpid/cpp/src/qpid/broker/SessionHandler.cpp?view=markup
line 72: session = connection.broker.getSessionManager().attach(*this, id,
force);
The class member session is aslo wrapped by auto_ptr.
My question is the session will be release automatically after
SessionHandler or we should release it manually?
--
View this message in context: http://apache-qpid-developers.2158895.n2.nabble.com/Memory-leak-in-QPID-C-Broker-tp6651794p6655155.html
Sent from the Apache Qpid developers mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
Re: Memory leak in QPID C++ Broker
Posted by Gordon Sim <gs...@redhat.com>.
On 08/04/2011 09:21 AM, et3w503 wrote:
> Dear all:
>
> I found a memory leak issue in QPID C++ broker using valgrind.
>
> My qpidd broker is the rpm version from Redhat ftp.
>
> ftp://ftp.redhat.com/pub/redhat/linux/enterprise/5Server/en/RHEMRG/SRPMS/qpidc-0.5.752581-34.el5.src.rpm
Can't say for sure with no further information, but I suspect this may
be simply the failure to free active sessions when the broker shuts
down. If so it is not an issue for a running system and is already fixed.
That is quite an old version, I'd recommend upgrading (the qpidc top
level package for RHEL is now called qpid-cpp-mrg). If you can reproduce
on a more recent broker, let me know.
> ==4485== 144,243 (872 direct, 143,371 indirect) bytes in 1 blocks are
> definitely lost in loss record 144 of 158
> ==4485== at 0x40060D5: operator new(unsigned int)
> (vg_replace_malloc.c:214)
> ==4485== by 0x63B8C1:
> qpid::broker::SessionManager::attach(qpid::broker::SessionHandler&,
> qpid::SessionId const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
> ==4485== by 0x63D95A: qpid::broker::SessionHandler::setState(std::string
> const&, bool) (in /usr/lib/libqpidbroker.so.0.1.0)
> ==4485== by 0x3F4C58: qpid::amqp_0_10::SessionHandler::attach(std::string
> const&, bool) (in /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x347A72:
> qpid::framing::AMQP_AllOperations::SessionHandler::Invoker::visit(qpid::framing::SessionAttachBody
> const&) (in /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x3765C7:
> qpid::framing::SessionAttachBody::accept(qpid::framing::MethodBodyConstVisitor&)
> const (in /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x3F98A6: qpid::framing::Invoker::Result
> qpid::framing::invoke<qpid::amqp_0_10::SessionHandler>(qpid::amqp_0_10::SessionHandler&,
> qpid::framing::AMQMethodBody const&) (in /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x3F43BF:
> qpid::amqp_0_10::SessionHandler::invoke(qpid::framing::AMQMethodBody const&)
> (in /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x3F82C6:
> qpid::amqp_0_10::SessionHandler::handleIn(qpid::framing::AMQFrame&) (in
> /usr/lib/libqpidcommon.so.0.1.0)
> ==4485== by 0x63A26A:
> qpid::framing::Handler<qpid::framing::AMQFrame&>::MemFunRef<qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface,
> &(qpid::framing::Handler<qpid::framing::AMQFrame&>::InOutHandlerInterface::handleIn(qpid::framing::AMQFrame&))>::handle(qpid::framing::AMQFrame&)
> (in /usr/lib/libqpidbroker.so.0.1.0)
> ==4485== by 0x599D6F:
> qpid::broker::Connection::received(qpid::framing::AMQFrame&) (in
> /usr/lib/libqpidbroker.so.0.1.0)
> ==4485== by 0x55C46E: qpid::amqp_0_10::Connection::decode(char const*,
> unsigned int) (in /usr/lib/libqpidbroker.so.0.1.0)
[snip]
> ==4485== LEAK SUMMARY:
> ==4485== definitely lost: 872 bytes in 1 blocks
> ==4485== indirectly lost: 143,371 bytes in 75 blocks
> ==4485== possibly lost: 13,650,722 bytes in 142,053 blocks
> ==4485== still reachable: 1,067,045 bytes in 97 blocks
> ==4485== suppressed: 0 bytes in 0 blocks
> ==4485== Reachable blocks (those to which a pointer was found) are not
> shown.
> ==4485== To see them, rerun with: --leak-check=full --show-reachable=yes
> ==4485==
> ==4485== For counts of detected and suppressed errors, rerun with: -v
> ==4485== ERROR SUMMARY: 62 errors from 62 contexts (suppressed: 93 from 13)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org