rice.p2p.replication.manager
Class ReplicationManagerImpl.ReplicationManagerHelper

java.lang.Object
  rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Enclosing class:

ReplicationManagerImpl

protected class ReplicationManagerImpl.ReplicationManagerHelper

extends java.lang.Object

Inner class which keeps track of the state we're in- waiting, sleeping, or with nothing to do.

Version:

$Id: pretty.settings 2305 2005-03-11 20:22:33Z jeffh $

Author:

jeffh

Field Summary

protected Id	current The next message UID which is available
protected java.util.HashMap	hints A cache of hints, mapping Id -> NodeHandle
protected IdSet	set The set of keys we have yet to fetch
protected int	state The current state that we are in
int	STATE_NOTHING The set of possible states we can be in
int	STATE_SLEEPING DESCRIBE THE FIELD
int	STATE_WAITING DESCRIBE THE FIELD

Constructor Summary

ReplicationManagerImpl.ReplicationManagerHelper()
Constructor

Method Summary

void	fetch(IdSet keySet, NodeHandle hint) Method by which keys are added to the list of keys to fetch
protected Id	getNextId() Interal method which safely takes the next id to be fetched from the set of pending keys
void	message(Id id) DESCRIBE THE METHOD
IdSet	scan(IdRange range) In this case, it returns the list of keys the client has, along with the keys which we have yet to tell the client to fetch.
protected void	send() Method which determines if a message should be sent, and if so, sends it
void	setRange(IdRange range) Method by which the range is set, which will delete any keys from the to fetch list not in the range
void	wakeup() DESCRIBE THE METHOD

Methods inherited from class java.lang.Object

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

Field Detail

STATE_NOTHING

public int STATE_NOTHING

The set of possible states we can be in

STATE_WAITING

public int STATE_WAITING

DESCRIBE THE FIELD

STATE_SLEEPING

public int STATE_SLEEPING

DESCRIBE THE FIELD

state

protected int state

The current state that we are in

set

protected IdSet set

The set of keys we have yet to fetch

current

protected Id current

The next message UID which is available

hints

protected java.util.HashMap hints

A cache of hints, mapping Id -> NodeHandle

Constructor Detail

ReplicationManagerImpl.ReplicationManagerHelper

public ReplicationManagerImpl.ReplicationManagerHelper()

Constructor

Method Detail

getNextId

protected Id getNextId()

Interal method which safely takes the next id to be fetched from the set of pending keys

Returns:

The next key to be fetched

setRange

public void setRange(IdRange range)

Method by which the range is set, which will delete any keys from the to fetch list not in the range

Parameters:

range - The new range

fetch

public void fetch(IdSet keySet,
                  NodeHandle hint)

Method by which keys are added to the list of keys to fetch

Parameters:

keySet - The keys to add

hint - DESCRIBE THE PARAMETER

scan

public IdSet scan(IdRange range)

In this case, it returns the list of keys the client has, along with the keys which we have yet to tell the client to fetch.

Parameters:

range - the requested range

Returns:

DESCRIBE THE RETURN VALUE

send

protected void send()

Method which determines if a message should be sent, and if so, sends it

wakeup

public void wakeup()

DESCRIBE THE METHOD

message

public void message(Id id)

DESCRIBE THE METHOD

Parameters:

id - DESCRIBE THE PARAMETER