diff options
Diffstat (limited to 'cpp/src/IceStorm/Instance.cpp')
-rw-r--r-- | cpp/src/IceStorm/Instance.cpp | 20 |
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(); } } |