diff options
author | Bernard Normier <bernard@zeroc.com> | 2003-09-30 02:23:10 +0000 |
---|---|---|
committer | Bernard Normier <bernard@zeroc.com> | 2003-09-30 02:23:10 +0000 |
commit | 9d8b924dd0d2971e359beca9a7b10720b08a7e0d (patch) | |
tree | 234fc0bcd1d91bf1a991691c7c8e9631a871c474 /cpp/src/Freeze/ConnectionI.cpp | |
parent | Removed DB, cleaned up configuration (diff) | |
download | ice-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.cpp | 28 |
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"; } |