diff options
Diffstat (limited to 'cpp/src/Glacier2Lib/Application.cpp')
| -rw-r--r-- | cpp/src/Glacier2Lib/Application.cpp | 378 |
1 files changed, 0 insertions, 378 deletions
diff --git a/cpp/src/Glacier2Lib/Application.cpp b/cpp/src/Glacier2Lib/Application.cpp deleted file mode 100644 index ef330e41e88..00000000000 --- a/cpp/src/Glacier2Lib/Application.cpp +++ /dev/null @@ -1,378 +0,0 @@ -// -// Copyright (c) ZeroC, Inc. All rights reserved. -// - -#include <Glacier2/Application.h> -#include <Ice/Ice.h> -#include <IceUtil/IceUtil.h> -#include <Ice/ArgVector.h> - -using namespace std; -using namespace Ice; - -Ice::ObjectAdapterPtr Glacier2::Application::_adapter; -Glacier2::RouterPrxPtr Glacier2::Application::_router; -Glacier2::SessionPrxPtr Glacier2::Application::_session; -string Glacier2::Application::_category; - -namespace -{ -#ifndef ICE_CPP11_MAPPING // C++98 -class CloseCallbackI : public Ice::CloseCallback -{ -public: - - CloseCallbackI(Glacier2::Application* app) : _app(app) - { - } - - virtual void - closed(const Ice::ConnectionPtr&) - { - _app->sessionDestroyed(); - } - -private: - - Glacier2::Application* _app; -}; -#endif -} - -string -Glacier2::RestartSessionException::ice_id() const -{ - return "::Glacier2::RestartSessionException"; -} - -#ifndef ICE_CPP11_MAPPING -Glacier2::RestartSessionException* -Glacier2::RestartSessionException::ice_clone() const -{ - return new RestartSessionException(*this); -} -#endif - -Glacier2::Application::Application(SignalPolicy signalPolicy) : - Ice::Application(signalPolicy) -{ -} - -Ice::ObjectAdapterPtr -Glacier2::Application::objectAdapter() -{ - if(!_router) - { - throw SessionNotExistException(); - } - - IceUtil::Mutex::Lock lock(_mutex); - if(!_adapter) - { - _adapter = communicator()->createObjectAdapterWithRouter("", _router); - _adapter->activate(); - } - return _adapter; -} - -Ice::ObjectPrxPtr -Glacier2::Application::addWithUUID(const Ice::ObjectPtr& servant) -{ - return objectAdapter()->add(servant, createCallbackIdentity(Ice::generateUUID())); -} - -Ice::Identity -Glacier2::Application::createCallbackIdentity(const string& name) -{ - Ice::Identity id; - id.name = name; - id.category = categoryForClient(); - return id; -} - -void -Glacier2::Application::sessionDestroyed() -{ -} - -void -Glacier2::Application::restart() -{ - throw RestartSessionException(); -} - -Glacier2::RouterPrxPtr -Glacier2::Application::router() -{ - return _router; -} - -Glacier2::SessionPrxPtr -Glacier2::Application::session() -{ - return _session; -} - -std::string -Glacier2::Application::categoryForClient() -{ - if(!_router) - { - throw SessionNotExistException(); - } - return _category; -} - -int -Glacier2::Application::doMain(int argc, char* argv[], const Ice::InitializationData& initData, int version) -{ - // Set the default properties for all Glacier2 applications. - initData.properties->setProperty("Ice.RetryIntervals", "-1"); - - bool restart; - int ret = 0; - do - { - // - // A copy of the initialization data and the string seq - // needs to be passed to doMainInternal, as these can be - // changed by the application. - // - Ice::InitializationData id(initData); - id.properties = id.properties->clone(); - Ice::StringSeq args = Ice::argsToStringSeq(argc, argv); - - restart = doMain(args, id, ret, version); - } - while(restart); - return ret; -} - -bool -Glacier2::Application::doMain(Ice::StringSeq& args, const Ice::InitializationData& initData, int& status, int version) -{ - // - // Reset internal state variables from Ice.Application. The - // remainder are reset at the end of this method. - // - _callbackInProgress = false; - _destroyed = false; - _interrupted = false; - - bool restart = false; - bool sessionCreated = false; - status = 0; - - try - { - _communicator = Ice::initialize(args, initData, version); - _router = ICE_UNCHECKED_CAST(Glacier2::RouterPrx, communicator()->getDefaultRouter()); - - if(!_router) - { - Error out(getProcessLogger()); - out << _appName << ": no glacier2 router configured"; - status = 1; - } - else - { - // - // The default is to destroy when a signal is received. - // - if(_signalPolicy == ICE_ENUM(SignalPolicy, HandleSignals)) - { - destroyOnInterrupt(); - } - - // If createSession throws, we're done. - try - { - _session = createSession(); - sessionCreated = true; - } - catch(const Ice::LocalException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - status = 1; - } - - if(sessionCreated) - { - Ice::Int acmTimeout = 0; - try - { - acmTimeout = _router->getACMTimeout(); - } - catch(const Ice::OperationNotExistException&) - { - } - if(acmTimeout <= 0) - { - acmTimeout = static_cast<Ice::Int>(_router->getSessionTimeout()); - } - - if(acmTimeout > 0) - { - Ice::ConnectionPtr connection = _router->ice_getCachedConnection(); - assert(connection); - connection->setACM(acmTimeout, IceUtil::None, ICE_ENUM(ACMHeartbeat, HeartbeatAlways)); -#ifdef ICE_CPP11_MAPPING - connection->setCloseCallback( - [this](Ice::ConnectionPtr) - { - sessionDestroyed(); - }); -#else - connection->setCloseCallback(ICE_MAKE_SHARED(CloseCallbackI, this)); -#endif - } - - _category = _router->getCategoryForClient(); - IceInternal::ArgVector a(args); - status = runWithSession(a.argc, a.argv); - } - } - } - // We want to restart on those exceptions which indicate a - // break down in communications, but not those exceptions that - // indicate a programming logic error (ie: marshal, protocol - // failure, etc). - catch(const RestartSessionException&) - { - restart = true; - } - catch(const Ice::ConnectionRefusedException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - restart = true; - } - catch(const Ice::ConnectionLostException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - restart = true; - } - catch(const Ice::UnknownLocalException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - restart = true; - } - catch(const Ice::RequestFailedException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - restart = true; - } - catch(const Ice::TimeoutException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - restart = true; - } - catch(const Ice::LocalException& ex) - { - Error out(getProcessLogger()); - out << _appName << ": " << ex; - status = 1; - } - catch(const std::exception& ex) - { - Error out(getProcessLogger()); - out << _appName << ": std::exception " << ex; - status = 1; - } - catch(const std::string& ex) - { - Error out(getProcessLogger()); - out << _appName << ": c++ exception " << ex; - status = 1; - } - catch(const char* ex) - { - Error out(getProcessLogger()); - out << _appName << ": char* exception " << ex; - status = 1; - } - catch(...) - { - Error out(getProcessLogger()); - out << _appName << ": unknown exception"; - status = 1; - } - - // - // Don't want any new interrupt and at this point (post-run), - // it would not make sense to release a held signal to run - // shutdown or destroy. - // - if(_signalPolicy == ICE_ENUM(SignalPolicy, HandleSignals)) - { - ignoreInterrupt(); - } - - { - IceUtil::Mutex::Lock lock(_mutex); - while(_callbackInProgress) - { - _condVar.wait(lock); - } - if(_destroyed) - { - _communicator = 0; - } - else - { - _destroyed = true; - // - // And _communicator != 0, meaning will be destroyed - // next, _destroyed = true also ensures that any - // remaining callback won't do anything - // - } - _application = 0; - } - - if(sessionCreated && _router) - { - try - { - _router->destroySession(); - } - catch(const Ice::ConnectionLostException&) - { - // Expected if another thread invoked on an object from the session concurrently. - } - catch(const Glacier2::SessionNotExistException&) - { - // This can also occur. - } - catch(const exception& ex) - { - // Not expected. - Error out(getProcessLogger()); - out << "unexpected exception when destroying the session:\n" << ex; - } - _router = 0; - } - - if(_communicator) - { - _communicator->destroy(); - _communicator = 0; - } - - // - // Reset internal state. We cannot reset the Application state - // here, since _destroyed must remain true until we re-run - // this method. - // - _adapter = 0; - _router = 0; - _session = 0; - _category.clear(); - - return restart; -} |