diff options
author | Marc Laukien <marc@zeroc.com> | 2001-09-18 22:46:47 +0000 |
---|---|---|
committer | Marc Laukien <marc@zeroc.com> | 2001-09-18 22:46:47 +0000 |
commit | c9a7b9dba6b1370492826b365cf37314dd702e24 (patch) | |
tree | cb1ccb37f2939c136d5eddd728cf49705a015445 /cpp/src | |
parent | fixes (diff) | |
download | ice-c9a7b9dba6b1370492826b365cf37314dd702e24.tar.bz2 ice-c9a7b9dba6b1370492826b365cf37314dd702e24.tar.xz ice-c9a7b9dba6b1370492826b365cf37314dd702e24.zip |
fixes
Diffstat (limited to 'cpp/src')
-rw-r--r-- | cpp/src/Freeze/DBI.cpp | 39 | ||||
-rw-r--r-- | cpp/src/Freeze/DBI.h | 11 |
2 files changed, 17 insertions, 33 deletions
diff --git a/cpp/src/Freeze/DBI.cpp b/cpp/src/Freeze/DBI.cpp index 480efafa853..e2f941961ad 100644 --- a/cpp/src/Freeze/DBI.cpp +++ b/cpp/src/Freeze/DBI.cpp @@ -23,14 +23,13 @@ using namespace Freeze; # define FREEZE_DB_MODE (S_IRUSR | S_IWUSR) #endif -Freeze::DBI::DBI(const CommunicatorPtr& communicator, const PropertiesPtr& properties, const DBEnvIPtr& dbenvObj, - ::DB_ENV* dbenv, ::DB* db, const string& name) : +Freeze::DBI::DBI(const CommunicatorPtr& communicator, const string& name, const DBEnvIPtr& dbenvObj, ::DB_ENV* dbenv, + ::DB* db) : _communicator(communicator), - _properties(properties), + _name(name), _dbenvObj(dbenvObj), _dbenv(dbenv), - _db(db), - _name(name) + _db(db) { } @@ -46,7 +45,7 @@ Freeze::DBI::~DBI() } void -Freeze::DBI::put(const std::string& key, const ::Ice::ObjectPtr& servant) +Freeze::DBI::put(const string& key, const ObjectPtr& servant) { // // TODO: Is synchronization necessary here? I really don't @@ -153,8 +152,8 @@ Freeze::DBI::put(const std::string& key, const ::Ice::ObjectPtr& servant) } } -::Ice::ObjectPtr -Freeze::DBI::get(const std::string& key) +ObjectPtr +Freeze::DBI::get(const string& key) { // // TODO: Is synchronization necessary here? I really don't @@ -239,7 +238,7 @@ Freeze::DBI::get(const std::string& key) } void -Freeze::DBI::del(const std::string& key) +Freeze::DBI::del(const string& key) { // // TODO: Is synchronization necessary here? I really don't @@ -286,17 +285,11 @@ Freeze::DBI::close() _db = 0; } -Freeze::DBEnvI::DBEnvI(const CommunicatorPtr& communicator, const PropertiesPtr& properties) : +Freeze::DBEnvI::DBEnvI(const CommunicatorPtr& communicator, const string& directory) : _communicator(communicator), - _properties(properties), + _directory(directory), _dbenv(0) { - _directory = _properties->getProperty("Freeze.Directory"); - if (_directory.empty()) - { - _directory = "."; - } - int ret; ret = db_env_create(&_dbenv, 0); @@ -387,7 +380,7 @@ Freeze::DBEnvI::open(const string& name) throw ex; } - DBPtr dbp = new DBI(_communicator, _properties, this, _dbenv, db, name); + DBPtr dbp = new DBI(_communicator, name, this, _dbenv, db); _dbmap[name] = dbp; return dbp; } @@ -430,13 +423,7 @@ Freeze::DBEnvI::remove(const string& name) } DBEnvPtr -Freeze::initialize(const CommunicatorPtr& communicator) -{ - return new DBEnvI(communicator, communicator->getProperties()); -} - -DBEnvPtr -Freeze::initializeWithProperties(const CommunicatorPtr& communicator, const PropertiesPtr& properties) +Freeze::initialize(const CommunicatorPtr& communicator, const string& directory) { - return new DBEnvI(communicator, properties); + return new DBEnvI(communicator, directory); } diff --git a/cpp/src/Freeze/DBI.h b/cpp/src/Freeze/DBI.h index 31c3f38c436..6959b6f8f87 100644 --- a/cpp/src/Freeze/DBI.h +++ b/cpp/src/Freeze/DBI.h @@ -27,8 +27,7 @@ class DBI : public DB, public JTCMutex { public: - DBI(const ::Ice::CommunicatorPtr&, const ::Ice::PropertiesPtr&, const DBEnvIPtr&, ::DB_ENV*, ::DB*, - const std::string&); + DBI(const ::Ice::CommunicatorPtr&, const std::string&, const DBEnvIPtr&, ::DB_ENV*, ::DB*); virtual ~DBI(); virtual void put(const std::string&, const ::Ice::ObjectPtr&); @@ -39,18 +38,17 @@ public: private: ::Ice::CommunicatorPtr _communicator; - ::Ice::PropertiesPtr _properties; + std::string _name; DBEnvIPtr _dbenvObj; ::DB_ENV* _dbenv; ::DB* _db; - std::string _name; }; class DBEnvI : public DBEnv, public JTCRecursiveMutex { public: - DBEnvI(const ::Ice::CommunicatorPtr&, const ::Ice::PropertiesPtr&); + DBEnvI(const ::Ice::CommunicatorPtr&, const std::string&); virtual ~DBEnvI(); virtual DBPtr open(const std::string&); @@ -61,9 +59,8 @@ public: private: ::Ice::CommunicatorPtr _communicator; - ::Ice::PropertiesPtr _properties; - ::DB_ENV* _dbenv; std::string _directory; + ::DB_ENV* _dbenv; std::map<std::string, DBPtr> _dbmap; }; |