rice.pastry.wire
Class SocketChannelWriter
- public class SocketChannelWriter
- Class which serves as an "writer" for all of the messages sent across the wire in Pastry. This class serializes and properly formats all messages, and then waits to be called with an available SocketChannel in order to write the message out. If the messagae could not be written in one go, subsequent calls to the write() method will finish writing out the message. This class also maintains an internal queue of messages waiting to be sent across the wire. Calling isEmpty() will tell clients if it is safe to mark the SelectionKey as not being interested in writing.
- Version:
- $Id: SocketChannelWriter.java,v 1.6 2002/09/13 03:23:56 amislove Exp $
- Author:
- Alan Mislove
SocketChannelWriter
public SocketChannelWriter(rice.pastry.wire.WirePastryNode spn,
rice.pastry.wire.messaging.socket.SocketCommandMessage msg)
- Constructor which creates this SocketChannelWriter with a pastry node and an object to write out.
- Parameters:
spn
- The PastryNode the SocketChannelWriter servers
o
- The object to be written
enqueue
public void enqueue(java.lang.Object o)
- Adds an object to this SocketChannelWriter's queue of pending objects to write. This methos is synchronized and therefore safe for use by multiple threads.
- Parameters:
o
- The object to be written.
isEmpty
public boolean isEmpty()
- Returns whether or not there are objects in the queue on in writing. If the result is true, it the safe to mark the SelectionKey as not being interested in writing.
- Returns:
- Whether or not there are objects still to be written.
getQueue
public java.util.LinkedList getQueue()
- Returns the queue of writes for the remote address
- Returns:
- the queue of writes for the remote address
reset
public void reset(rice.pastry.wire.messaging.socket.SocketCommandMessage msg)
- Resets the SocketChannelWriter, by clearing both the buffer and the queue. Should not be used except when a socket has just been opened.
- Parameters:
msg
- The greeting message that should be enqueued first
write
public boolean write(java.nio.channels.SocketChannel sc)
- Method which is designed to be called when this writer should write out its data. Returns whether or not the message was completely written. If false is returns, write() will need to be called again when the SocketChannel is ready for data to be written.
- Parameters:
sc
- The SocketChannel to write to
- Returns:
- true if this output stream is done, false otherwise
serialize
public static java.nio.ByteBuffer serialize(java.lang.Object o)
- Method which serializes a given object into a ByteBuffer, in order to prepare it for writing. This is necessary because the size of the object must be prepended to the to the front of the buffer in order to tell the reciever how long the object is.
- Parameters:
o
- The object to serialize
- Returns:
- A ByteBuffer containing the object prepended with its size.