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.

Field Summary

protected int	nextUID The next message UID which is available
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
int	STATE_WAITING

Constructor Summary

ReplicationManagerImpl.ReplicationManagerHelper()
Constructor

Method Summary

void	fetch(IdSet keySet) 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
protected int	getNextUID() Returns the next unique id for a message
void	message(int id)
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()

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

STATE_SLEEPING

public int STATE_SLEEPING

state

protected int state

The current state that we are in

set

protected IdSet set

The set of keys we have yet to fetch

nextUID

protected int nextUID

The next message UID which is available

Constructor Detail

ReplicationManagerImpl.ReplicationManagerHelper

public ReplicationManagerImpl.ReplicationManagerHelper()

Constructor

Method Detail

fetch

public void fetch(IdSet keySet)

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

Parameters:

keySet - The keys to add

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

send

protected void send()

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

getNextUID

protected int getNextUID()

Returns the next unique id for a message

Returns:

The next available UID

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

wakeup

public void wakeup()

message

public void message(int id)