diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2011-10-31 16:07:55 +0100 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2011-10-31 16:07:55 +0100 |
| commit | a969a38974c6469edcc573e25e46512d564911e8 (patch) | |
| tree | 05e619722d90f5853ed5a2a1f4f6dd1a0b8b359a /cpp/src/IceStorm/TopicManagerI.cpp | |
| parent | Glacier2 Session Helper implementation (diff) | |
| download | ice-a969a38974c6469edcc573e25e46512d564911e8.tar.bz2 ice-a969a38974c6469edcc573e25e46512d564911e8.tar.xz ice-a969a38974c6469edcc573e25e46512d564911e8.zip | |
Fixed ICE-4727, create new connection for each request instead of re-using the same connection
Diffstat (limited to 'cpp/src/IceStorm/TopicManagerI.cpp')
| -rw-r--r-- | cpp/src/IceStorm/TopicManagerI.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/IceStorm/TopicManagerI.cpp b/cpp/src/IceStorm/TopicManagerI.cpp index d826c47ab48..831a31a9493 100644 --- a/cpp/src/IceStorm/TopicManagerI.cpp +++ b/cpp/src/IceStorm/TopicManagerI.cpp @@ -312,7 +312,7 @@ TopicManagerImpl::TopicManagerImpl(const InstancePtr& instance) : _sync = _instance->nodeAdapter()->addWithUUID(_syncImpl); } - DatabaseConnectionPtr connection = _databaseCache->getConnection(); + DatabaseConnectionPtr connection = _databaseCache->newConnection(); // Ensure that the llu counter is present in the log. LLUWrapperPtr lluWrapper = _databaseCache->getLLU(connection); @@ -381,7 +381,7 @@ TopicManagerImpl::create(const string& name) { try { - DatabaseConnectionPtr connection = _databaseCache->getConnection(); + DatabaseConnectionPtr connection = _databaseCache->newConnection(); TransactionHolder txn(connection); SubscriberRecordKey key; @@ -486,7 +486,7 @@ TopicManagerImpl::observerInit(const LogUpdate& llu, const TopicContentSeq& cont { try { - DatabaseConnectionPtr connection = _databaseCache->getConnection(); + DatabaseConnectionPtr connection = _databaseCache->newConnection(); TransactionHolder txn(connection); LLUWrapperPtr lluWrapper = _databaseCache->getLLU(connection); @@ -590,7 +590,7 @@ TopicManagerImpl::observerCreateTopic(const LogUpdate& llu, const string& name) { try { - DatabaseConnectionPtr connection = _databaseCache->getConnection(); + DatabaseConnectionPtr connection = _databaseCache->newConnection(); TransactionHolder txn(connection); SubscriberRecordKey key; @@ -776,7 +776,7 @@ TopicManagerImpl::initMaster(const set<GroupNodeInfo>& slaves, const LogUpdate& { content.clear(); - DatabaseConnectionPtr connection = _databaseCache->getConnection(); + DatabaseConnectionPtr connection = _databaseCache->newConnection(); TransactionHolder txn(connection); for(map<string, TopicImplPtr>::const_iterator p = _topics.begin(); p != _topics.end(); ++p) |