Skip to content
Snippets Groups Projects
Select Git revision
  • 73f602fc70a7f2cbbb144ce288042a3b3e2009be
  • master default protected
  • release/202005
  • release/202001
  • release/201912
  • release/201911
  • release/releaseWindowsTestOne
  • release/windowsReleaseTest
  • release/releaseTest
  • release/releaseWindowsTest
  • release/201910
  • release/qt/201910
  • release/windows-test/201910
  • release/201908
  • release/201906
  • release/201905
  • release/201904
  • release/201903
  • release/201902
  • release/201901
  • release/201812
  • 4.0.0
  • 2.2.0
  • 2.1.0
  • 2.0.1
  • 2.0.0
  • 1.4.1
  • 1.4.0
  • 1.3.0
  • 1.2.0
  • 1.1.0
31 results

observer.h

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    observer.h 2.94 KiB
    /*
     *  Copyright (C) 2004-2020 Savoir-faire Linux Inc.
     *
     *  Author: Guillaume Roguez <Guillaume.Roguez@savoirfairelinux.com>
     *  Author: Adrien Béraud <adrien.beraud@savoirfairelinux.com>
     *
     *  This program is free software; you can redistribute it and/or modify
     *  it under the terms of the GNU General Public License as published by
     *  the Free Software Foundation; either version 3 of the License, or
     *  (at your option) any later version.
     *
     *  This program is distributed in the hope that it will be useful,
     *  but WITHOUT ANY WARRANTY; without even the implied warranty of
     *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     *  GNU General Public License for more details.
     *
     *  You should have received a copy of the GNU General Public License
     *  along with this program; if not, write to the Free Software
     *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA.
     */
    
    #pragma once
    
    #include "noncopyable.h"
    
    #include <cstdlib>
    #include <cstdint>
    #include <memory>
    #include <set>
    #include <mutex>
    #include <functional>
    #include <ciso646> // fix windows compiler bug
    
    namespace jami {
    
    template <typename T> class Observer;
    template <typename T> class Observable;
    
    /*=== Observable =============================================================*/
    
    template <typename T>
    class Observable
    {
    public:
        Observable() : mutex_(), observers_() {}
    
        virtual ~Observable() {
            std::lock_guard<std::mutex> lk(mutex_);
            for (auto& o : observers_)
                o->detached(this);
        };
    
        bool attach(Observer<T>* o) {
            std::lock_guard<std::mutex> lk(mutex_);
            if (o and observers_.insert(o).second) {
                o->attached(this);
                return true;
            }
            return false;
        }
    
        bool detach(Observer<T>* o) {
            std::lock_guard<std::mutex> lk(mutex_);
            if (o and observers_.erase(o)) {
                o->detached(this);
                return true;
            }
            return false;
        }
    
        int getObserversCount() {
            std::lock_guard<std::mutex> lk(mutex_);
            return observers_.size();
        }
    
    protected:
        void notify(T data) {
            std::lock_guard<std::mutex> lk(mutex_);
            for (auto observer : observers_)
                observer->update(this, data);
        }
    
    private:
        NON_COPYABLE(Observable<T>);
    
        std::mutex mutex_; // lock observers_
        std::set<Observer<T>*> observers_;
    };
    
    /*=== Observer =============================================================*/
    
    template <typename T>
    class Observer
    {
    public:
        virtual ~Observer() {};
        virtual void update(Observable<T>*, const T&) = 0;
        virtual void attached(Observable<T>*) {};
        virtual void detached(Observable<T>*) {};
    };
    
    
    template <typename T>
    class FuncObserver : public Observer<T>
    {
    public:
        using F = std::function<void(const T&)>;
        FuncObserver(F f) : f_(f) {};
        virtual ~FuncObserver() {};
        void update(Observable<T>*, const T& t) override { f_(t); }
    private:
        F f_;
    };
    
    }; // namespace jami