fabric.worker.remote

Class RemoteWorker

java.lang.Object

fabric.net.RemoteNode<RemoteWorker>

fabric.worker.remote.RemoteWorker

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

InProcessRemoteWorker

public class RemoteWorker
extends RemoteNode<RemoteWorker>

Encapsulates a remote worker. This class maintains the connection to the remote worker and manages all communication. RemoteWorkers can only be obtained through the RemoteCallManager.getWorker() interface. For each remote worker, there should be at most one RemoteWorker object representing that worker.

See Also:

Serialized Form

Field Summary

Fields inherited from class fabric.net.RemoteNode

name

Constructor Summary

Constructors

Constructor and Description
RemoteWorker(java.lang.String name) This should only be called by fabric.worker.Worker.

Method Summary

Modifier and Type	Method and Description
void	abortTransaction(TransactionID tid) Informs the remote worker that a transaction is aborting.
boolean	checkForStaleObjects(TransactionID tid) Asks the worker to check that the objects used in a given transaction are up-to-date.
void	commitTransaction(long tid)
Principal	getPrincipal()
java.lang.Object	issueRemoteCall(Object._Proxy receiver, java.lang.String methodName, java.lang.Class<?>[] parameterTypes, java.lang.Object[] args)
java.util.List<java.lang.Long>	notifyObjectUpdates(java.util.List<java.lang.Long> updatedOnums, java.util.List<ObjectGroup> updates) Notifies the worker that a set of objects has been updated.
java.util.List<java.lang.Long>	notifyObjectUpdates(java.lang.String store, LongKeyMap<ObjectGlob> updates) Notifies the dissemination node at the given worker that an object has been updated.
void	prepareTransaction(long tid)
void	readObject(TransactionID tid, Object._Impl obj) Reads the given object from the remote worker, updating the object's state.
Pair<Store,SerializedObject>	readObject(TransactionID tid, Store store, long onum)
void	takeOwnership(TransactionID tid, Store store, long onum) Unsets the ownership bit for the given object at the remote worker.
java.lang.String	toString()

Methods inherited from class fabric.net.RemoteNode

getSocket, name, recycle, send

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteWorker

public RemoteWorker(java.lang.String name)

This should only be called by fabric.worker.Worker. If you want a RemoteWorker, use fabric.worker.Worker.getWorker() instead.

Method Detail

issueRemoteCall

public java.lang.Object issueRemoteCall(Object._Proxy receiver,
                                        java.lang.String methodName,
                                        java.lang.Class<?>[] parameterTypes,
                                        java.lang.Object[] args)
                                 throws UnreachableNodeException,
                                        RemoteCallException

Throws:

UnreachableNodeException

RemoteCallException

prepareTransaction

public void prepareTransaction(long tid)
                        throws UnreachableNodeException,
                               TransactionPrepareFailedException

Throws:

UnreachableNodeException

TransactionPrepareFailedException

commitTransaction

public void commitTransaction(long tid)
                       throws UnreachableNodeException,
                              TransactionCommitFailedException

Throws:

UnreachableNodeException

TransactionCommitFailedException

abortTransaction

public void abortTransaction(TransactionID tid)
                      throws AccessException,
                             UnreachableNodeException

Informs the remote worker that a transaction is aborting.

Parameters:

tid - the tid for the transaction that is aborting.

Throws:

AccessException

UnreachableNodeException

readObject

public void readObject(TransactionID tid,
                       Object._Impl obj)

Reads the given object from the remote worker, updating the object's state.

Parameters:

tid - the tid for the current transaction.

readObject

public Pair<Store,SerializedObject> readObject(TransactionID tid,
                                               Store store,
                                               long onum)
                                        throws AccessException

Throws:

AccessException

takeOwnership

public void takeOwnership(TransactionID tid,
                          Store store,
                          long onum)

Unsets the ownership bit for the given object at the remote worker.

Parameters:

tid - the tid for the current transaction.

getPrincipal

public Principal getPrincipal()

Specified by:

getPrincipal in class RemoteNode<RemoteWorker>

Returns:

the principal associated with the remote worker.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

notifyObjectUpdates

public java.util.List<java.lang.Long> notifyObjectUpdates(java.lang.String store,
                                                          LongKeyMap<ObjectGlob> updates)

Notifies the dissemination node at the given worker that an object has been updated.

Returns:

whether the node is resubscribing to the object.

notifyObjectUpdates

public java.util.List<java.lang.Long> notifyObjectUpdates(java.util.List<java.lang.Long> updatedOnums,
                                                          java.util.List<ObjectGroup> updates)

Notifies the worker that a set of objects has been updated.

Returns:

whether the node is resubscribing to the object.

checkForStaleObjects

public boolean checkForStaleObjects(TransactionID tid)

Asks the worker to check that the objects used in a given transaction are up-to-date.