diff options
author | Dwayne Boone <dwayne@zeroc.com> | 2014-11-04 09:40:19 -0330 |
---|---|---|
committer | Dwayne Boone <dwayne@zeroc.com> | 2014-11-04 09:40:19 -0330 |
commit | bab355fce9f866adf7ed54bc22f7d9682f2a03c6 (patch) | |
tree | b56c0b9f22a38cc9121e17e45ade207d7837b364 /cpp/src/IceGrid/AdminSessionI.cpp | |
parent | Minor CHANGES typo fix (diff) | |
download | ice-bab355fce9f866adf7ed54bc22f7d9682f2a03c6.tar.bz2 ice-bab355fce9f866adf7ed54bc22f7d9682f2a03c6.tar.xz ice-bab355fce9f866adf7ed54bc22f7d9682f2a03c6.zip |
Windows build fix
Diffstat (limited to 'cpp/src/IceGrid/AdminSessionI.cpp')
-rw-r--r-- | cpp/src/IceGrid/AdminSessionI.cpp | 60 |
1 files changed, 30 insertions, 30 deletions
diff --git a/cpp/src/IceGrid/AdminSessionI.cpp b/cpp/src/IceGrid/AdminSessionI.cpp index 23d544852eb..5760bf5c934 100644 --- a/cpp/src/IceGrid/AdminSessionI.cpp +++ b/cpp/src/IceGrid/AdminSessionI.cpp @@ -30,23 +30,23 @@ class SubscriberForwarderI : public Ice::BlobjectArrayAsync { public: - virtual void + virtual void exception(const Ice::Exception& ex, const Ice::AMD_Object_ice_invokePtr& amdCB) { try { ex.ice_throw(); } - catch(const Ice::Exception& ex) + catch(const Ice::Exception&) { // Throw ObjectNotExistException, the subscriber is unreachable amdCB->ice_exception(Ice::ObjectNotExistException(__FILE__, __LINE__)); } } - + virtual void - response(bool ok, - const pair<const Ice::Byte*, const Ice::Byte*>& outP, + response(bool ok, + const pair<const Ice::Byte*, const Ice::Byte*>& outP, const Ice::AMD_Object_ice_invokePtr& amdCB) { amdCB->ice_response(ok, outP); @@ -55,13 +55,13 @@ class SubscriberForwarderI : public Ice::BlobjectArrayAsync public: - SubscriberForwarderI(const Ice::ObjectPrx& proxy) : + SubscriberForwarderI(const Ice::ObjectPrx& proxy) : _proxy(proxy), _callback(newCallback_Object_ice_invoke(new CallbackI(), &CallbackI::response, &CallbackI::exception)) { } - virtual void + virtual void ice_invoke_async(const Ice::AMD_Object_ice_invokePtr& amdCB, const pair<const Ice::Byte*, const Ice::Byte*>& inParams, const Ice::Current& current) @@ -72,13 +72,13 @@ public: private: const Ice::ObjectPrx _proxy; - const Ice::Callback_Object_ice_invokePtr _callback; + const Ice::Callback_Object_ice_invokePtr _callback; }; } -FileIteratorI::FileIteratorI(const AdminSessionIPtr& session, - const FileReaderPrx& reader, +FileIteratorI::FileIteratorI(const AdminSessionIPtr& session, + const FileReaderPrx& reader, const string& filename, Ice::Long offset, int messageSizeMax) : @@ -137,11 +137,11 @@ AdminSessionI::_register(const SessionServantManagerPtr& servantManager, const I if(con) { category = _database->getInstanceName() + "-" + IceUtil::generateUUID(); - + Ice::Identity templateId; templateId.name = "pick-a-name"; templateId.category = category; - + _adminCallbackTemplate = _registry->createAdminCallbackProxy(templateId); } @@ -165,8 +165,8 @@ AdminSessionI::getAdminCallbackTemplate(const Ice::Current&) const } void -AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, - const NodeObserverPrx& nodeObserver, +AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, + const NodeObserverPrx& nodeObserver, const ApplicationObserverPrx& appObserver, const AdapterObserverPrx& adapterObserver, const ObjectObserverPrx& objectObserver, @@ -184,7 +184,7 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, const Ice::LocatorPrx l = _registry->getLocator(); if(registryObserver) { - setupObserverSubscription(RegistryObserverTopicName, + setupObserverSubscription(RegistryObserverTopicName, addForwarder(registryObserver->ice_timeout(t)->ice_locator(l))); } else @@ -194,7 +194,7 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, if(nodeObserver) { - setupObserverSubscription(NodeObserverTopicName, + setupObserverSubscription(NodeObserverTopicName, addForwarder(nodeObserver->ice_timeout(t)->ice_locator(l))); } else @@ -204,7 +204,7 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, if(appObserver) { - setupObserverSubscription(ApplicationObserverTopicName, + setupObserverSubscription(ApplicationObserverTopicName, addForwarder(appObserver->ice_timeout(t)->ice_locator(l))); } else @@ -221,10 +221,10 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, { setupObserverSubscription(AdapterObserverTopicName, Ice::ObjectPrx()); } - + if(objectObserver) { - setupObserverSubscription(ObjectObserverTopicName, + setupObserverSubscription(ObjectObserverTopicName, addForwarder(objectObserver->ice_timeout(t)->ice_locator(l))); } else @@ -234,7 +234,7 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, } void -AdminSessionI::setObserversByIdentity(const Ice::Identity& registryObserver, +AdminSessionI::setObserversByIdentity(const Ice::Identity& registryObserver, const Ice::Identity& nodeObserver, const Ice::Identity& appObserver, const Ice::Identity& adapterObserver, @@ -305,7 +305,7 @@ AdminSessionI::openServerLog(const string& id, const string& path, int nLines, c } } -FileIteratorPrx +FileIteratorPrx AdminSessionI::openServerStdOut(const string& id, int nLines, const Ice::Current& current) { try @@ -319,7 +319,7 @@ AdminSessionI::openServerStdOut(const string& id, int nLines, const Ice::Current } } -FileIteratorPrx +FileIteratorPrx AdminSessionI::openServerStdErr(const string& id, int nLines, const Ice::Current& current) { try @@ -333,19 +333,19 @@ AdminSessionI::openServerStdErr(const string& id, int nLines, const Ice::Current } } -FileIteratorPrx +FileIteratorPrx AdminSessionI::openNodeStdOut(const string& name, int nLines, const Ice::Current& current) { return addFileIterator(_database->getNode(name)->getProxy(), "stdout", nLines, current); } -FileIteratorPrx +FileIteratorPrx AdminSessionI::openNodeStdErr(const string& name, int nLines, const Ice::Current& current) { return addFileIterator(_database->getNode(name)->getProxy(), "stderr", nLines, current); } -FileIteratorPrx +FileIteratorPrx AdminSessionI::openRegistryStdOut(const string& name, int nLines, const Ice::Current& current) { FileReaderPrx reader; @@ -405,7 +405,7 @@ AdminSessionI::setupObserverSubscription(TopicName name, const Ice::ObjectPrx& o { _observers[name].first = observer; _observers[name].second = forwarder; - _database->getObserverTopic(name)->subscribe(observer); + _database->getObserverTopic(name)->subscribe(observer); } } @@ -499,7 +499,7 @@ AdminSessionFactory::AdminSessionFactory(const SessionServantManagerPtr& servant const ReapThreadPtr& reaper, const RegistryIPtr& registry) : _servantManager(servantManager), - _database(database), + _database(database), _timeout(registry->getSessionTimeout()), _reaper(reaper), _registry(registry), @@ -532,7 +532,7 @@ AdminSessionFactory::createGlacier2Session(const string& sessionId, const Glacie queryId.category = _database->getInstanceName(); queryId.name = "Query"; ids.push_back(queryId); - + _servantManager->setSessionControl(session, ctl, ids); } timeout = ctl->getSessionTimeout(); @@ -563,7 +563,7 @@ AdminSessionFactory::createSessionServant(const string& id) const TraceLevelsPtr& AdminSessionFactory::getTraceLevels() const { - return _database->getTraceLevels(); + return _database->getTraceLevels(); } AdminSessionManagerI::AdminSessionManagerI(const AdminSessionFactoryPtr& factory) : _factory(factory) @@ -581,7 +581,7 @@ AdminSSLSessionManagerI::AdminSSLSessionManagerI(const AdminSessionFactoryPtr& f } Glacier2::SessionPrx -AdminSSLSessionManagerI::create(const Glacier2::SSLInfo& info, +AdminSSLSessionManagerI::create(const Glacier2::SSLInfo& info, const Glacier2::SessionControlPrx& ctl, const Ice::Current&) { |