diff options
Diffstat (limited to 'cpp/test/Ice/retry/Client.cpp')
-rw-r--r-- | cpp/test/Ice/retry/Client.cpp | 89 |
1 files changed, 40 insertions, 49 deletions
diff --git a/cpp/test/Ice/retry/Client.cpp b/cpp/test/Ice/retry/Client.cpp index ead1c6e6c64..63ef0a4a905 100644 --- a/cpp/test/Ice/retry/Client.cpp +++ b/cpp/test/Ice/retry/Client.cpp @@ -8,63 +8,54 @@ // ********************************************************************** #include <Ice/Ice.h> -#include <TestCommon.h> +#include <TestHelper.h> #include <Test.h> #include <InstrumentationI.h> -DEFINE_TEST("client") - using namespace std; using namespace Test; -int -run(int, char**, const Ice::CommunicatorPtr& communicator, const Ice::CommunicatorPtr& communicator2) -{ - RetryPrxPtr allTests(const Ice::CommunicatorPtr&, const Ice::CommunicatorPtr&, const string&); - RetryPrxPtr retry = allTests(communicator, communicator2, "retry:" + getTestEndpoint(communicator, 0)); - retry->shutdown(); - return EXIT_SUCCESS; -} - -int -main(int argc, char* argv[]) +class Client : public Test::TestHelper { -#ifdef ICE_STATIC_LIBS - Ice::registerIceSSL(false); - Ice::registerIceWS(true); -#endif - try - { - initCounts(); +public: - Ice::InitializationData initData = getTestInitData(argc, argv); - initData.observer = getObserver(); - // - // This test kills connections, so we don't want warnings. - // - initData.properties->setProperty("Ice.Warn.Connections", "0"); + void run(int, char**); +}; - // Disable PrintStackTraces otherwise the test can fail on Windows/Debug - initData.properties->setProperty("Ice.PrintStackTraces", "0"); - - initData.properties->setProperty("Ice.RetryIntervals", "0 1 10 1"); - Ice::CommunicatorHolder ich(argc, argv, initData); +void +Client::run(int argc, char** argv) +{ + initCounts(); + + Ice::InitializationData initData; + initData.properties = createTestProperties(argc, argv); + initData.observer = getObserver(); + // + // This test kills connections, so we don't want warnings. + // + initData.properties->setProperty("Ice.Warn.Connections", "0"); + + // Disable PrintStackTraces otherwise the test can fail on Windows/Debug + initData.properties->setProperty("Ice.PrintStackTraces", "0"); + + initData.properties->setProperty("Ice.RetryIntervals", "0 1 10 1"); + Ice::CommunicatorHolder ich1 = Ice::initialize(argc, argv, initData); + + // + // Configure a second communicator for the invocation timeout + // + retry test, we need to configure a large retry interval + // to avoid time-sensitive failures. + // + initData.properties = initData.properties->clone(); + initData.properties->setProperty("Ice.RetryIntervals", "0 1 10000"); + initData.observer = getObserver(); + Ice::CommunicatorHolder ich2 = Ice::initialize(initData); - // - // Configure a second communicator for the invocation timeout - // + retry test, we need to configure a large retry interval - // to avoid time-sensitive failures. - // - Ice::InitializationData initData2; - initData2.properties = initData.properties->clone(); - initData2.properties->setProperty("Ice.RetryIntervals", "0 1 10000"); - initData2.observer = getObserver(); - Ice::CommunicatorHolder ich2(initData2); - return run(argc, argv, ich.communicator(), ich2.communicator()); - } - catch(const Ice::Exception& ex) - { - cerr << ex << endl; - return EXIT_FAILURE; - } + RetryPrxPtr allTests(const Ice::CommunicatorPtr&, const Ice::CommunicatorPtr&, const string&); + RetryPrxPtr retry = allTests(ich1.communicator(), + ich2.communicator(), + "retry:" + TestHelper::getTestEndpoint(ich1->getProperties())); + retry->shutdown(); } + +DEFINE_TEST(Client) |