summaryrefslogtreecommitdiff
path: root/cpp/src/IceStorm/Instance.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceStorm/Instance.cpp')
-rw-r--r--cpp/src/IceStorm/Instance.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/cpp/src/IceStorm/Instance.cpp b/cpp/src/IceStorm/Instance.cpp
index a5bcb3628d6..dac531d34f0 100644
--- a/cpp/src/IceStorm/Instance.cpp
+++ b/cpp/src/IceStorm/Instance.cpp
@@ -28,23 +28,23 @@ Instance::Instance(
_adapter(adapter),
_traceLevels(new TraceLevels(name, communicator->getProperties(), communicator->getLogger())),
_discardInterval(IceUtil::Time::seconds(communicator->getProperties()->getPropertyAsIntWithDefault(
- "IceStorm.Discard.Interval", 60))), // default one minute.
+ "IceStorm.Discard.Interval", 60))), // default one minute.
// default one minute.
_sendTimeout(communicator->getProperties()->getPropertyAsIntWithDefault("IceStorm.Send.Timeout", 60 * 1000))
{
try
{
- __setNoDelete(true);
+ __setNoDelete(true);
- _batchFlusher = new BatchFlusher(this);
- _subscriberPool = new SubscriberPool(this);
+ _batchFlusher = new BatchFlusher(this);
+ _subscriberPool = new SubscriberPool(this);
}
catch(...)
{
- shutdown();
- __setNoDelete(false);
+ shutdown();
+ __setNoDelete(false);
- throw;
+ throw;
}
__setNoDelete(false);
}
@@ -112,12 +112,12 @@ Instance::shutdown()
{
if(_batchFlusher)
{
- _batchFlusher->destroy();
- _batchFlusher->getThreadControl().join();
+ _batchFlusher->destroy();
+ _batchFlusher->getThreadControl().join();
}
if(_subscriberPool)
{
- _subscriberPool->destroy();
+ _subscriberPool->destroy();
}
}