fabric.messages

Class TakeOwnershipMessage

java.lang.Object

fabric.messages.Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

fabric.messages.TakeOwnershipMessage

public class TakeOwnershipMessage
extends Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

Represents a request from a worker to take ownership of an object from another worker.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TakeOwnershipMessage.Response

Nested classes/interfaces inherited from class fabric.messages.Message

Message.MessageType, Message.NoException

Field Summary

Fields

Modifier and Type	Field and Description
long	onum
Store	store
TransactionID	tid

Fields inherited from class fabric.messages.Message

exceptionClass, messageType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TakeOwnershipMessage(java.io.DataInput in)
	TakeOwnershipMessage(TransactionID tid, Store store, long onum)

Method Summary

Modifier and Type	Method and Description
TakeOwnershipMessage.Response	dispatch(RemoteIdentity<RemoteWorker> worker, MessageHandler h) Visitor method.
protected TakeOwnershipMessage.Response	readResponse(java.io.DataInput in) Creates a Response message of the appropriate type using the provided DataOutput
protected void	writeMessage(java.io.DataOutput out) Writes this message out on the given output stream.
void	writeResponse(java.io.DataOutput out, TakeOwnershipMessage.Response r) Writes a Response message of the appropriate type using the provided DataOutput.

Methods inherited from class fabric.messages.Message

readObject, readRef, receive, respond, respond, send, writeObject, writeRef

Methods inherited from class java.lang.Object

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

Field Detail

tid

public final TransactionID tid

store

public final Store store

onum

public final long onum

Constructor Detail

TakeOwnershipMessage

public TakeOwnershipMessage(TransactionID tid,
                            Store store,
                            long onum)

TakeOwnershipMessage

protected TakeOwnershipMessage(java.io.DataInput in)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

dispatch

public TakeOwnershipMessage.Response dispatch(RemoteIdentity<RemoteWorker> worker,
                                              MessageHandler h)
                                       throws ProtocolError,
                                              TakeOwnershipFailedException

Description copied from class: Message

Visitor method.

Specified by:

dispatch in class Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

Parameters:

worker - the node that is issuing the request.

h - the handler to which this message is to be dispatched.

Throws:

ProtocolError

TakeOwnershipFailedException

writeMessage

protected void writeMessage(java.io.DataOutput out)
                     throws java.io.IOException

Description copied from class: Message

Writes this message out on the given output stream.

Specified by:

writeMessage in class Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

Throws:

java.io.IOException - if the DataOutput fails.

writeResponse

public void writeResponse(java.io.DataOutput out,
                          TakeOwnershipMessage.Response r)
                   throws java.io.IOException

Description copied from class: Message

Writes a Response message of the appropriate type using the provided DataOutput.

Specified by:

writeResponse in class Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

Throws:

java.io.IOException - if the DataOutput fails.

readResponse

protected TakeOwnershipMessage.Response readResponse(java.io.DataInput in)
                                              throws java.io.IOException

Description copied from class: Message

Creates a Response message of the appropriate type using the provided DataOutput

Specified by:

readResponse in class Message<TakeOwnershipMessage.Response,TakeOwnershipFailedException>

Throws:

java.io.IOException - if the response is malformed, or if the DataInput fails.