diff options
| author | Matthew Newhook <matthew@zeroc.com> | 2006-11-14 00:21:06 +0000 |
|---|---|---|
| committer | Matthew Newhook <matthew@zeroc.com> | 2006-11-14 00:21:06 +0000 |
| commit | b902465227fd20c9e9fe30cf251e2611c682f7ce (patch) | |
| tree | 24055cded291dc6282b16f7fd34d85761b688780 /cpp/src/IceStorm/SubscriberPool.cpp | |
| parent | Fix (diff) | |
| download | ice-b902465227fd20c9e9fe30cf251e2611c682f7ce.tar.bz2 ice-b902465227fd20c9e9fe30cf251e2611c682f7ce.tar.xz ice-b902465227fd20c9e9fe30cf251e2611c682f7ce.zip | |
http://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1549
Diffstat (limited to 'cpp/src/IceStorm/SubscriberPool.cpp')
| -rw-r--r-- | cpp/src/IceStorm/SubscriberPool.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/cpp/src/IceStorm/SubscriberPool.cpp b/cpp/src/IceStorm/SubscriberPool.cpp index 26d99dee299..4f1e568583c 100644 --- a/cpp/src/IceStorm/SubscriberPool.cpp +++ b/cpp/src/IceStorm/SubscriberPool.cpp @@ -206,6 +206,14 @@ SubscriberPool::flush(list<SubscriberPtr>& subscribers) } void +SubscriberPool::flush(const SubscriberPtr& subscriber) +{ + Lock sync(*this); + _pending.push_back(subscriber); + notify(); +} + +void SubscriberPool::add(const SubscriberPtr& subscriber) { Lock sync(*this); |