diff options
author | Alan Conway <aconway@apache.org> | 2009-03-03 15:07:58 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2009-03-03 15:07:58 +0000 |
commit | 50cf38c98dc657ab0823b6ea8df8e1a439dd17f5 (patch) | |
tree | 0689641f705b4dd0d8a6351df0b8e1d05eb5bc4d | |
parent | 2b86e1de4f37ce69ba32cfcfdfffeba237270626 (diff) | |
download | qpid-python-50cf38c98dc657ab0823b6ea8df8e1a439dd17f5.tar.gz |
QPID-1707 Mick Goulish. Improved failover_soak code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749627 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | cpp/src/tests/failover_soak.cpp | 27 |
1 files changed, 19 insertions, 8 deletions
diff --git a/cpp/src/tests/failover_soak.cpp b/cpp/src/tests/failover_soak.cpp index bd2189dbfd..706383d758 100644 --- a/cpp/src/tests/failover_soak.cpp +++ b/cpp/src/tests/failover_soak.cpp @@ -326,7 +326,7 @@ startNewBroker ( brokerVector & brokers, stringstream path, prefix, module; module << moduleDir << "/cluster.so"; path << srcRoot << "/qpidd"; - prefix << "soak-" << brokerId++; + prefix << "soak-" << brokerId; std::vector<std::string> argv = list_of<string> ("qpidd") @@ -345,8 +345,14 @@ startNewBroker ( brokerVector & brokers, ForkedBroker * broker = new ForkedBroker ( argv ); if ( verbosity > 0 ) - std::cerr << "new broker created: pid == " << broker->getPID() << endl; + std::cerr << "new broker created: pid == " + << broker->getPID() + << " log-prefix == " + << "soak-" << brokerId + << endl; brokers.push_back ( broker ); + + ++ brokerId; } @@ -394,7 +400,12 @@ killAllBrokers ( brokerVector & brokers, int delay ) for ( uint i = 0; i < brokers.size(); ++ i ) try { brokers[i]->kill(9); } - catch ( ... ) { } + catch ( ... ) + { + std::cerr << "killAllBrokers Warning: exception during kill on broker " + << i + << endl; + } } @@ -633,8 +644,8 @@ main ( int argc, char const ** argv ) } - int minSleep = 3, - maxSleep = 6; + int minSleep = 2, + maxSleep = 4; for ( int totalBrokers = 3; @@ -681,7 +692,7 @@ main ( int argc, char const ** argv ) // If all children have exited, quit. int unfinished = allMyChildren.unfinished(); if ( ! unfinished ) { - killAllBrokers ( brokers, 10 ); + killAllBrokers ( brokers, 5 ); if ( verbosity > 0 ) cout << "failoverSoak: all children have exited.\n"; @@ -707,7 +718,7 @@ main ( int argc, char const ** argv ) if ( verbosity > 0 ) cout << "failoverSoak: error on child.\n"; allMyChildren.killEverybody(); - killAllBrokers ( brokers, 10 ); + killAllBrokers ( brokers, 5 ); std::cerr << "ERROR: CLIENT END_OF_TEST\n"; return ERROR_ON_CHILD; } @@ -736,7 +747,7 @@ main ( int argc, char const ** argv ) cout << "failoverSoak: maxBrokers reached.\n"; allMyChildren.killEverybody(); - killAllBrokers ( brokers, 10 ); + killAllBrokers ( brokers, 5 ); std::cerr << "SUCCESSFUL END_OF_TEST\n"; |