saml/saml2/metadata/impl/ObservableMetadataProvider.cpp

   1 /*
   2  *  Copyright 2009-2010 Internet2
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 /**
  18  * ObservableMetadataProvider.cpp
  19  *
  20  * A metadata provider that notifies interested parties of changes.
  21  */
  22
  23 #include "internal.h"
  24 #include "saml2/metadata/ObservableMetadataProvider.h"
  25
  26 #include <xmltooling/util/Threads.h>
  27
  28 using namespace opensaml::saml2md;
  29 using namespace xmltooling;
  30 using namespace std;
  31
  32 ObservableMetadataProvider::ObservableMetadataProvider(const xercesc::DOMElement* e)
  33     : MetadataProvider(e), m_observerLock(Mutex::create())
  34 {
  35 }
  36
  37 ObservableMetadataProvider::~ObservableMetadataProvider()
  38 {
  39     delete m_observerLock;
  40 }
  41
  42 void ObservableMetadataProvider::emitChangeEvent() const
  43 {
  44     Lock lock(m_observerLock);
  45     for (vector<const Observer*>::const_iterator i=m_observers.begin(); i!=m_observers.end(); i++) {
  46         (*i)->onEvent(*this);
  47     }
  48 }
  49
  50 void ObservableMetadataProvider::addObserver(const Observer* newObserver) const
  51 {
  52     Lock lock(m_observerLock);
  53     m_observers.push_back(newObserver);
  54 }
  55
  56 const ObservableMetadataProvider::Observer* ObservableMetadataProvider::removeObserver(const Observer* oldObserver) const
  57 {
  58     Lock lock(m_observerLock);
  59     for (vector<const Observer*>::iterator i=m_observers.begin(); i!=m_observers.end(); i++) {
  60         if (oldObserver==(*i)) {
  61             m_observers.erase(i);
  62             return oldObserver;
  63         }
  64     }
  65     return nullptr;
  66 }
  67
  68 ObservableMetadataProvider::Observer::Observer()
  69 {
  70 }
  71
  72 ObservableMetadataProvider::Observer::~Observer()
  73 {
  74 }