diff options
| author | Matthew Newhook <matthew@zeroc.com> | 2001-12-27 18:38:22 +0000 |
|---|---|---|
| committer | Matthew Newhook <matthew@zeroc.com> | 2001-12-27 18:38:22 +0000 |
| commit | ca2b7f71b4133faf486a677b3744904c0f759471 (patch) | |
| tree | 2ea5e06f611c338f8160a0c3bd36d069118926fe /cpp/src/IceStorm/TopicManagerI.cpp | |
| parent | file run.py was initially added on branch IceThread. (diff) | |
| download | ice-ca2b7f71b4133faf486a677b3744904c0f759471.tar.bz2 ice-ca2b7f71b4133faf486a677b3744904c0f759471.tar.xz ice-ca2b7f71b4133faf486a677b3744904c0f759471.zip | |
IceThread merge.
Diffstat (limited to 'cpp/src/IceStorm/TopicManagerI.cpp')
| -rw-r--r-- | cpp/src/IceStorm/TopicManagerI.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/IceStorm/TopicManagerI.cpp b/cpp/src/IceStorm/TopicManagerI.cpp index 0a3722fd261..9cf3616b867 100644 --- a/cpp/src/IceStorm/TopicManagerI.cpp +++ b/cpp/src/IceStorm/TopicManagerI.cpp @@ -70,7 +70,7 @@ TopicPrx TopicManagerI::create(const string& name, const Ice::Current&) { // TODO: reader/writer mutex - JTCSyncT<JTCMutex> sync(*this); + IceUtil::Mutex::Lock sync(*this); reap(); @@ -95,7 +95,7 @@ TopicManagerI::create(const string& name, const Ice::Current&) TopicPrx TopicManagerI::retrieve(const string& name, const Ice::Current&) { - JTCSyncT<JTCMutex> sync(*this); + IceUtil::Mutex::Lock sync(*this); reap(); @@ -125,7 +125,7 @@ transformToTopicDict(TopicIMap::value_type p, Ice::ObjectAdapterPtr adapter) TopicDict TopicManagerI::retrieveAll(const Ice::Current&) { - JTCSyncT<JTCMutex> sync(*this); + IceUtil::Mutex::Lock sync(*this); reap(); @@ -140,7 +140,7 @@ void TopicManagerI::subscribe(const string& id, const QoS& qos, const StringSeq& topics, const Ice::ObjectPrx& tmpl, const Ice::Current&) { - JTCSyncT<JTCMutex> sync(*this); + IceUtil::Mutex::Lock sync(*this); if (_traceLevels->topicMgr > 0) { @@ -204,7 +204,7 @@ TopicManagerI::subscribe(const string& id, const QoS& qos, const StringSeq& topi void TopicManagerI::unsubscribe(const string& id, const StringSeq& topics, const Ice::Current&) { - JTCSyncT<JTCMutex> sync(*this); + IceUtil::Mutex::Lock sync(*this); if (_traceLevels->topicMgr > 0) { @@ -251,7 +251,7 @@ TopicManagerI::reap() // // Always Called with mutex locked // - // JTCSyncT<JTCMutex> sync(*this); + // IceUtil::Mutex::Lock sync(*this); // TopicIMap::iterator i = _topicIMap.begin(); while (i != _topicIMap.end()) |