rice.pastry.socket
Class PingManager

java.lang.Object
  rice.selector.SelectionKeyHandler
      rice.pastry.socket.PingManager

public class PingManager

extends SelectionKeyHandler

Version:

$Id: PingManager.java,v 1.33 2005/05/16 18:30:22 amislove Exp $

Author:

jeffh To change the template for this generated type comment go to Window>Preferences>Java>Code Generation>Code and Comments

Nested Class Summary

class

PingManager.Envelope Internal class which holds a pending datagram

Field Summary

static int	DATAGRAM_RECEIVE_BUFFER_SIZE DESCRIBE THE FIELD
static int	DATAGRAM_SEND_BUFFER_SIZE DESCRIBE THE FIELD
protected static byte[]	HEADER_PING DESCRIBE THE FIELD
protected static byte[]	HEADER_SHORT_PING DESCRIBE THE FIELD
protected static byte[]	HEADER_SHORT_PING_RESPONSE DESCRIBE THE FIELD
static int	HEADER_SIZE DESCRIBE THE FIELD
protected java.util.ArrayList	pendingMsgs DESCRIBE THE FIELD
static int	PING_THROTTLE DESCRIBE THE FIELD
protected java.util.Hashtable	pingListeners DESCRIBE THE FIELD
static boolean	USE_SHORT_PINGS DESCRIBE THE FIELD

Constructor Summary

PingManager(SocketPastryNode spn, SocketSourceRouteManager manager, EpochInetSocketAddress bindAddress, EpochInetSocketAddress proxyAddress)

Method Summary

static byte[]	addHeader(SourceRoute path, java.lang.Object data, EpochInetSocketAddress localAddress) Method which adds a header for the provided path to the given data.
protected void	addPingResponseListener(SourceRoute path, PingResponseListener prl) Adds a feature to the PingResponseListener attribute of the PingManager object
static SourceRoute	decodeHeader(byte[] header) Method which adds a header for the provided path to the given data.
static java.lang.Object	deserialize(byte[] array) Method which takes in a ByteBuffer read from a datagram, and deserializes the contained object.
void	enqueue(SourceRoute path, java.lang.Object msg) DESCRIBE THE METHOD
void	modifyKey(java.nio.channels.SelectionKey key) DESCRIBE THE METHOD
protected void	notifyPingResponseListeners(SourceRoute path, int proximity, long lastTimePinged) caller must synchronized(pingResponseTimes)
protected void	ping(SourceRoute path, PingResponseListener prl) Method which actually sends a ping to over the specified path, and returns the result to the specified listener.
void	read(java.nio.channels.SelectionKey key) DESCRIBE THE METHOD
protected void	readHeader(java.net.InetSocketAddress address) Method which processes an incoming message and hands it off to the appropriate handler.
void	receiveMessage(java.lang.Object message, int size, java.net.InetSocketAddress from) DESCRIBE THE METHOD
protected void	resign() Makes this node resign from the network.
protected void	sendShortPing(SourceRoute route) Builds the data for a short ping
static byte[]	serialize(java.lang.Object message) Method which serializes a given object into a ByteBuffer, in order to prepare it for writing.
protected void	shortPingReceived(SourceRoute route, byte[] payload) Builds the data for a short ping response
protected void	shortPingResponseReceived(SourceRoute route, byte[] payload) Processes a short ping response
void	stall() Internal testing method which simulates a stall.
void	write(java.nio.channels.SelectionKey key) DESCRIBE THE METHOD

Methods inherited from class rice.selector.SelectionKeyHandler

accept, connect

Methods inherited from class java.lang.Object

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

Field Detail

pingListeners

protected java.util.Hashtable pingListeners

DESCRIBE THE FIELD

pendingMsgs

protected java.util.ArrayList pendingMsgs

DESCRIBE THE FIELD

USE_SHORT_PINGS

public static boolean USE_SHORT_PINGS

DESCRIBE THE FIELD

HEADER_PING

protected static byte[] HEADER_PING

DESCRIBE THE FIELD

HEADER_SHORT_PING

protected static byte[] HEADER_SHORT_PING

DESCRIBE THE FIELD

HEADER_SHORT_PING_RESPONSE

protected static byte[] HEADER_SHORT_PING_RESPONSE

DESCRIBE THE FIELD

HEADER_SIZE

public static int HEADER_SIZE

DESCRIBE THE FIELD

DATAGRAM_RECEIVE_BUFFER_SIZE

public static int DATAGRAM_RECEIVE_BUFFER_SIZE

DESCRIBE THE FIELD

DATAGRAM_SEND_BUFFER_SIZE

public static int DATAGRAM_SEND_BUFFER_SIZE

DESCRIBE THE FIELD

PING_THROTTLE

public static int PING_THROTTLE

DESCRIBE THE FIELD

Constructor Detail

PingManager

public PingManager(SocketPastryNode spn,
                   SocketSourceRouteManager manager,
                   EpochInetSocketAddress bindAddress,
                   EpochInetSocketAddress proxyAddress)

Parameters:

manager - DESCRIBE THE PARAMETER

spn - DESCRIBE THE PARAMETER

bindAddress - DESCRIBE THE PARAMETER

proxyAddress - DESCRIBE THE PARAMETER

Method Detail

ping

protected void ping(SourceRoute path,
                    PingResponseListener prl)

Method which actually sends a ping to over the specified path, and returns the result to the specified listener. Note that if no ping response is ever received, the listener is never called.

Parameters:

path - The path to send the ping over

prl - The listener which should hear about the response

resign

protected void resign()
               throws java.io.IOException

Makes this node resign from the network. Is designed to be used for debugging and testing.

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

stall

public void stall()

Internal testing method which simulates a stall. DO NOT USE!!!!!

sendShortPing

protected void sendShortPing(SourceRoute route)

Builds the data for a short ping

Parameters:

route - DESCRIBE THE PARAMETER

shortPingReceived

protected void shortPingReceived(SourceRoute route,
                                 byte[] payload)
                          throws java.io.IOException

Builds the data for a short ping response

Parameters:

route - DESCRIBE THE PARAMETER

payload - DESCRIBE THE PARAMETER

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

shortPingResponseReceived

protected void shortPingResponseReceived(SourceRoute route,
                                         byte[] payload)
                                  throws java.io.IOException

Processes a short ping response

Parameters:

route - DESCRIBE THE PARAMETER

payload - DESCRIBE THE PARAMETER

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

addPingResponseListener

protected void addPingResponseListener(SourceRoute path,
                                       PingResponseListener prl)

Adds a feature to the PingResponseListener attribute of the PingManager object

Parameters:

prl - The feature to be added to the PingResponseListener attribute

path - The feature to be added to the PingResponseListener attribute

notifyPingResponseListeners

protected void notifyPingResponseListeners(SourceRoute path,
                                           int proximity,
                                           long lastTimePinged)

caller must synchronized(pingResponseTimes)

Parameters:

proximity -

lastTimePinged -

path - DESCRIBE THE PARAMETER

enqueue

public void enqueue(SourceRoute path,
                    java.lang.Object msg)

DESCRIBE THE METHOD

Parameters:

msg - DESCRIBE THE PARAMETER

path - DESCRIBE THE PARAMETER

receiveMessage

public void receiveMessage(java.lang.Object message,
                           int size,
                           java.net.InetSocketAddress from)
                    throws java.io.IOException

DESCRIBE THE METHOD

Parameters:

message - DESCRIBE THE PARAMETER

size - DESCRIBE THE PARAMETER

from - DESCRIBE THE PARAMETER

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

read

public void read(java.nio.channels.SelectionKey key)

DESCRIBE THE METHOD

Overrides:

read in class SelectionKeyHandler

Parameters:

key - DESCRIBE THE PARAMETER

write

public void write(java.nio.channels.SelectionKey key)

DESCRIBE THE METHOD

Overrides:

write in class SelectionKeyHandler

Parameters:

key - DESCRIBE THE PARAMETER

modifyKey

public void modifyKey(java.nio.channels.SelectionKey key)

DESCRIBE THE METHOD

Overrides:

modifyKey in class SelectionKeyHandler

Parameters:

key - DESCRIBE THE PARAMETER

readHeader

protected void readHeader(java.net.InetSocketAddress address)
                   throws java.io.IOException

Method which processes an incoming message and hands it off to the appropriate handler.

Parameters:

address - DESCRIBE THE PARAMETER

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

serialize

public static byte[] serialize(java.lang.Object message)
                        throws java.io.IOException

Method which serializes a given object into a ByteBuffer, in order to prepare it for writing.

Parameters:

message - DESCRIBE THE PARAMETER

Returns:

A ByteBuffer containing the object

Throws:

java.io.IOException - if the object can't be serialized

deserialize

public static java.lang.Object deserialize(byte[] array)
                                    throws java.io.IOException

Method which takes in a ByteBuffer read from a datagram, and deserializes the contained object.

Parameters:

array - DESCRIBE THE PARAMETER

Returns:

The deserialized object.

Throws:

java.io.IOException - if the buffer can't be deserialized

addHeader

public static byte[] addHeader(SourceRoute path,
                               java.lang.Object data,
                               EpochInetSocketAddress localAddress)
                        throws java.io.IOException

Method which adds a header for the provided path to the given data.

Parameters:

path - The feature to be added to the Header attribute

data - The feature to be added to the Header attribute

localAddress - The feature to be added to the Header attribute

Returns:

The messag with a header attached

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION

decodeHeader

public static SourceRoute decodeHeader(byte[] header)
                                throws java.io.IOException

Method which adds a header for the provided path to the given data.

Parameters:

header - DESCRIBE THE PARAMETER

Returns:

The messag with a header attached

Throws:

java.io.IOException - DESCRIBE THE EXCEPTION