summaryrefslogtreecommitdiff
path: root/java/src/Freeze/TransactionI.java
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2014-10-20 11:40:05 -0230
committerMatthew Newhook <matthew@zeroc.com>2014-10-20 11:40:05 -0230
commitb51469b41167fb86ae2059a15cf0475c53fdda7b (patch)
treefc85d6ca2efd89c67e1e4e7438f437c3e08313f4 /java/src/Freeze/TransactionI.java
parentFixed (ICE-5695) - IceSSL: misleading exception (diff)
downloadice-b51469b41167fb86ae2059a15cf0475c53fdda7b.tar.bz2
ice-b51469b41167fb86ae2059a15cf0475c53fdda7b.tar.xz
ice-b51469b41167fb86ae2059a15cf0475c53fdda7b.zip
Down with ant. From the gradle to the grave.
Diffstat (limited to 'java/src/Freeze/TransactionI.java')
-rw-r--r--java/src/Freeze/TransactionI.java235
1 files changed, 0 insertions, 235 deletions
diff --git a/java/src/Freeze/TransactionI.java b/java/src/Freeze/TransactionI.java
deleted file mode 100644
index 55f61e5e217..00000000000
--- a/java/src/Freeze/TransactionI.java
+++ /dev/null
@@ -1,235 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
-//
-// This copy of Ice is licensed to you under the terms described in the
-// ICE_LICENSE file included in this distribution.
-//
-// **********************************************************************
-
-package Freeze;
-
-class TransactionI implements Transaction
-{
- @Override
- public void
- commit()
- {
- if(_txn == null)
- {
- throw new DatabaseException(_errorPrefix + "inactive transaction");
- }
-
- String txnId = null;
- boolean committed = false;
- boolean deadlock = false;
-
- try
- {
- _connection.closeAllIterators();
-
- if(_txTrace >= 1)
- {
- txnId = Long.toHexString((_txn.getId() & 0x7FFFFFFF) + 0x80000000L);
- }
-
- _txn.commit();
- committed = true;
-
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "committed transaction " + txnId);
- }
- }
- catch(com.sleepycat.db.DeadlockException e)
- {
- deadlock = true;
-
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "failed to commit transaction " + txnId + ": " +
- e.getMessage());
- }
-
- throw new DeadlockException(_errorPrefix + "DbTxn.commit: " + e.getMessage(), this, e);
- }
- catch(com.sleepycat.db.DatabaseException e)
- {
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "failed to commit transaction " + txnId + ": " +
- e.getMessage());
- }
-
- throw new DatabaseException(_errorPrefix + "DbTxn.commit: " + e.getMessage(), e);
- }
- finally
- {
- _connection.clearTransaction();
- SharedDbEnv dbEnv = _connection.dbEnv();
- if(_ownConnection)
- {
- _connection.close();
- }
- _connection = null;
- _txn = null;
- postCompletion(committed, deadlock, dbEnv);
- }
- }
-
- @Override
- public void
- rollback()
- {
- if(_txn == null)
- {
- throw new DatabaseException(_errorPrefix + "inactive transaction");
- }
-
- String txnId = null;
- boolean deadlock = false;
-
- try
- {
- _connection.closeAllIterators();
-
- if(_txTrace >= 1)
- {
- txnId = Long.toHexString((_txn.getId() & 0x7FFFFFFF) + 0x80000000L);
- }
-
- _txn.abort();
-
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "rolled back transaction " + txnId);
- }
- }
- catch(com.sleepycat.db.DeadlockException e)
- {
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "failed to rollback transaction " + txnId + ": " +
- e.getMessage());
- }
-
- deadlock = true;
-
- throw new DeadlockException(_errorPrefix + "DbTxn.abort: " + e.getMessage(), this, e);
- }
- catch(com.sleepycat.db.DatabaseException e)
- {
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "failed to rollback transaction " + txnId + ": " +
- e.getMessage());
- }
-
- throw new DatabaseException(_errorPrefix + "DbTxn.abort: " + e.getMessage(), e);
- }
- finally
- {
- _connection.clearTransaction();
- SharedDbEnv dbEnv = _connection.dbEnv();
- if(_ownConnection)
- {
- _connection.close();
- }
- _connection = null;
- _txn = null;
- postCompletion(false, deadlock, dbEnv);
- }
- }
-
- @Override
- public Connection
- getConnection()
- {
- return _connection;
- }
-
- TransactionI(ConnectionI connection)
- {
- _connection = connection;
- _txTrace = connection.txTrace();
- _errorPrefix = "DbEnv(\"" + _connection.envName() + "\"): ";
-
- try
- {
- _txn = _connection.dbEnv().getEnv().beginTransaction(null, null);
-
- if(_txTrace >= 1)
- {
- String txnId = Long.toHexString((_txn.getId() & 0x7FFFFFFF) + 0x80000000L);
-
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "started transaction " + txnId);
- }
- }
- catch(com.sleepycat.db.DatabaseException e)
- {
- if(_txTrace >= 1)
- {
- _connection.communicator().getLogger().trace("Freeze.Transaction", _errorPrefix +
- "failed to start transaction: " + e.getMessage());
- }
-
- throw new DatabaseException(_errorPrefix + "txn_begin: " + e.getMessage(), e);
- }
- }
-
- void
- setPostCompletionCallback(PostCompletionCallback cb)
- {
- _postCompletionCallback = cb;
- }
-
- void
- adoptConnection()
- {
- _ownConnection = true;
- }
-
- ConnectionI
- getConnectionI()
- {
- return _connection;
- }
-
- com.sleepycat.db.Transaction
- dbTxn()
- {
- return _txn;
- }
-
- private void
- postCompletion(boolean committed, boolean deadlock, SharedDbEnv dbEnv)
- {
- if(_postCompletionCallback != null)
- {
- try
- {
- _postCompletionCallback.postCompletion(committed, deadlock, dbEnv);
- }
- finally
- {
- _postCompletionCallback = null;
- }
- }
- }
-
- private ConnectionI _connection;
- private int _txTrace;
- private com.sleepycat.db.Transaction _txn;
-
- private PostCompletionCallback _postCompletionCallback;
-
- private String _errorPrefix;
- private boolean _ownConnection = false;
-}