summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ACM.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Ice/ACM.cpp')
-rw-r--r--cpp/src/Ice/ACM.cpp46
1 files changed, 23 insertions, 23 deletions
diff --git a/cpp/src/Ice/ACM.cpp b/cpp/src/Ice/ACM.cpp
index 9990d76f995..8795874212a 100644
--- a/cpp/src/Ice/ACM.cpp
+++ b/cpp/src/Ice/ACM.cpp
@@ -24,14 +24,14 @@ IceUtil::Shared* IceInternal::upCast(FactoryACMMonitor* p) { return p; }
#endif
IceInternal::ACMConfig::ACMConfig(bool server) :
- timeout(IceUtil::Time::seconds(60)),
- heartbeat(Ice::HeartbeatOnInvocation),
- close(server ? Ice::CloseOnInvocation : Ice::CloseOnInvocationAndIdle)
+ timeout(IceUtil::Time::seconds(60)),
+ heartbeat(ICE_ENUM(ACMHeartbeat, HeartbeatOnInvocation)),
+ close(server ? ICE_ENUM(ACMClose, CloseOnInvocation) : ICE_ENUM(ACMClose, CloseOnInvocationAndIdle))
{
}
-IceInternal::ACMConfig::ACMConfig(const Ice::PropertiesPtr& p,
- const Ice::LoggerPtr& l,
+IceInternal::ACMConfig::ACMConfig(const Ice::PropertiesPtr& p,
+ const Ice::LoggerPtr& l,
const string& prefix,
const ACMConfig& dflt)
{
@@ -45,10 +45,10 @@ IceInternal::ACMConfig::ACMConfig(const Ice::PropertiesPtr& p,
timeoutProperty = prefix + ".Timeout";
};
- this->timeout = IceUtil::Time::seconds(p->getPropertyAsIntWithDefault(timeoutProperty,
+ this->timeout = IceUtil::Time::seconds(p->getPropertyAsIntWithDefault(timeoutProperty,
static_cast<int>(dflt.timeout.toSeconds())));
- int hb = p->getPropertyAsIntWithDefault(prefix + ".Heartbeat", dflt.heartbeat);
- if(hb >= Ice::HeartbeatOff && hb <= Ice::HeartbeatAlways)
+ int hb = p->getPropertyAsIntWithDefault(prefix + ".Heartbeat", static_cast<int>(dflt.heartbeat));
+ if(hb >= static_cast<int>(ICE_ENUM(ACMHeartbeat, HeartbeatOff)) && hb <= static_cast<int>(ICE_ENUM(ACMHeartbeat, HeartbeatAlways)))
{
this->heartbeat = static_cast<Ice::ACMHeartbeat>(hb);
}
@@ -58,8 +58,8 @@ IceInternal::ACMConfig::ACMConfig(const Ice::PropertiesPtr& p,
this->heartbeat = dflt.heartbeat;
}
- int cl = p->getPropertyAsIntWithDefault(prefix + ".Close", dflt.close);
- if(cl >= Ice::CloseOff && cl <= Ice::CloseOnIdleForceful)
+ int cl = p->getPropertyAsIntWithDefault(prefix + ".Close", static_cast<int>(dflt.close));
+ if(cl >= static_cast<int>(ICE_ENUM(ACMClose, CloseOff)) && cl <= static_cast<int>(ICE_ENUM(ACMClose, CloseOnIdleForceful)))
{
this->close = static_cast<Ice::ACMClose>(cl);
}
@@ -138,8 +138,8 @@ IceInternal::FactoryACMMonitor::reap(const ConnectionIPtr& connection)
}
ACMMonitorPtr
-IceInternal::FactoryACMMonitor::acm(const IceUtil::Optional<int>& timeout,
- const IceUtil::Optional<Ice::ACMClose>& close,
+IceInternal::FactoryACMMonitor::acm(const IceUtil::Optional<int>& timeout,
+ const IceUtil::Optional<Ice::ACMClose>& close,
const IceUtil::Optional<Ice::ACMHeartbeat>& heartbeat)
{
Lock sync(*this);
@@ -208,7 +208,7 @@ IceInternal::FactoryACMMonitor::runTimerTask()
}
}
-
+
//
// Monitor connections outside the thread synchronization, so
// that connections can be added or removed during monitoring.
@@ -217,11 +217,11 @@ IceInternal::FactoryACMMonitor::runTimerTask()
for(set<ConnectionIPtr>::const_iterator p = _connections.begin(); p != _connections.end(); ++p)
{
try
- {
+ {
(*p)->monitor(now, _config);
}
catch(const exception& ex)
- {
+ {
handleException(ex);
}
catch(...)
@@ -239,7 +239,7 @@ FactoryACMMonitor::handleException(const exception& ex)
{
return;
}
-
+
Error out(_instance->initializationData().logger);
out << "exception in connection monitor:\n" << ex.what();
}
@@ -252,12 +252,12 @@ FactoryACMMonitor::handleException()
{
return;
}
-
+
Error out(_instance->initializationData().logger);
out << "unknown exception in connection monitor";
}
-IceInternal::ConnectionACMMonitor::ConnectionACMMonitor(const FactoryACMMonitorPtr& parent,
+IceInternal::ConnectionACMMonitor::ConnectionACMMonitor(const FactoryACMMonitorPtr& parent,
const IceUtil::TimerPtr& timer,
const ACMConfig& config) :
_parent(parent), _timer(timer), _config(config)
@@ -300,8 +300,8 @@ IceInternal::ConnectionACMMonitor::reap(const ConnectionIPtr& connection)
}
ACMMonitorPtr
-IceInternal::ConnectionACMMonitor::acm(const IceUtil::Optional<int>& timeout,
- const IceUtil::Optional<Ice::ACMClose>& close,
+IceInternal::ConnectionACMMonitor::acm(const IceUtil::Optional<int>& timeout,
+ const IceUtil::Optional<Ice::ACMClose>& close,
const IceUtil::Optional<Ice::ACMHeartbeat>& heartbeat)
{
return _parent->acm(timeout, close, heartbeat);
@@ -329,13 +329,13 @@ IceInternal::ConnectionACMMonitor::runTimerTask()
}
connection = _connection;
}
-
+
try
- {
+ {
connection->monitor(IceUtil::Time::now(IceUtil::Time::Monotonic), _config);
}
catch(const exception& ex)
- {
+ {
_parent->handleException(ex);
}
catch(...)