diff options
Diffstat (limited to 'cells-impl.hpp')
-rw-r--r-- | cells-impl.hpp | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/cells-impl.hpp b/cells-impl.hpp index 86d7c98..deae2fd 100644 --- a/cells-impl.hpp +++ b/cells-impl.hpp @@ -58,6 +58,29 @@ namespace cells { static thread_local dynvar<std::forward_list<observer*>> current_dependencies; static thread_local dynvar<transaction> current_transaction; + inline observer::observer() : self(std::make_shared<observer*>(this)) { }; + + inline observer::observer(observer const& other) : self(std::make_shared<observer*>(this)) { + reset_dependents(other.dependents); + reset_dependencies(other.dependencies); + } + + inline observer& observer::operator =(observer const& other) { + reset_dependents(other.dependents); + reset_dependencies(other.dependencies); + return *this; + } + + inline void observer::reset_dependents(std::list<std::weak_ptr<observer*>> const& new_dependents) { + for (auto const& dependent : dependents) { + std::shared_ptr<observer*> sdependent = dependent.lock(); + if (sdependent) { + remove_dependent(*sdependent); + } + } + dependents = new_dependents; + } + inline void observer::clear_dependencies() { for (auto const& dep : dependencies) { std::shared_ptr<observer*> sdep = dep.lock(); @@ -79,6 +102,17 @@ namespace cells { }); } + inline void observer::reset_dependencies(std::forward_list<std::weak_ptr<observer*>> const& newdeps) { + clear_dependencies(); + dependencies = newdeps; + for (auto const& dep : newdeps) { + shared_ptr<observer*> p = dep.lock(); + if (p) { + (*p)->add_dependent(this); + } + } + } + inline void observer::reset_dependencies(std::forward_list<observer*> const& newdeps) { clear_dependencies(); for (auto const& dep : newdeps) { |