|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sun.jini.mahalo.Job
com.sun.jini.mahalo.PrepareAndCommitJob
public class PrepareAndCommitJob
An implementation of a Job
which interacts with
a set of TransactionParticipant
s to inform them
to vote and roll forward/back changes associated with a given
Transaction
.
Job
,
ParticipantTask
,
Transaction
,
TransactionParticipant
Field Summary | |
---|---|
(package private) ParticipantHandle |
handle
|
(package private) ClientLog |
log
|
(package private) int |
maxtries
|
private boolean |
notifyClient
|
private static Logger |
operationsLogger
Logger for operations related messages |
private static Logger |
persistenceLogger
Logger for persistence related messages |
private RemoteException |
reCaught
|
(package private) ServerTransaction |
tr
|
Fields inherited from class com.sun.jini.mahalo.Job |
---|
attempts, logger, results |
Fields inherited from interface net.jini.core.transaction.server.TransactionConstants |
---|
ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING |
Constructor Summary | |
---|---|
PrepareAndCommitJob(Transaction tr,
TaskManager pool,
WakeupManager wm,
ClientLog log,
ParticipantHandle handle)
Constructs a PrepareAndCommitJob . |
Method Summary | |
---|---|
(package private) Object |
computeResult()
Gathers partial results submitted by tasks and produces a single outcome. |
(package private) TaskManager.Task[] |
createTasks()
Creates the TaskManager.Task s necessary to
inform participants to vote and roll-forward/back. |
(package private) Object |
doWork(TaskManager.Task who,
Object param)
The work to be performed by each TaskManager.Task
is provided by the Job that creates it. |
(package private) Exception |
getAlternateException()
Simple accessor that returns the the exception to send back to the client. |
Methods inherited from class com.sun.jini.mahalo.Job |
---|
attempt, getMgr, getPool, isCompleted, performWork, scheduleTasks, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
ServerTransaction tr
ClientLog log
ParticipantHandle handle
int maxtries
private volatile RemoteException reCaught
private volatile boolean notifyClient
private static final Logger operationsLogger
private static final Logger persistenceLogger
Constructor Detail |
---|
public PrepareAndCommitJob(Transaction tr, TaskManager pool, WakeupManager wm, ClientLog log, ParticipantHandle handle)
PrepareAndCommitJob
.
tr
- The Transaction
whose participants
will be instructed to vote and roll-forward/back.pool
- The TaskManager
which provides the
threads used for interacting with participants.log
- The ClientLog
used for recording
recovery data.handle
- The array of participants which will be contacted
and informed to vote and roll-forward/back.TaskManager
,
ClientLog
,
TransactionParticipant
Method Detail |
---|
Object doWork(TaskManager.Task who, Object param)
TaskManager.Task
is provided by the Job
that creates it.
The work performed by a task belonging to the CommitJob
contacts a participant, instructs it to vote, roll-forward/back
and log appropriately.
doWork
in class Job
who
- The task performing the workparam
- A parameter, of the task's choosing, useful
in performing work.Job
,
TaskManager.Task
TaskManager.Task[] createTasks()
TaskManager.Task
s necessary to
inform participants to vote and roll-forward/back.
createTasks
in class Job
Object computeResult() throws JobException
computeResult
in class Job
JobException
Job
Exception getAlternateException()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |