Mercurial > hg > orthanc-stone

comparison Framework/Messages/IObservable.cpp @ 1148:5e164c629923 broker

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
timing
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 15 Nov 2019 10:42:16 +0100
parents 08cc0d47aa94
children 0ca50d275b9a
comparison
equal deleted inserted replaced
1147:bc27c199eefe 1148:5e164c629923
56 } 56 }
57 57
58 void IObservable::EmitMessageInternal(const IObserver* receiver, 58 void IObservable::EmitMessageInternal(const IObserver* receiver,
59 const IMessage& message) 59 const IMessage& message)
60 { 60 {
61 LOG(TRACE) << "IObservable::EmitMessageInternal receiver = " 61 //LOG(TRACE) << "IObservable::EmitMessageInternal receiver = " << std::hex << receiver << std::dec;
62 << std::hex << receiver << std::dec;
63 Callables::const_iterator found = callables_.find(message.GetIdentifier()); 62 Callables::const_iterator found = callables_.find(message.GetIdentifier());
64 63
65 if (found != callables_.end()) 64 if (found != callables_.end())
66 { 65 {
67 for (std::set<ICallable*>::const_iterator 66 for (std::set<ICallable*>::const_iterator
111 110
112 111
113 void IObservable::EmitMessage(boost::weak_ptr<IObserver> observer, 112 void IObservable::EmitMessage(boost::weak_ptr<IObserver> observer,
114 const IMessage& message) 113 const IMessage& message)
115 { 114 {
116 LOG(TRACE) << "IObservable::EmitMessage observer = " 115 //LOG(TRACE) << "IObservable::EmitMessage observer = " << std::hex << &observer << std::dec;
117 << std::hex << &observer << std::dec;
118 116
119 boost::shared_ptr<IObserver> lock(observer.lock()); 117 boost::shared_ptr<IObserver> lock(observer.lock());
120 if (lock) 118 if (lock)
121 { 119 {
122 EmitMessageInternal(lock.get(), message); 120 EmitMessageInternal(lock.get(), message);