fabric.worker.remote

Class RemoteCallManager

java.lang.Object

fabric.messages.AbstractMessageServer

fabric.messages.MessageToWorkerHandler

fabric.worker.remote.RemoteCallManager

All Implemented Interfaces:

MessageHandler, java.lang.Runnable

public class RemoteCallManager
extends MessageToWorkerHandler

A thread that handles incoming requests from other workers.

Field Summary

Fields inherited from class fabric.messages.AbstractMessageServer

logger, name

Constructor Summary

Constructors

Constructor and Description
RemoteCallManager(Worker worker)

Method Summary

Modifier and Type	Method and Description
protected SubServerSocket	createServerSocket() Creates and returns a SubServerSocket for listening to requests.
AbortTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, AbortTransactionMessage abortTransactionMessage) In each message handler, we maintain the invariant that upon exit, the worker's TransactionManager is associated with a null log.
CommitTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, CommitTransactionMessage commitTransactionMessage) In each message handler, we maintain the invariant that upon exit, the worker's TransactionManager is associated with a null log.
DirtyReadMessage.Response	handle(RemoteIdentity<RemoteWorker> client, DirtyReadMessage readMessage)
InterWorkerStalenessMessage.Response	handle(RemoteIdentity<RemoteWorker> client, InterWorkerStalenessMessage stalenessCheckMessage)
ObjectUpdateMessage.Response	handle(RemoteIdentity<RemoteWorker> client, ObjectUpdateMessage objectUpdateMessage)
PrepareTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, PrepareTransactionMessage prepareTransactionMessage)
RemoteCallMessage.Response	handle(RemoteIdentity<RemoteWorker> client, RemoteCallMessage remoteCallMessage)
TakeOwnershipMessage.Response	handle(RemoteIdentity<RemoteWorker> client, TakeOwnershipMessage msg)

Methods inherited from class fabric.messages.MessageToWorkerHandler

handle, handle, handle, handle, handle, handle

Methods inherited from class fabric.messages.AbstractMessageServer

run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemoteCallManager

public RemoteCallManager(Worker worker)

Method Detail

createServerSocket

protected SubServerSocket createServerSocket()

Description copied from class: AbstractMessageServer

Creates and returns a SubServerSocket for listening to requests.

Specified by:

createServerSocket in class AbstractMessageServer

handle

public RemoteCallMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                         RemoteCallMessage remoteCallMessage)
                                  throws RemoteCallException

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

Throws:

RemoteCallException

handle

public AbortTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                               AbortTransactionMessage abortTransactionMessage)

In each message handler, we maintain the invariant that upon exit, the worker's TransactionManager is associated with a null log.

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

handle

public PrepareTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                 PrepareTransactionMessage prepareTransactionMessage)
                                          throws TransactionPrepareFailedException

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

Throws:

TransactionPrepareFailedException

handle

public CommitTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                CommitTransactionMessage commitTransactionMessage)
                                         throws TransactionCommitFailedException

In each message handler, we maintain the invariant that upon exit, the worker's TransactionManager is associated with a null log.

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

Throws:

TransactionCommitFailedException

handle

public DirtyReadMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                        DirtyReadMessage readMessage)

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

handle

public TakeOwnershipMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                            TakeOwnershipMessage msg)
                                     throws TakeOwnershipFailedException

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

Throws:

TakeOwnershipFailedException

handle

public ObjectUpdateMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                           ObjectUpdateMessage objectUpdateMessage)

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler

handle

public InterWorkerStalenessMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                   InterWorkerStalenessMessage stalenessCheckMessage)

Specified by:

handle in interface MessageHandler

Specified by:

handle in class MessageToWorkerHandler