diff options
author | Marc Laukien <marc@zeroc.com> | 2001-11-29 16:26:33 +0000 |
---|---|---|
committer | Marc Laukien <marc@zeroc.com> | 2001-11-29 16:26:33 +0000 |
commit | 5651a067168fb1ada7c2fe38202c0d954f731609 (patch) | |
tree | 5c9bcbf29d2d3a97e8c5b0e9e774cce28222c2a3 /cpp/src/IceStorm/TopicManagerI.cpp | |
parent | initial check-in (diff) | |
download | ice-5651a067168fb1ada7c2fe38202c0d954f731609.tar.bz2 ice-5651a067168fb1ada7c2fe38202c0d954f731609.tar.xz ice-5651a067168fb1ada7c2fe38202c0d954f731609.zip |
more current/context stuff
Diffstat (limited to 'cpp/src/IceStorm/TopicManagerI.cpp')
-rw-r--r-- | cpp/src/IceStorm/TopicManagerI.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/cpp/src/IceStorm/TopicManagerI.cpp b/cpp/src/IceStorm/TopicManagerI.cpp index 49bfe3dbe1e..41db1c34bef 100644 --- a/cpp/src/IceStorm/TopicManagerI.cpp +++ b/cpp/src/IceStorm/TopicManagerI.cpp @@ -35,7 +35,7 @@ TopicManagerI::~TopicManagerI() } TopicPrx -TopicManagerI::create(const string& name) +TopicManagerI::create(const string& name, const Ice::Current&) { // TODO: reader/writer mutex JTCSyncT<JTCMutex> sync(*this); @@ -67,7 +67,7 @@ TopicManagerI::create(const string& name) } TopicPrx -TopicManagerI::retrieve(const string& name) +TopicManagerI::retrieve(const string& name, const Ice::Current&) { JTCSyncT<JTCMutex> sync(*this); @@ -90,7 +90,7 @@ transformToTopicDict(TopicIMap::value_type p, Ice::ObjectAdapterPtr adapter) } TopicDict -TopicManagerI::retrieveAll() +TopicManagerI::retrieveAll(const Ice::Current&) { JTCSyncT<JTCMutex> sync(*this); @@ -104,7 +104,8 @@ TopicManagerI::retrieveAll() } void -TopicManagerI::subscribe(const string& id, const QoS& qos, const StringSeq& topics, const Ice::ObjectPrx& tmpl) +TopicManagerI::subscribe(const string& id, const QoS& qos, const StringSeq& topics, const Ice::ObjectPrx& tmpl, + const Ice::Current&) { JTCSyncT<JTCMutex> sync(*this); @@ -168,7 +169,7 @@ TopicManagerI::subscribe(const string& id, const QoS& qos, const StringSeq& topi } void -TopicManagerI::unsubscribe(const string& id, const StringSeq& topics) +TopicManagerI::unsubscribe(const string& id, const StringSeq& topics, const Ice::Current&) { JTCSyncT<JTCMutex> sync(*this); @@ -202,7 +203,7 @@ TopicManagerI::unsubscribe(const string& id, const StringSeq& topics) } void -TopicManagerI::shutdown() +TopicManagerI::shutdown(const Ice::Current&) { _flusher->stopFlushing(); _communicator->shutdown(); |