| |
|
| java.lang.Object java.lang.Thread org.continuent.sequoia.controller.loadbalancer.BackendWorkerThread
BackendWorkerThread | public class BackendWorkerThread extends Thread (Code) | | Process sequentially a set of tasks and send them to a backend.
author: Emmanuel Cecchet version: 1.0 |
BackendWorkerThread | public BackendWorkerThread(DatabaseBackend backend, AbstractLoadBalancer loadBalancer)(Code) | | Creates a new BackendWorkerThread .
Parameters: backend - the backend this thread is associated to. Parameters: loadBalancer - the load balancer instanciating this thread |
BackendWorkerThread | public BackendWorkerThread(String name, DatabaseBackend backend, AbstractLoadBalancer loadBalancer)(Code) | | Creates a new BackendWorkerThread .
Parameters: name - the name to give to the thread Parameters: backend - the backend this thread is associated to. Parameters: loadBalancer - the load balancer instanciating this thread |
getCurrentStatement | final public Statement getCurrentStatement()(Code) | | Returns the currentStatement value.
Returns the currentStatement. |
getLoadBalancer | final public AbstractLoadBalancer getLoadBalancer()(Code) | | Returns the loadBalancer value.
Returns the loadBalancer. |
getLogger | public Trace getLogger()(Code) | | Returns the logger for tracing.
a Trace instance |
isPlayingCommitRollbackOnly | public boolean isPlayingCommitRollbackOnly()(Code) | | Returns the playCommitRollbackOnly value.
Returns the playCommitRollbackOnly. |
killAndForceDisable | public void killAndForceDisable()(Code) | | Kills this thread after the next task processing and forces the load
balancer to disable the backend. It also marks all remaining tasks in the
task list as failed.
|
killWithoutDisablingBackend | public void killWithoutDisablingBackend()(Code) | | Kills this thread after the next task processing. It also disables the
backend.
|
run | public void run()(Code) | | Process the tasklist and call wait() (on itself) when the
tasklist becomes empty.
|
setCurrentStatement | final public void setCurrentStatement(Statement currentStatement)(Code) | | Sets the currentStatement value.
Parameters: currentStatement - The currentStatement to set. |
setPlayCommitRollbackOnly | public void setPlayCommitRollbackOnly(boolean playCommitRollbackOnly)(Code) | | Sets the playCommitRollbackOnly value.
Parameters: playCommitRollbackOnly - The playCommitRollbackOnly to set. |
|
|
|