summaryrefslogtreecommitdiff
path: root/cpp/src/IceStorm/InstrumentationI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceStorm/InstrumentationI.cpp')
-rw-r--r--cpp/src/IceStorm/InstrumentationI.cpp32
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,