diff options
author | Marc Laukien <marc@zeroc.com> | 2001-08-14 11:52:47 +0000 |
---|---|---|
committer | Marc Laukien <marc@zeroc.com> | 2001-08-14 11:52:47 +0000 |
commit | 91a394a09d9684d20cfa4c941cebb6b3579b9666 (patch) | |
tree | eb99bdac118a23814e1dfcd8d4e5fc64a9c8f0cc /cpp/src/Ice/ObjectAdapterFactory.cpp | |
parent | locator (diff) | |
download | ice-91a394a09d9684d20cfa4c941cebb6b3579b9666.tar.bz2 ice-91a394a09d9684d20cfa4c941cebb6b3579b9666.tar.xz ice-91a394a09d9684d20cfa4c941cebb6b3579b9666.zip |
changed directory structure
Diffstat (limited to 'cpp/src/Ice/ObjectAdapterFactory.cpp')
-rw-r--r-- | cpp/src/Ice/ObjectAdapterFactory.cpp | 69 |
1 files changed, 69 insertions, 0 deletions
diff --git a/cpp/src/Ice/ObjectAdapterFactory.cpp b/cpp/src/Ice/ObjectAdapterFactory.cpp new file mode 100644 index 00000000000..0df7b32816f --- /dev/null +++ b/cpp/src/Ice/ObjectAdapterFactory.cpp @@ -0,0 +1,69 @@ +// ********************************************************************** +// +// Copyright (c) 2001 +// MutableRealms, Inc. +// Huntsville, AL, USA +// +// All Rights Reserved +// +// ********************************************************************** + +#include <Ice/ObjectAdapterFactory.h> +#include <Ice/ObjectAdapterI.h> +#include <Ice/Functional.h> + + +#include <Ice/Instance.h> + +using namespace std; +using namespace Ice; +using namespace IceInternal; + +void IceInternal::incRef(ObjectAdapterFactory* p) { p->__incRef(); } +void IceInternal::decRef(ObjectAdapterFactory* p) { p->__decRef(); } + +void +IceInternal::ObjectAdapterFactory::shutdown() +{ + JTCSyncT<JTCMutex> sync(*this); + for_each(_adapters.begin(), _adapters.end(), secondVoidMemFun<string, ObjectAdapter>(&ObjectAdapter::deactivate)); + _adapters.clear(); +} + +ObjectAdapterPtr +IceInternal::ObjectAdapterFactory::createObjectAdapter(const string& name, const string& endpts) +{ + JTCSyncT<JTCMutex> sync(*this); + map<string, ObjectAdapterPtr>::iterator p = _adapters.find(name); + if (p != _adapters.end()) + { + return p->second; + } + + ObjectAdapterPtr adapter = new ObjectAdapterI(_instance, name, endpts); + _adapters.insert(make_pair(name, adapter)); + return adapter; +} + +ObjectPtr +IceInternal::ObjectAdapterFactory::proxyToObject(const ObjectPrx& proxy) +{ + map<string, ObjectAdapterPtr>::iterator p; + for (p = _adapters.begin(); p != _adapters.end(); ++p) + { + try + { + return p->second->proxyToObject(proxy); + } + catch(const WrongObjectAdapterException&) + { + } + } + + return 0; +} + +IceInternal::ObjectAdapterFactory::ObjectAdapterFactory(const InstancePtr& instance) : + _instance(instance) +{ +} |