diff options
author | Bernard Normier <bernard@zeroc.com> | 2004-11-03 16:37:42 +0000 |
---|---|---|
committer | Bernard Normier <bernard@zeroc.com> | 2004-11-03 16:37:42 +0000 |
commit | 7b1808f457ddc1597ac00c89bf4d95190496ce01 (patch) | |
tree | 2ba4ca2aa350b307d9a0a086827eeeed5e7be096 /java/src/Freeze/ObjectStore.java | |
parent | Added Freeze.Trace.Transaction (diff) | |
download | ice-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.java | 36 |
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()); + } + } } } |