diff options
Diffstat (limited to 'cpp/test/Ice/metrics/Collocated.cpp')
-rw-r--r-- | cpp/test/Ice/metrics/Collocated.cpp | 62 |
1 files changed, 26 insertions, 36 deletions
diff --git a/cpp/test/Ice/metrics/Collocated.cpp b/cpp/test/Ice/metrics/Collocated.cpp index 156673ff1e1..4dc2e316e46 100644 --- a/cpp/test/Ice/metrics/Collocated.cpp +++ b/cpp/test/Ice/metrics/Collocated.cpp @@ -8,57 +8,47 @@ // ********************************************************************** #include <Ice/Ice.h> -#include <TestCommon.h> +#include <TestHelper.h> #include <TestI.h> #include <InstrumentationI.h> -DEFINE_TEST("client") - using namespace std; using namespace Test; -int -run(int, char**, const Ice::CommunicatorPtr& communicator, const CommunicatorObserverIPtr& observer) +class Collocated : public Test::TestHelper +{ +public: + + void run(int, char**); +}; + +void +Collocated::run(int argc, char** argv) { - communicator->getProperties()->setProperty("TestAdapter.Endpoints", getTestEndpoint(communicator, 0)); + Ice::InitializationData initData; + initData.properties = createTestProperties(argc, argv); + initData.properties->setProperty("Ice.Admin.Endpoints", "tcp"); + initData.properties->setProperty("Ice.Admin.InstanceName", "client"); + initData.properties->setProperty("Ice.Admin.DelayCreation", "1"); + initData.properties->setProperty("Ice.Warn.Connections", "0"); + initData.properties->setProperty("Ice.Warn.Dispatch", "0"); + CommunicatorObserverIPtr observer = ICE_MAKE_SHARED(CommunicatorObserverI); + initData.observer = observer; + Ice::CommunicatorHolder communicator = initialize(argc, argv, initData); + + communicator->getProperties()->setProperty("TestAdapter.Endpoints", getTestEndpoint()); Ice::ObjectAdapterPtr adapter = communicator->createObjectAdapter("TestAdapter"); adapter->add(ICE_MAKE_SHARED(MetricsI), Ice::stringToIdentity("metrics")); //adapter->activate(); // Don't activate OA to ensure collocation is used. - communicator->getProperties()->setProperty("ControllerAdapter.Endpoints", getTestEndpoint(communicator, 1)); + communicator->getProperties()->setProperty("ControllerAdapter.Endpoints", getTestEndpoint(1)); Ice::ObjectAdapterPtr controllerAdapter = communicator->createObjectAdapter("ControllerAdapter"); controllerAdapter->add(ICE_MAKE_SHARED(ControllerI, adapter), Ice::stringToIdentity("controller")); //controllerAdapter->activate(); // Don't activate OA to ensure collocation is used. - MetricsPrxPtr allTests(const Ice::CommunicatorPtr&, const CommunicatorObserverIPtr&); - MetricsPrxPtr metrics = allTests(communicator, observer); + MetricsPrxPtr allTests(Test::TestHelper*, const CommunicatorObserverIPtr&); + MetricsPrxPtr metrics = allTests(this, observer); metrics->shutdown(); - return EXIT_SUCCESS; } -int -main(int argc, char* argv[]) -{ -#ifdef ICE_STATIC_LIBS - Ice::registerIceSSL(false); - Ice::registerIceWS(true); -#endif - try - { - Ice::InitializationData initData = getTestInitData(argc, argv); - initData.properties->setProperty("Ice.Admin.Endpoints", "tcp"); - initData.properties->setProperty("Ice.Admin.InstanceName", "client"); - initData.properties->setProperty("Ice.Admin.DelayCreation", "1"); - initData.properties->setProperty("Ice.Warn.Connections", "0"); - initData.properties->setProperty("Ice.Warn.Dispatch", "0"); - CommunicatorObserverIPtr observer = ICE_MAKE_SHARED(CommunicatorObserverI); - initData.observer = observer; - Ice::CommunicatorHolder ich(argc, argv, initData); - return run(argc, argv, ich.communicator(), observer); - } - catch(const Ice::Exception& ex) - { - cerr << ex << endl; - return EXIT_FAILURE; - } -} +DEFINE_TEST(Collocated) |