--- /dev/null
+/*\r
+ * Copyright 2001-2005 Internet2\r
+ * \r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+\r
+/**\r
+ * ChainingMetadataProvider.cpp\r
+ * \r
+ * MetadataProvider that uses multiple providers in sequence.\r
+ */\r
+\r
+#include "internal.h"\r
+#include "exceptions.h"\r
+#include "saml2/metadata/ChainingMetadataProvider.h"\r
+\r
+#include <xmltooling/util/XMLHelper.h>\r
+#include <xercesc/util/XMLUniDefs.hpp>\r
+\r
+using namespace opensaml::saml2md;\r
+using namespace opensaml;\r
+using namespace xmlsignature;\r
+using namespace xmltooling;\r
+using namespace std;\r
+\r
+namespace opensaml {\r
+ namespace saml2md {\r
+ MetadataProvider* SAML_DLLLOCAL ChainingMetadataProviderFactory(const DOMElement* const & e)\r
+ {\r
+ return new ChainingMetadataProvider(e);\r
+ }\r
+ };\r
+};\r
+\r
+static const XMLCh GenericMetadataProvider[] = UNICODE_LITERAL_16(M,e,t,a,d,a,t,a,P,r,o,v,i,d,e,r);\r
+static const XMLCh type[] = UNICODE_LITERAL_4(t,y,p,e);\r
+\r
+ChainingMetadataProvider::ChainingMetadataProvider(const DOMElement* e) : ObservableMetadataProvider(e), m_tlsKey(NULL)\r
+{\r
+ try {\r
+ e = e ? xmltooling::XMLHelper::getFirstChildElement(e, GenericMetadataProvider) : NULL;\r
+ while (e) {\r
+ auto_ptr_char temp(e->getAttributeNS(NULL,type));\r
+ if (temp.get()) {\r
+ auto_ptr<MetadataProvider> provider(\r
+ SAMLConfig::getConfig().MetadataProviderManager.newPlugin(temp.get(), e)\r
+ );\r
+ ObservableMetadataProvider* obs = dynamic_cast<ObservableMetadataProvider*>(provider.get());\r
+ if (obs)\r
+ obs->addObserver(this);\r
+ m_providers.push_back(provider.get());\r
+ provider.release();\r
+ }\r
+ e = XMLHelper::getNextSiblingElement(e, GenericMetadataProvider);\r
+ }\r
+ }\r
+ catch (XMLToolingException&) {\r
+ for_each(m_providers.begin(), m_providers.end(), xmltooling::cleanup<MetadataProvider>());\r
+ throw;\r
+ }\r
+ m_tlsKey = ThreadKey::create(NULL);\r
+}\r
+\r
+ChainingMetadataProvider::~ChainingMetadataProvider()\r
+{\r
+ delete m_tlsKey;\r
+ for_each(m_providers.begin(), m_providers.end(), xmltooling::cleanup<MetadataProvider>());\r
+}\r
+\r
+void ChainingMetadataProvider::onEvent(MetadataProvider& provider)\r
+{\r
+ emitChangeEvent();\r
+}\r
+\r
+void ChainingMetadataProvider::init()\r
+{\r
+ for_each(m_providers.begin(), m_providers.end(), mem_fun<void,MetadataProvider>(&MetadataProvider::init));\r
+}\r
+\r
+Lockable* ChainingMetadataProvider::lock()\r
+{\r
+ return this; // we're not lockable ourselves...\r
+}\r
+\r
+void ChainingMetadataProvider::unlock()\r
+{\r
+ // Check for a locked provider.\r
+ void* ptr=m_tlsKey->getData();\r
+ if (ptr) {\r
+ m_tlsKey->setData(NULL);\r
+ reinterpret_cast<MetadataProvider*>(ptr)->unlock();\r
+ }\r
+}\r
+\r
+const KeyResolver* ChainingMetadataProvider::getKeyResolver() const\r
+{\r
+ // Check for a locked provider.\r
+ void* ptr=m_tlsKey->getData();\r
+ return ptr ? reinterpret_cast<MetadataProvider*>(ptr)->getKeyResolver() : NULL;\r
+ \r
+}\r
+\r
+const XMLObject* ChainingMetadataProvider::getMetadata() const\r
+{\r
+ throw XMLToolingException("getMetadata operation not implemented on this provider.");\r
+}\r
+\r
+const EntitiesDescriptor* ChainingMetadataProvider::getEntitiesDescriptor(const char* name, bool requireValidMetadata) const\r
+{\r
+ // Clear any existing lock.\r
+ const_cast<ChainingMetadataProvider*>(this)->unlock();\r
+\r
+ // Do a search.\r
+ const EntitiesDescriptor* ret=NULL;\r
+ for (vector<MetadataProvider*>::const_iterator i=m_providers.begin(); i!=m_providers.end(); ++i) {\r
+ (*i)->lock();\r
+ if (ret=(*i)->getEntitiesDescriptor(name,requireValidMetadata)) {\r
+ // Save locked provider.\r
+ m_tlsKey->setData(*i);\r
+ return ret;\r
+ }\r
+ (*i)->unlock();\r
+ }\r
+\r
+ return NULL;\r
+}\r
+\r
+const EntityDescriptor* ChainingMetadataProvider::getEntityDescriptor(const char* id, bool requireValidMetadata) const\r
+{\r
+ // Clear any existing lock.\r
+ const_cast<ChainingMetadataProvider*>(this)->unlock();\r
+\r
+ // Do a search.\r
+ const EntityDescriptor* ret=NULL;\r
+ for (vector<MetadataProvider*>::const_iterator i=m_providers.begin(); i!=m_providers.end(); ++i) {\r
+ (*i)->lock();\r
+ if (ret=(*i)->getEntityDescriptor(id,requireValidMetadata)) {\r
+ // Save locked provider.\r
+ m_tlsKey->setData(*i);\r
+ return ret;\r
+ }\r
+ (*i)->unlock();\r
+ }\r
+\r
+ return NULL;\r
+}\r
+\r
+const EntityDescriptor* ChainingMetadataProvider::getEntityDescriptor(const SAMLArtifact* artifact) const\r
+{\r
+ // Clear any existing lock.\r
+ const_cast<ChainingMetadataProvider*>(this)->unlock();\r
+\r
+ // Do a search.\r
+ const EntityDescriptor* ret=NULL;\r
+ for (vector<MetadataProvider*>::const_iterator i=m_providers.begin(); i!=m_providers.end(); ++i) {\r
+ (*i)->lock();\r
+ if (ret=(*i)->getEntityDescriptor(artifact)) {\r
+ // Save locked provider.\r
+ m_tlsKey->setData(*i);\r
+ return ret;\r
+ }\r
+ (*i)->unlock();\r
+ }\r
+\r
+ return NULL;\r
+}\r
projects / shibboleth / opensaml2.git / blobdiff