summaryrefslogtreecommitdiff
path: root/cpp/src/Freeze/MapI.cpp
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2007-10-12 15:48:24 -0400
committerBernard Normier <bernard@zeroc.com>2007-10-12 15:48:24 -0400
commitf038c925c49876569efcaf28c185b20bc4a939d2 (patch)
treef6e2874b9a0c8014ab81df05360658535838ec19 /cpp/src/Freeze/MapI.cpp
parentFurther fix for bug 2502. (diff)
downloadice-f038c925c49876569efcaf28c185b20bc4a939d2.tar.bz2
ice-f038c925c49876569efcaf28c185b20bc4a939d2.tar.xz
ice-f038c925c49876569efcaf28c185b20bc4a939d2.zip
Fixed bug #702
Diffstat (limited to 'cpp/src/Freeze/MapI.cpp')
-rw-r--r--cpp/src/Freeze/MapI.cpp41
1 files changed, 39 insertions, 2 deletions
diff --git a/cpp/src/Freeze/MapI.cpp b/cpp/src/Freeze/MapI.cpp
index 57728bc8f0e..ff8ffb916ee 100644
--- a/cpp/src/Freeze/MapI.cpp
+++ b/cpp/src/Freeze/MapI.cpp
@@ -1385,8 +1385,7 @@ Freeze::MapIndexI::MapIndexI(const ConnectionIPtr& connection, SharedDb& db,
_db.reset(new Db(connection->dbEnv()->getEnv(), 0));
_db->set_flags(DB_DUP | DB_DUPSORT);
- _db->set_app_private(this);
-
+
u_int32_t flags = 0;
if(createDb)
{
@@ -1402,6 +1401,44 @@ Freeze::MapIndexI::MapIndexI(const ConnectionIPtr& connection, SharedDb& db,
_db->set_bt_compare(&customIndexCompare);
}
+ Ice::PropertiesPtr properties = connection->communicator()->getProperties();
+ string propPrefix = "Freeze.Map." + _dbName + ".";
+ int btreeMinKey = properties->getPropertyAsInt(propPrefix + "BtreeMinKey");
+ if(btreeMinKey > 2)
+ {
+ if(connection->trace() >= 1)
+ {
+ Trace out(connection->communicator()->getLogger(), "Freeze.Map");
+ out << "Setting \"" << _dbName << "\"'s btree minkey to " << btreeMinKey;
+ }
+
+ _db->set_bt_minkey(btreeMinKey);
+ }
+
+ bool checksum = properties->getPropertyAsInt(propPrefix + "Checksum") > 0;
+ if(checksum)
+ {
+ if(connection->trace() >= 1)
+ {
+ Trace out(connection->communicator()->getLogger(), "Freeze.Map");
+ out << "Turning checksum on for \"" << _dbName << "\"";
+ }
+
+ _db->set_flags(DB_CHKSUM);
+ }
+
+ int pageSize = properties->getPropertyAsInt(propPrefix + "PageSize");
+ if(pageSize > 0)
+ {
+ if(connection->trace() >= 1)
+ {
+ Trace out(connection->communicator()->getLogger(), "Freeze.Map");
+ out << "Setting \"" << _dbName << "\"'s pagesize to " << pageSize;
+ }
+
+ _db->set_pagesize(pageSize);
+ }
+
_db->open(txn, _dbName.c_str(), 0, DB_BTREE, flags, FREEZE_DB_MODE);
//