diff options
Diffstat (limited to 'cppe/test/IceE/faultTolerance/AllTests.cpp')
-rw-r--r-- | cppe/test/IceE/faultTolerance/AllTests.cpp | 154 |
1 files changed, 0 insertions, 154 deletions
diff --git a/cppe/test/IceE/faultTolerance/AllTests.cpp b/cppe/test/IceE/faultTolerance/AllTests.cpp deleted file mode 100644 index 5193f8f78dd..00000000000 --- a/cppe/test/IceE/faultTolerance/AllTests.cpp +++ /dev/null @@ -1,154 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved. -// -// This copy of Ice-E is licensed to you under the terms described in the -// ICEE_LICENSE file included in this distribution. -// -// ********************************************************************** - -#include <IceE/DisableWarnings.h> -#include <IceE/IceE.h> -#include <TestCommon.h> -#include <Test.h> - -using namespace std; -using namespace Test; - -class CallbackBase : public IceUtil::Monitor<IceUtil::Mutex> -{ -public: - - CallbackBase() : - _called(false) - { - } - - virtual ~CallbackBase() - { - } - - bool check() - { - IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this); - while(!_called) - { - if(!timedWait(IceUtil::Time::seconds(30))) - { - return false; - } - } - _called = false; - return true; - } - -protected: - - void called() - { - IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this); - assert(!_called); - _called = true; - notify(); - } - -private: - - bool _called; -}; - -void -allTests(const Ice::CommunicatorPtr& communicator, const vector<int>& ports) -{ - tprintf("testing stringToProxy..."); - string ref("test"); - - char buf[32]; - for(vector<int>::const_iterator p = ports.begin(); p != ports.end(); ++p) - { - sprintf(buf, ":default -t 60000 -p %d", *p); - ref += buf; - } - Ice::ObjectPrx base = communicator->stringToProxy(ref); - test(base); - tprintf("ok\n"); - - tprintf("testing checked cast..."); - TestIntfPrx obj = TestIntfPrx::checkedCast(base); - test(obj); - test(obj == base); - tprintf("ok\n"); - - int oldPid = 0; - for(unsigned int i = 1, j = 0; i <= ports.size(); ++i, ++j) - { - if(j > 3) - { - j = 0; - } - - tprintf("testing server #%d...", i); - int pid = obj->pid(); - test(pid != oldPid); - tprintf("ok\n"); - oldPid = pid; - - if(j == 0) - { - tprintf("shutting down server #%d...", i); - obj->shutdown(); - tprintf("ok\n"); - } - else if(j == 1 || i + 1 > ports.size()) - { - tprintf("aborting server #%d...", i); - try - { - obj->abort(); - test(false); - } - catch(const Ice::ConnectionLostException&) - { - tprintf("ok\n"); - } - catch(const Ice::ConnectFailedException&) - { - tprintf("ok\n"); - } - } - else if(j == 2 || j == 3) - { - tprintf("aborting server #%d and #%d with idempotent call...", i, i + 1); - try - { - obj->idempotentAbort(); - test(false); - } - catch(const Ice::ConnectionLostException&) - { - tprintf("ok\n"); - } - catch(const Ice::ConnectFailedException&) - { - tprintf("ok\n"); - } - - ++i; - } - else - { - assert(false); - } - } - - tprintf("testing whether all servers are gone..."); - try - { - obj->ice_ping(); - test(false); - } - catch(const Ice::LocalException&) - { - tprintf("ok\n"); - } -} |