diff options
| author | Marc Laukien <marc@zeroc.com> | 2004-01-19 16:06:44 +0000 |
|---|---|---|
| committer | Marc Laukien <marc@zeroc.com> | 2004-01-19 16:06:44 +0000 |
| commit | dc9c65936ebe3632fa121d4db8960b1b0135d690 (patch) | |
| tree | 448ab51d29b013bda7a15ebfd6fad08992b4fffe /cpp/test/IceStorm/federation/Subscriber.cpp | |
| parent | timeout fix (diff) | |
| download | ice-dc9c65936ebe3632fa121d4db8960b1b0135d690.tar.bz2 ice-dc9c65936ebe3632fa121d4db8960b1b0135d690.tar.xz ice-dc9c65936ebe3632fa121d4db8960b1b0135d690.zip | |
fixes
Diffstat (limited to 'cpp/test/IceStorm/federation/Subscriber.cpp')
| -rw-r--r-- | cpp/test/IceStorm/federation/Subscriber.cpp | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/cpp/test/IceStorm/federation/Subscriber.cpp b/cpp/test/IceStorm/federation/Subscriber.cpp index ecacac9f19d..c0b349ea7a7 100644 --- a/cpp/test/IceStorm/federation/Subscriber.cpp +++ b/cpp/test/IceStorm/federation/Subscriber.cpp @@ -30,7 +30,7 @@ using namespace std; using namespace Ice; using namespace IceStorm; -class EventI : public Event +class EventI : public Event, public IceUtil::Mutex { public: @@ -40,8 +40,11 @@ public: { } - virtual void pub(const string& data, const Ice::Current&) + virtual void + pub(const string& data, const Ice::Current&) { + IceUtil::Mutex::Lock sync(*this); + if(data == "shutdown") { _communicator->shutdown(); @@ -50,7 +53,13 @@ public: ++_count; } - int count() const { return _count; } + int + count() const + { + IceUtil::Mutex::Lock sync(*this); + + return _count; + } private: |