diff options
Diffstat (limited to 'cpp/test/Ice/udp/Client.cpp')
-rw-r--r-- | cpp/test/Ice/udp/Client.cpp | 40 |
1 files changed, 6 insertions, 34 deletions
diff --git a/cpp/test/Ice/udp/Client.cpp b/cpp/test/Ice/udp/Client.cpp index aea2b223f48..25ec449b96c 100644 --- a/cpp/test/Ice/udp/Client.cpp +++ b/cpp/test/Ice/udp/Client.cpp @@ -26,8 +26,8 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) for(int i = 0; i < num; i++) { ostringstream os; - os << "control:tcp -p " << (12010 + i); - TestIntfPrx::uncheckedCast(communicator->stringToProxy(os.str()))->shutdown(); + os << "control:" << getTestEndpoint(communicator, i, "tcp"); + ICE_UNCHECKED_CAST(TestIntfPrx, communicator->stringToProxy(os.str()))->shutdown(); } return EXIT_SUCCESS; } @@ -39,47 +39,19 @@ main(int argc, char* argv[]) Ice::registerIceSSL(); #endif - int status; - Ice::CommunicatorPtr communicator; - try { - Ice::InitializationData initData; - initData.properties = Ice::createProperties(argc, argv); - + Ice::InitializationData initData = getTestInitData(argc, argv); initData.properties->setProperty("Ice.Warn.Connections", "0"); initData.properties->setProperty("Ice.UDP.RcvSize", "16384"); initData.properties->setProperty("Ice.UDP.SndSize", "16384"); - communicator = Ice::initialize(argc, argv, initData); - status = run(argc, argv, communicator); + Ice::CommunicatorHolder ich = Ice::initialize(argc, argv, initData); + return run(argc, argv, ich.communicator()); } catch(const Ice::Exception& ex) { cerr << ex << endl; - status = EXIT_FAILURE; - } - - if(communicator) - { - try - { - communicator->destroy(); - } - catch(const Ice::Exception& ex) - { - cerr << ex << endl; - status = EXIT_FAILURE; - } + return EXIT_FAILURE; } - -#if TARGET_OS_IPHONE != 0 - // - // iOS WORKAROUND: without a sleep before the communicator - // destroy, the close on the UDP socket hangs. - // - IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(500)); -#endif - - return status; } |