You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2008/11/03 14:56:19 UTC
svn commit: r710056 -
/activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp
Author: tabish
Date: Mon Nov 3 05:56:19 2008
New Revision: 710056
URL: http://svn.apache.org/viewvc?rev=710056&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-200
Fix possible memory leaks and resolving Valgrind warnings.
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp
Modified: activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp?rev=710056&r1=710055&r2=710056&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/ResponseCorrelator.cpp Mon Nov 3 05:56:19 2008
@@ -77,6 +77,7 @@
// Add a future response object to the map indexed by this
// command id.
+ // TODO = This might not get deleted if an exception is thrown.
FutureResponse* futureResponse = new FutureResponse();
synchronized( &mapMutex ){
@@ -134,6 +135,7 @@
// Add a future response object to the map indexed by this
// command id.
+ // TODO = This might not get deleted if an exception is thrown.
FutureResponse* futureResponse = new FutureResponse();
synchronized( &mapMutex ){