diff options
Diffstat (limited to 'cpp/src/IceStorm/InstrumentationI.cpp')
-rw-r--r-- | cpp/src/IceStorm/InstrumentationI.cpp | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/cpp/src/IceStorm/InstrumentationI.cpp b/cpp/src/IceStorm/InstrumentationI.cpp index 7d69eb2bc85..15dd423e250 100644 --- a/cpp/src/IceStorm/InstrumentationI.cpp +++ b/cpp/src/IceStorm/InstrumentationI.cpp @@ -18,7 +18,7 @@ using namespace IceStorm; using namespace IceStorm::Instrumentation; using namespace IceMX; -namespace +namespace { class TopicHelper : public MetricsHelperT<TopicMetrics> @@ -28,7 +28,7 @@ public: class Attributes : public AttributeResolverT<TopicHelper> { public: - + Attributes() { add("parent", &TopicHelper::getService); @@ -38,7 +38,7 @@ public: } }; static Attributes attributes; - + TopicHelper(const string& service, const string& name) : _service(service), _name(name) { } @@ -57,7 +57,7 @@ public: { return _name; } - + private: const string& _service; @@ -73,7 +73,7 @@ public: class Attributes : public AttributeResolverT<SubscriberHelper> { public: - + Attributes() { add("parent", &SubscriberHelper::getTopic); @@ -93,8 +93,8 @@ public: } }; static Attributes attributes; - - SubscriberHelper(const string& svc, const string& topic, const ::Ice::ObjectPrx& proxy, const IceStorm::QoS& qos, + + SubscriberHelper(const string& svc, const string& topic, const ::Ice::ObjectPrx& proxy, const IceStorm::QoS& qos, const IceStorm::TopicPrx& link, SubscriberState state) : _service(svc), _topic(topic), _proxy(proxy), _qos(qos), _link(link), _state(state) { @@ -140,23 +140,23 @@ public: if(_proxy->ice_isTwoway()) { return "twoway"; - } + } else if(_proxy->ice_isOneway()) { return "oneway"; - } + } else if(_proxy->ice_isBatchOneway()) { return "batch-oneway"; - } + } else if(_proxy->ice_isDatagram()) { return "datagram"; - } + } else if(_proxy->ice_isBatchDatagram()) { return "batch-datagram"; - } + } else { return "unknown"; @@ -318,7 +318,7 @@ SubscriberObserverI::delivered(int count) forEach(DeliveredUpdate(count)); } -TopicManagerObserverI::TopicManagerObserverI(const IceInternal::MetricsAdminIPtr& metrics) : +TopicManagerObserverI::TopicManagerObserverI(const IceInternal::MetricsAdminIPtr& metrics) : _metrics(metrics), _topics(metrics, "Topic"), _subscribers(metrics, "Subscriber") @@ -351,9 +351,9 @@ TopicManagerObserverI::getTopicObserver(const string& service, const string& top } SubscriberObserverPtr -TopicManagerObserverI::getSubscriberObserver(const string& svc, - const string& topic, - const ::Ice::ObjectPrx& proxy, +TopicManagerObserverI::getSubscriberObserver(const string& svc, + const string& topic, + const ::Ice::ObjectPrx& proxy, const IceStorm::QoS& qos, const IceStorm::TopicPrx& link, SubscriberState state, |