| /dports/devel/php-ice37/ice-3.7.2/cpp/src/IceStorm/ |
| H A D | Subscriber.h | 14 namespace IceStorm
27 static SubscriberPtr create(const InstancePtr&, const IceStorm::SubscriberRecord&);
31 IceStorm::SubscriberRecord record() const; // Get the subscriber record.
63 …Subscriber(const InstancePtr&, const IceStorm::SubscriberRecord&, const Ice::ObjectPrx&, int, int);
67 const IceStorm::SubscriberRecord _rec; // The subscriber record.
87 IceInternal::ObserverHelperT<IceStorm::Instrumentation::SubscriberObserver> _observer;
90 bool operator==(const IceStorm::SubscriberPtr&, const Ice::Identity&);
91 bool operator==(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
92 bool operator!=(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
93 bool operator<(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
|
| H A D | InstrumentationI.h | 13 namespace IceStorm
16 class TopicObserverI : public IceStorm::Instrumentation::TopicObserver,
25 class SubscriberObserverI : public IceStorm::Instrumentation::SubscriberObserver,
35 class TopicManagerObserverI : public IceStorm::Instrumentation::TopicManagerObserver
41 virtual void setObserverUpdater(const IceStorm::Instrumentation::ObserverUpdaterPtr&);
43 virtual IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(
46 virtual IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(
50 const IceStorm::QoS&,
51 const IceStorm::TopicPrx&,
52 IceStorm::Instrumentation::SubscriberState,
[all …]
|
| H A D | Admin.cpp | 129 map<Ice::Identity, IceStorm::TopicManagerPrx> managers;
131 IceStorm::TopicManagerPrx defaultManager;
144 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::uncheckedCast(
146 managers.insert(map<Ice::Identity, IceStorm::TopicManagerPrx>::value_type(
160 defaultManager = IceStorm::TopicManagerPrx::uncheckedCast(
179 …IceStorm::FinderPrx finder = IceStorm::FinderPrx::uncheckedCast(communicator->stringToProxy(os.str…
196 IceStorm::ParserPtr p = IceStorm::Parser::createParser(communicator, defaultManager, managers);
|
| H A D | Util.h | 13 namespace IceStorm
22 typedef IceDB::Dbi<IceStorm::SubscriberRecordKey, IceStorm::SubscriberRecord, IceDB::IceContext, Ic…
37 nameToIdentity(const IceStorm::InstancePtr&, const std::string&);
46 getIncrementedLLU(const IceDB::ReadWriteTxn&, IceStorm::LLUMap&);
|
| /dports/devel/ice37/ice-3.7.2/cpp/src/IceStorm/ |
| H A D | Subscriber.h | 14 namespace IceStorm
27 static SubscriberPtr create(const InstancePtr&, const IceStorm::SubscriberRecord&);
31 IceStorm::SubscriberRecord record() const; // Get the subscriber record.
63 …Subscriber(const InstancePtr&, const IceStorm::SubscriberRecord&, const Ice::ObjectPrx&, int, int);
67 const IceStorm::SubscriberRecord _rec; // The subscriber record.
87 IceInternal::ObserverHelperT<IceStorm::Instrumentation::SubscriberObserver> _observer;
90 bool operator==(const IceStorm::SubscriberPtr&, const Ice::Identity&);
91 bool operator==(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
92 bool operator!=(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
93 bool operator<(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
|
| H A D | InstrumentationI.h | 13 namespace IceStorm
16 class TopicObserverI : public IceStorm::Instrumentation::TopicObserver,
25 class SubscriberObserverI : public IceStorm::Instrumentation::SubscriberObserver,
35 class TopicManagerObserverI : public IceStorm::Instrumentation::TopicManagerObserver
41 virtual void setObserverUpdater(const IceStorm::Instrumentation::ObserverUpdaterPtr&);
43 virtual IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(
46 virtual IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(
50 const IceStorm::QoS&,
51 const IceStorm::TopicPrx&,
52 IceStorm::Instrumentation::SubscriberState,
[all …]
|
| H A D | Admin.cpp | 129 map<Ice::Identity, IceStorm::TopicManagerPrx> managers;
131 IceStorm::TopicManagerPrx defaultManager;
144 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::uncheckedCast(
146 managers.insert(map<Ice::Identity, IceStorm::TopicManagerPrx>::value_type(
160 defaultManager = IceStorm::TopicManagerPrx::uncheckedCast(
179 …IceStorm::FinderPrx finder = IceStorm::FinderPrx::uncheckedCast(communicator->stringToProxy(os.str…
196 IceStorm::ParserPtr p = IceStorm::Parser::createParser(communicator, defaultManager, managers);
|
| H A D | Util.h | 13 namespace IceStorm
22 typedef IceDB::Dbi<IceStorm::SubscriberRecordKey, IceStorm::SubscriberRecord, IceDB::IceContext, Ic…
37 nameToIdentity(const IceStorm::InstancePtr&, const std::string&);
46 getIncrementedLLU(const IceDB::ReadWriteTxn&, IceStorm::LLUMap&);
|
| H A D | InstrumentationI.cpp | 12 using namespace IceStorm;
13 using namespace IceStorm::Instrumentation;
92 …er(const string& svc, const string& topic, const ::Ice::ObjectPrx& proxy, const IceStorm::QoS& qos, in SubscriberHelper()
93 const IceStorm::TopicPrx& link, SubscriberState state) : in SubscriberHelper()
107 IceStorm::QoS::const_iterator p = _qos.find(attribute.substr(4)); in resolve()
212 const IceStorm::QoS& _qos;
213 const IceStorm::TopicPrx _link;
352 const IceStorm::QoS& qos, in getSubscriberObserver()
353 const IceStorm::TopicPrx& link, in getSubscriberObserver()
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/src/IceStorm/ |
| H A D | Subscriber.h | 14 namespace IceStorm
27 static SubscriberPtr create(const InstancePtr&, const IceStorm::SubscriberRecord&);
31 IceStorm::SubscriberRecord record() const; // Get the subscriber record.
63 …Subscriber(const InstancePtr&, const IceStorm::SubscriberRecord&, const Ice::ObjectPrx&, int, int);
67 const IceStorm::SubscriberRecord _rec; // The subscriber record.
87 IceInternal::ObserverHelperT<IceStorm::Instrumentation::SubscriberObserver> _observer;
90 bool operator==(const IceStorm::SubscriberPtr&, const Ice::Identity&);
91 bool operator==(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
92 bool operator!=(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
93 bool operator<(const IceStorm::Subscriber&, const IceStorm::Subscriber&);
|
| H A D | InstrumentationI.h | 13 namespace IceStorm
16 class TopicObserverI : public IceStorm::Instrumentation::TopicObserver,
25 class SubscriberObserverI : public IceStorm::Instrumentation::SubscriberObserver,
35 class TopicManagerObserverI : public IceStorm::Instrumentation::TopicManagerObserver
41 virtual void setObserverUpdater(const IceStorm::Instrumentation::ObserverUpdaterPtr&);
43 virtual IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(
46 virtual IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(
50 const IceStorm::QoS&,
51 const IceStorm::TopicPrx&,
52 IceStorm::Instrumentation::SubscriberState,
[all …]
|
| H A D | Admin.cpp | 129 map<Ice::Identity, IceStorm::TopicManagerPrx> managers;
131 IceStorm::TopicManagerPrx defaultManager;
144 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::uncheckedCast(
146 managers.insert(map<Ice::Identity, IceStorm::TopicManagerPrx>::value_type(
160 defaultManager = IceStorm::TopicManagerPrx::uncheckedCast(
179 …IceStorm::FinderPrx finder = IceStorm::FinderPrx::uncheckedCast(communicator->stringToProxy(os.str…
196 IceStorm::ParserPtr p = IceStorm::Parser::createParser(communicator, defaultManager, managers);
|
| H A D | Util.h | 13 namespace IceStorm
22 typedef IceDB::Dbi<IceStorm::SubscriberRecordKey, IceStorm::SubscriberRecord, IceDB::IceContext, Ic…
37 nameToIdentity(const IceStorm::InstancePtr&, const std::string&);
46 getIncrementedLLU(const IceDB::ReadWriteTxn&, IceStorm::LLUMap&);
|
| /dports/devel/ice37/ice-3.7.2/slice/IceStorm/ |
| H A D | Metrics.ice | 8 [["cpp:doxygen:include:IceStorm/IceStorm.h"]]
10 [["cpp:include:IceStorm/Config.h"]]
17 [["python:pkgdir:IceStorm"]]
31 * Provides information on IceStorm topics.
45 * Number of events forwarded on the topic by IceStorm topic links.
53 * Provides information on IceStorm subscribers.
|
| /dports/devel/php-ice37/ice-3.7.2/slice/IceStorm/ |
| H A D | Metrics.ice | 8 [["cpp:doxygen:include:IceStorm/IceStorm.h"]]
10 [["cpp:include:IceStorm/Config.h"]]
17 [["python:pkgdir:IceStorm"]]
31 * Provides information on IceStorm topics.
45 * Number of events forwarded on the topic by IceStorm topic links.
53 * Provides information on IceStorm subscribers.
|
| /dports/devel/py-ice37/ice-3.7.2/slice/IceStorm/ |
| H A D | Metrics.ice | 8 [["cpp:doxygen:include:IceStorm/IceStorm.h"]]
10 [["cpp:include:IceStorm/Config.h"]]
17 [["python:pkgdir:IceStorm"]]
31 * Provides information on IceStorm topics.
45 * Number of events forwarded on the topic by IceStorm topic links.
53 * Provides information on IceStorm subscribers.
|
| /dports/devel/php-ice37/ice-3.7.2/cpp/test/IceStorm/single/ |
| H A D | Subscriber.cpp | 12 using namespace IceStorm;
127 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base);
163 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
181 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
187 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
193 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
199 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
203 IceStorm::QoS qos;
212 IceStorm::QoS qos;
229 topic->subscribeAndGetPublisher(IceStorm::QoS(), object);
[all …]
|
| /dports/devel/ice37/ice-3.7.2/cpp/test/IceStorm/single/ |
| H A D | Subscriber.cpp | 12 using namespace IceStorm;
127 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base); in run()
163 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
181 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
187 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
193 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
199 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
203 IceStorm::QoS qos; in run()
212 IceStorm::QoS qos; in run()
229 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
[all …]
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/test/IceStorm/single/ |
| H A D | Subscriber.cpp | 12 using namespace IceStorm;
127 IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base); in run()
163 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
181 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
187 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
193 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
199 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
203 IceStorm::QoS qos; in run()
212 IceStorm::QoS qos; in run()
229 topic->subscribeAndGetPublisher(IceStorm::QoS(), object); in run()
[all …]
|
| /dports/devel/php-ice37/ice-3.7.2/objective-c/src/IceStorm/ |
| H A D | Makefile.mk | 8 IceStormObjC_sliceflags := --include-dir objc/IceStorm
10 IceStormObjC_slicedir := $(slicedir)/IceStorm
11 IceStormObjC_includedir := $(includedir)/objc/IceStorm
13 IceStormObjC_install:: $(install_includedir)/objc/IceStorm.h
|
| /dports/devel/ice37/ice-3.7.2/objective-c/src/IceStorm/ |
| H A D | Makefile.mk | 8 IceStormObjC_sliceflags := --include-dir objc/IceStorm
10 IceStormObjC_slicedir := $(slicedir)/IceStorm
11 IceStormObjC_includedir := $(includedir)/objc/IceStorm
13 IceStormObjC_install:: $(install_includedir)/objc/IceStorm.h
|
| /dports/devel/py-ice37/ice-3.7.2/objective-c/src/IceStorm/ |
| H A D | Makefile.mk | 8 IceStormObjC_sliceflags := --include-dir objc/IceStorm
10 IceStormObjC_slicedir := $(slicedir)/IceStorm
11 IceStormObjC_includedir := $(includedir)/objc/IceStorm
13 IceStormObjC_install:: $(install_includedir)/objc/IceStorm.h
|
| /dports/devel/php-ice37/ice-3.7.2/cpp/test/Ice/services/ |
| H A D | AllTests.cpp | 97 IceStorm::TopicManagerPrxPtr manager = in allTests()
98 …ICE_UNCHECKED_CAST(IceStorm::TopicManagerPrx, communicator->stringToProxy("test:default -p 12010")… in allTests()
100 IceStorm::QoS qos; in allTests()
101 IceStorm::TopicPrxPtr topic; in allTests()
109 catch(const IceStorm::NoSuchTopic&) in allTests()
128 catch(const IceStorm::AlreadySubscribed&) in allTests()
|
| /dports/devel/ice37/ice-3.7.2/cpp/test/Ice/services/ |
| H A D | AllTests.cpp | 97 IceStorm::TopicManagerPrxPtr manager = in allTests()
98 …ICE_UNCHECKED_CAST(IceStorm::TopicManagerPrx, communicator->stringToProxy("test:default -p 12010")… in allTests()
100 IceStorm::QoS qos; in allTests()
101 IceStorm::TopicPrxPtr topic; in allTests()
109 catch(const IceStorm::NoSuchTopic&) in allTests()
128 catch(const IceStorm::AlreadySubscribed&) in allTests()
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/test/Ice/services/ |
| H A D | AllTests.cpp | 97 IceStorm::TopicManagerPrxPtr manager = in allTests()
98 …ICE_UNCHECKED_CAST(IceStorm::TopicManagerPrx, communicator->stringToProxy("test:default -p 12010")… in allTests()
100 IceStorm::QoS qos; in allTests()
101 IceStorm::TopicPrxPtr topic; in allTests()
109 catch(const IceStorm::NoSuchTopic&) in allTests()
128 catch(const IceStorm::AlreadySubscribed&) in allTests()
|