diff options
| author | Alan Conway <aconway@apache.org> | 2010-06-16 20:32:04 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-06-16 20:32:04 +0000 |
| commit | a6801aa6ac2c6d97b6747ef7bd7d2264be9c58ab (patch) | |
| tree | d4368c5338c635d2cd7a7c40c576636b18098ed6 /cpp/src/tests | |
| parent | 2273c62236d666ab677d964591f564f81908d6ad (diff) | |
| download | qpid-python-a6801aa6ac2c6d97b6747ef7bd7d2264be9c58ab.tar.gz | |
Bug 603835 - cluster_tests.test_management failing.
Clean up connections causing extra connection objects in the mangement agent map.
- update connection was not being closed.
- connections belonging to members that left the cluster were not fully cleaned up
Also fixed test errors making failover_soak fail sporadically.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@955370 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests')
| -rw-r--r-- | cpp/src/tests/failover_soak.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/cpp/src/tests/failover_soak.cpp b/cpp/src/tests/failover_soak.cpp index f61a565f50..c2ac36a757 100644 --- a/cpp/src/tests/failover_soak.cpp +++ b/cpp/src/tests/failover_soak.cpp @@ -673,7 +673,7 @@ main ( int argc, char const ** argv ) // Get prefix for each queue name. stringstream queue_prefix; queue_prefix << "failover_soak_" << getpid(); - + string queue_prefix_str(queue_prefix.str()); // Run the declareQueues child. int childStatus; @@ -683,7 +683,7 @@ main ( int argc, char const ** argv ) declareQueuesPath, verbosity, durable, - queue_prefix.str().c_str(), + queue_prefix_str.c_str(), n_queues ); if ( -1 == dqClientPid ) { @@ -707,6 +707,7 @@ main ( int argc, char const ** argv ) stringstream queue_name; queue_name << queue_prefix.str() << '_' << i; + string queue_name_str(queue_name.str()); // Receiving client --------------------------- pid_t receivingClientPid = @@ -715,7 +716,7 @@ main ( int argc, char const ** argv ) receiverPath, reportFrequency, verbosity, - queue_name.str().c_str() ); + queue_name_str.c_str() ); if ( -1 == receivingClientPid ) { cerr << "END_OF_TEST ERROR_START_RECEIVER\n"; return CANT_FORK_RECEIVER; @@ -731,7 +732,7 @@ main ( int argc, char const ** argv ) reportFrequency, verbosity, durable, - queue_name.str().c_str() ); + queue_name_str.c_str() ); if ( -1 == sendingClientPid ) { cerr << "END_OF_TEST ERROR_START_SENDER\n"; return CANT_FORK_SENDER; |