summaryrefslogtreecommitdiff
path: root/java/src/Freeze/ObjectStore.java
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2004-11-03 16:37:42 +0000
committerBernard Normier <bernard@zeroc.com>2004-11-03 16:37:42 +0000
commit7b1808f457ddc1597ac00c89bf4d95190496ce01 (patch)
tree2ba4ca2aa350b307d9a0a086827eeeed5e7be096 /java/src/Freeze/ObjectStore.java
parentAdded Freeze.Trace.Transaction (diff)
downloadice-7b1808f457ddc1597ac00c89bf4d95190496ce01.tar.bz2
ice-7b1808f457ddc1597ac00c89bf4d95190496ce01.tar.xz
ice-7b1808f457ddc1597ac00c89bf4d95190496ce01.zip
Added Freeze.Trace.Transaction tracing
Diffstat (limited to 'java/src/Freeze/ObjectStore.java')
-rw-r--r--java/src/Freeze/ObjectStore.java36
1 files changed, 35 insertions, 1 deletions
diff --git a/java/src/Freeze/ObjectStore.java b/java/src/Freeze/ObjectStore.java
index 135f9297b81..5492886be02 100644
--- a/java/src/Freeze/ObjectStore.java
+++ b/java/src/Freeze/ObjectStore.java
@@ -34,12 +34,24 @@ class ObjectStore implements IceUtil.Store
com.sleepycat.db.DbTxn txn = null;
com.sleepycat.db.DbEnv dbEnv = evictor.dbEnv();
+ String txnId = null;
+
try
{
_db = new com.sleepycat.db.Db(dbEnv, 0);
txn = dbEnv.txnBegin(null, 0);
+ if(evictor.txTrace() >= 1)
+ {
+ txnId = Long.toHexString((txn.id() & 0x7FFFFFFF) + 0x80000000L);
+
+ evictor.communicator().getLogger().trace
+ ("Freeze.Evictor", _evictor.errorPrefix() + "successfully started transaction " +
+ txnId + " to open Db");
+ }
+
+
//
// TODO: FREEZE_DB_MODE
//
@@ -61,6 +73,14 @@ class ObjectStore implements IceUtil.Store
com.sleepycat.db.DbTxn toCommit = txn;
txn = null;
toCommit.commit(0);
+
+ if(evictor.txTrace() >= 1)
+ {
+ evictor.communicator().getLogger().trace
+ ("Freeze.Evictor", _evictor.errorPrefix() + "successfully committed transaction " +
+ txnId);
+ }
+
}
catch(java.io.FileNotFoundException dx)
{
@@ -81,11 +101,25 @@ class ObjectStore implements IceUtil.Store
if(txn != null)
{
try
- {
+ {
txn.abort();
+
+ if(evictor.txTrace() >= 1)
+ {
+ evictor.communicator().getLogger().trace
+ ("Freeze.Evictor", _evictor.errorPrefix() + "successfully rolled back transaction " +
+ txnId);
+ }
}
catch(com.sleepycat.db.DbException dx)
{
+ if(evictor.txTrace() >= 1)
+ {
+ evictor.communicator().getLogger().trace
+ ("Freeze.Evictor", _evictor.errorPrefix() + "failed to rollback transaction " +
+ txnId + ": " + dx.getMessage());
+ }
+
}
}
}