diff options
author | Benoit Foucher <benoit@zeroc.com> | 2009-10-07 18:18:37 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2009-10-07 18:18:37 +0200 |
commit | 5fc2dc27228263e4c56ba3a49852ab3f8c724299 (patch) | |
tree | a1340491094705a1e604a3df22ec4dad0c8d1a8e /cpp/src/IceGrid/Topics.cpp | |
parent | Bug 4251 - add IceUtil::Time double initializers (diff) | |
download | ice-5fc2dc27228263e4c56ba3a49852ab3f8c724299.tar.bz2 ice-5fc2dc27228263e4c56ba3a49852ab3f8c724299.tar.xz ice-5fc2dc27228263e4c56ba3a49852ab3f8c724299.zip |
- Bug 4286: added support for IceStorm/IceGrid database plugins
- Fixed IceGrid database code to first save to the database and then
do state changes.
Diffstat (limited to 'cpp/src/IceGrid/Topics.cpp')
-rw-r--r-- | cpp/src/IceGrid/Topics.cpp | 45 |
1 files changed, 9 insertions, 36 deletions
diff --git a/cpp/src/IceGrid/Topics.cpp b/cpp/src/IceGrid/Topics.cpp index 1825d7d5e49..8cdec342096 100644 --- a/cpp/src/IceGrid/Topics.cpp +++ b/cpp/src/IceGrid/Topics.cpp @@ -496,19 +496,10 @@ NodeObserverTopic::initObserver(const Ice::ObjectPrx& obsv) } ApplicationObserverTopic::ApplicationObserverTopic(const IceStorm::TopicManagerPrx& topicManager, - const StringApplicationInfoDict& applications) : - ObserverTopic(topicManager, "ApplicationObserver") -#ifndef _RWSTD_NO_MEMBER_TEMPLATES - ,_applications(applications.begin(), applications.end()) -#endif + const map<string, ApplicationInfo>& applications) : + ObserverTopic(topicManager, "ApplicationObserver"), + _applications(applications) { -#ifdef _RWSTD_NO_MEMBER_TEMPLATES - for(StringApplicationInfoDict::const_iterator p = applications.begin(); p != applications.end(); ++p) - { - _applications[p->first] = p->second; - } -#endif - const_cast<ApplicationObserverPrx&>(_publisher) = ApplicationObserverPrx::uncheckedCast(_basePublisher); } @@ -653,19 +644,10 @@ ApplicationObserverTopic::initObserver(const Ice::ObjectPrx& obsv) } AdapterObserverTopic::AdapterObserverTopic(const IceStorm::TopicManagerPrx& topicManager, - const StringAdapterInfoDict& adapters) : - ObserverTopic(topicManager, "AdapterObserver") -#ifndef _RWSTD_NO_MEMBER_TEMPLATES - , _adapters(adapters.begin(), adapters.end()) -#endif + const map<string, AdapterInfo>& adapters) : + ObserverTopic(topicManager, "AdapterObserver"), + _adapters(adapters) { -#ifdef _RWSTD_NO_MEMBER_TEMPLATES - for(StringAdapterInfoDict::const_iterator p = adapters.begin(); p != adapters.end(); ++p) - { - _adapters[p->first] = p->second; - } -#endif - const_cast<AdapterObserverPrx&>(_publisher) = AdapterObserverPrx::uncheckedCast(_basePublisher); } @@ -778,19 +760,10 @@ AdapterObserverTopic::initObserver(const Ice::ObjectPrx& obsv) } ObjectObserverTopic::ObjectObserverTopic(const IceStorm::TopicManagerPrx& topicManager, - const IdentityObjectInfoDict& objects) : - ObserverTopic(topicManager, "ObjectObserver") -#ifndef _RWSTD_NO_MEMBER_TEMPLATES - , _objects(objects.begin(), objects.end()) -#endif + const map<Ice::Identity, ObjectInfo>& objects) : + ObserverTopic(topicManager, "ObjectObserver"), + _objects(objects) { -#ifdef _RWSTD_NO_MEMBER_TEMPLATES - for(IdentityObjectInfoDict::const_iterator p = objects.begin(); p != objects.end(); ++p) - { - _objects[p->first] = p->second; - } -#endif - const_cast<ObjectObserverPrx&>(_publisher) = ObjectObserverPrx::uncheckedCast(_basePublisher); } |