Mercurial > hg > orthanc-stone
comparison Framework/Messages/IObservable.cpp @ 1148:5e164c629923 broker
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); |