fabric.worker.remote

Class InProcessRemoteWorker

java.lang.Object

fabric.net.RemoteNode<RemoteWorker>

fabric.worker.remote.RemoteWorker

fabric.worker.remote.InProcessRemoteWorker

All Implemented Interfaces:

java.io.Serializable

public class InProcessRemoteWorker
extends RemoteWorker

In-process implementation of RemoteWorker. This is so that a store or dissemination node can contact its colocated worker using the same interface as a worker that is genuinely remote.

See Also:

Serialized Form

Field Summary

Fields inherited from class fabric.net.RemoteNode

name

Constructor Summary

Constructors

Constructor and Description
InProcessRemoteWorker(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 storeName, 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.

Methods inherited from class fabric.worker.remote.RemoteWorker

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

InProcessRemoteWorker

public InProcessRemoteWorker(Worker worker)

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

Overrides:

issueRemoteCall in class RemoteWorker

Throws:

UnreachableNodeException

RemoteCallException

prepareTransaction

public void prepareTransaction(long tid)
                        throws UnreachableNodeException,
                               TransactionPrepareFailedException

Overrides:

prepareTransaction in class RemoteWorker

Throws:

UnreachableNodeException

TransactionPrepareFailedException

commitTransaction

public void commitTransaction(long tid)
                       throws UnreachableNodeException,
                              TransactionCommitFailedException

Overrides:

commitTransaction in class RemoteWorker

Throws:

UnreachableNodeException

TransactionCommitFailedException

abortTransaction

public void abortTransaction(TransactionID tid)
                      throws AccessException,
                             UnreachableNodeException

Description copied from class: RemoteWorker

Informs the remote worker that a transaction is aborting.

Overrides:

abortTransaction in class RemoteWorker

Parameters:

tid - the tid for the transaction that is aborting.

Throws:

AccessException

UnreachableNodeException

readObject

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

Description copied from class: RemoteWorker

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

Overrides:

readObject in class RemoteWorker

Parameters:

tid - the tid for the current transaction.

readObject

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

Overrides:

readObject in class RemoteWorker

Throws:

AccessException

takeOwnership

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

Description copied from class: RemoteWorker

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

Overrides:

takeOwnership in class RemoteWorker

Parameters:

tid - the tid for the current transaction.

getPrincipal

public Principal getPrincipal()

Overrides:

getPrincipal in class RemoteWorker

Returns:

the principal associated with the remote worker.

notifyObjectUpdates

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

Description copied from class: RemoteWorker

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

Overrides:

notifyObjectUpdates in class RemoteWorker

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)

Description copied from class: RemoteWorker

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

Overrides:

notifyObjectUpdates in class RemoteWorker

Returns:

whether the node is resubscribing to the object.

checkForStaleObjects

public boolean checkForStaleObjects(TransactionID tid)

Description copied from class: RemoteWorker

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

Overrides:

checkForStaleObjects in class RemoteWorker