|
| |
|
| java.lang.Object
 java.lang.Thread
org.continuent.sequoia.controller.virtualdatabase.VirtualDatabaseWorkerThread
| Method Summary | |
| public long | getCurrentTransactionId()
Return the current transaction id (should be 0 if not in a transaction). | | public long | getPersistentConnectionId()
Return the persistent connection id. | | public long | getTimeActive()
| | public String | getUser()
| | public void | notifyAbort(long tid)
Notify the abort of the given transaction which should match the current
transaction id of this thread else an exception will be thrown. | | public void | notifyClose(long persistentConnectionId)
Notify the closing of the given persistent connection which should match
the current persistent connection id of this thread else an exception will
be thrown. | | public String[] | retrieveClientData()
| | public void | run()
Gets a connection from the connection queue and process it. | | public void | shutdown()
Shutdown this thread by setting isKilled value to true. |
| VirtualDatabaseWorkerThread | | public VirtualDatabaseWorkerThread(Controller controller, VirtualDatabase vdb)(Code) | | Creates a new VirtualDatabaseWorkerThread instance.
Parameters:
controller - the thread was originated from
Parameters:
vdb - the virtual database instantiating this thread. |
| getCurrentTransactionId | | public long getCurrentTransactionId()(Code) | | Return the current transaction id (should be 0 if not in a transaction).
the current transaction id |
| getPersistentConnectionId | | public long getPersistentConnectionId()(Code) | | Return the persistent connection id.
the persistent connection id |
| getTimeActive | | public long getTimeActive()(Code) | | Get time active
time active since started |
| getUser | | public String getUser()(Code) | | Returns the login of the current user. |
| notifyAbort | | public void notifyAbort(long tid) throws SQLException(Code) | | Notify the abort of the given transaction which should match the current
transaction id of this thread else an exception will be thrown.
Parameters:
tid - the transaction identifier to abort
throws:
SQLException - if the tid does not correspond to the currenttransaction id of this thread or if the abort throws aSQLException |
| notifyClose | | public void notifyClose(long persistentConnectionId)(Code) | | Notify the closing of the given persistent connection which should match
the current persistent connection id of this thread else an exception will
be thrown.
Parameters:
tid - the persistent connection identifier to abort |
| retrieveClientData | | public String[] retrieveClientData()(Code) | | Retrieve general information on this client
an array of string |
| run | | public void run()(Code) | | Gets a connection from the connection queue and process it.
|
| shutdown | | public void shutdown()(Code) | | Shutdown this thread by setting isKilled value to true. This
gives time to check for needed rollback transactions
|
|
|
|