summaryrefslogtreecommitdiff
path: root/cpp/src/Freeze/ConnectionI.cpp
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2003-09-30 02:23:10 +0000
committerBernard Normier <bernard@zeroc.com>2003-09-30 02:23:10 +0000
commit9d8b924dd0d2971e359beca9a7b10720b08a7e0d (patch)
tree234fc0bcd1d91bf1a991691c7c8e9631a871c474 /cpp/src/Freeze/ConnectionI.cpp
parentRemoved DB, cleaned up configuration (diff)
downloadice-9d8b924dd0d2971e359beca9a7b10720b08a7e0d.tar.bz2
ice-9d8b924dd0d2971e359beca9a7b10720b08a7e0d.tar.xz
ice-9d8b924dd0d2971e359beca9a7b10720b08a7e0d.zip
Removed DB, cleaned up configuration
Diffstat (limited to 'cpp/src/Freeze/ConnectionI.cpp')
-rw-r--r--cpp/src/Freeze/ConnectionI.cpp28
1 files changed, 15 insertions, 13 deletions
diff --git a/cpp/src/Freeze/ConnectionI.cpp b/cpp/src/Freeze/ConnectionI.cpp
index 7701e39ef24..7d6c9e1fc73 100644
--- a/cpp/src/Freeze/ConnectionI.cpp
+++ b/cpp/src/Freeze/ConnectionI.cpp
@@ -48,7 +48,7 @@ Freeze::ConnectionI::close()
{
_transaction->rollback();
}
- catch(const Freeze::DBException&)
+ catch(const DatabaseException&)
{
//
// Ignored
@@ -68,7 +68,7 @@ Freeze::ConnectionI::close()
}
}
-Ice::CommunicatorPtr
+CommunicatorPtr
Freeze::ConnectionI::getCommunicator() const
{
return _communicator;
@@ -86,29 +86,30 @@ Freeze::ConnectionI::~ConnectionI()
close();
}
-Freeze::ConnectionI::ConnectionI(const Ice::CommunicatorPtr& communicator,
- const std::string& envName) :
+Freeze::ConnectionI::ConnectionI(const CommunicatorPtr& communicator,
+ const string& envName) :
_communicator(communicator),
_dbEnvHolder(SharedDbEnv::get(communicator, envName)),
_envName(envName),
- _trace(communicator->getProperties()->getPropertyAsInt("Freeze.Trace.DB"))
+ _trace(communicator->getProperties()->getPropertyAsInt("Freeze.Trace.Map"))
{
_dbEnv = _dbEnvHolder.get();
}
-Freeze::ConnectionI::ConnectionI(const Ice::CommunicatorPtr& communicator,
+Freeze::ConnectionI::ConnectionI(const CommunicatorPtr& communicator,
+ const string& envName,
DbEnv& dbEnv) :
_communicator(communicator),
_dbEnv(&dbEnv),
- _envName("External"),
- _trace(communicator->getProperties()->getPropertyAsInt("Freeze.Trace.DB"))
+ _envName(envName),
+ _trace(communicator->getProperties()->getPropertyAsInt("Freeze.Trace.Map"))
{
}
void
Freeze::ConnectionI::closeAllIterators()
{
- for(list<DBMapHelperI*>::iterator p = _mapList.begin(); p != _mapList.end();
+ for(list<MapHelperI*>::iterator p = _mapList.begin(); p != _mapList.end();
++p)
{
(*p)->closeAllIterators();
@@ -116,13 +117,13 @@ Freeze::ConnectionI::closeAllIterators()
}
void
-Freeze::ConnectionI::registerMap(DBMapHelperI* m)
+Freeze::ConnectionI::registerMap(MapHelperI* m)
{
_mapList.push_back(m);
}
void
-Freeze::ConnectionI::unregisterMap(DBMapHelperI* m)
+Freeze::ConnectionI::unregisterMap(MapHelperI* m)
{
_mapList.remove(m);
}
@@ -137,14 +138,15 @@ Freeze::createConnection(const CommunicatorPtr& communicator,
Freeze::ConnectionPtr
Freeze::createConnection(const CommunicatorPtr& communicator,
+ const string& envName,
DbEnv& dbEnv)
{
- return new ConnectionI(communicator, dbEnv);
+ return new ConnectionI(communicator, envName, dbEnv);
}
void
Freeze::TransactionAlreadyInProgressException::ice_print(ostream& out) const
{
Exception::ice_print(out);
- out << ":\ntransaction already in progess";
+ out << ":\ntransaction already in progress";
}