routing

Class WaveRouter

java.lang.Object

routing.MessageRouter

routing.ActiveRouter

routing.WaveRouter

public class WaveRouter
extends ActiveRouter

Epidemic-like message router making waves of messages. Work in progress.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CUSTODY_S Custody fraction -setting id ("custodyFraction").
static java.lang.String	IMMUNITY_S Immunity time -setting id ("immunityTime").

Fields inherited from class routing.ActiveRouter

DELETE_DELIVERED_S, deleteDelivered, RESPONSE_PREFIX, sendingConnections

Fields inherited from class routing.MessageRouter

B_SIZE_S, DENIED_LOW_RESOURCES, DENIED_NO_SPACE, DENIED_OLD, DENIED_POLICY, DENIED_TTL, DENIED_UNSPECIFIED, MSG_TTL_S, msgTtl, Q_MODE_FIFO, Q_MODE_RANDOM, RCV_OK, SEND_QUEUE_MODE_S, TRY_LATER_BUSY

Constructor Summary

Constructors

Modifier	Constructor and Description
	WaveRouter(Settings s) Constructor.
protected	WaveRouter(WaveRouter r) Copy constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected int	checkReceiving(Message m, DTNHost from) Checks if router "wants" to start receiving message (i.e.
protected Message	getNextMessageToRemove(boolean excludeMsgBeingSent) Returns the oldest message that has been already sent forward
RoutingInfo	getRoutingInfo() Returns routing information about this router.
Message	messageTransferred(java.lang.String id, DTNHost from) This method should be called (on the receiving host) after a message was successfully transferred.
WaveRouter	replicate() Creates a replicate of this router.
protected void	transferDone(Connection con) Method is called just before a transfer is finalized at ActiveRouter.update().
void	update() Checks out all sending connections to finalize the ready ones and abort those whose connection went down.

Methods inherited from class routing.ActiveRouter

addToSendingConnections, canStartTransfer, changedConnection, createNewMessage, dropExpiredMessages, exchangeDeliverableMessages, getConnections, getMessagesForConnected, hasEnergy, init, isSending, isTransferring, makeRoomForMessage, makeRoomForNewMessage, receiveMessage, requestDeliverableMessages, shuffleMessages, startTransfer, transferAborted, tryAllMessages, tryAllMessagesToAllConnections, tryMessagesForConnected, tryMessagesToConnections

Methods inherited from class routing.MessageRouter

addApplication, addToMessages, compareByQueueMode, deleteMessage, getApplications, getBufferSize, getFreeBufferSize, getHost, getMessage, getMessageCollection, getNrofMessages, hasMessage, isBlacklistedMessage, isDeliveredMessage, isIncomingMessage, messageAborted, putToIncomingBuffer, removeFromIncomingBuffer, removeFromMessages, sendMessage, sortByQueueMode, toString

Methods inherited from class java.lang.Object

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

Field Detail

IMMUNITY_S

public static final java.lang.String IMMUNITY_S

Immunity time -setting id ("immunityTime"). Defines how long time a node will reject incoming messages it has already received

See Also:

Constant Field Values

CUSTODY_S

public static final java.lang.String CUSTODY_S

Custody fraction -setting id ("custodyFraction"). Defines how long (compared to immunity time) nodes accept custody for new incoming messages.

See Also:

Constant Field Values

Constructor Detail

WaveRouter

public WaveRouter(Settings s)

Constructor. Creates a new message router based on the settings in the given Settings object.

Parameters:

s - The settings object

WaveRouter

protected WaveRouter(WaveRouter r)

Copy constructor.

Parameters:

r - The router prototype where setting values are copied from

Method Detail

checkReceiving

protected int checkReceiving(Message m,
                 DTNHost from)

Description copied from class: ActiveRouter

Checks if router "wants" to start receiving message (i.e. router isn't transferring, doesn't have the message and has room for it).

Overrides:

checkReceiving in class ActiveRouter

Parameters:

m - The message to check

Returns:

A return code similar to MessageRouter.receiveMessage(Message, DTNHost), i.e. MessageRouter.RCV_OK if receiving seems to be OK, TRY_LATER_BUSY if router is transferring, DENIED_OLD if the router is already carrying the message or it has been delivered to this router (as final recipient), or DENIED_NO_SPACE if the message does not fit into buffer

getNextMessageToRemove

protected Message getNextMessageToRemove(boolean excludeMsgBeingSent)

Returns the oldest message that has been already sent forward

Overrides:

getNextMessageToRemove in class ActiveRouter

Parameters:

excludeMsgBeingSent - If true, excludes message(s) that are being sent from the oldest message check (i.e. if oldest message is being sent, the second oldest message is returned)

Returns:

The oldest message or null if no message could be returned (no messages in buffer or all messages in buffer are being sent and exludeMsgBeingSent is true)

update

public void update()

Description copied from class: ActiveRouter

Checks out all sending connections to finalize the ready ones and abort those whose connection went down. Also drops messages whose TTL <= 0 (checking every one simulated minute).

Overrides:

update in class ActiveRouter

See Also:

ActiveRouter.addToSendingConnections(Connection)

messageTransferred

public Message messageTransferred(java.lang.String id,
                         DTNHost from)

Description copied from class: MessageRouter

This method should be called (on the receiving host) after a message was successfully transferred. The transferred message is put to the message buffer unless this host is the final recipient of the message.

Overrides:

messageTransferred in class ActiveRouter

Parameters:

id - Id of the transferred message

from - Host the message was from (previous hop)

Returns:

The message that this host received

transferDone

protected void transferDone(Connection con)

Description copied from class: ActiveRouter

Method is called just before a transfer is finalized at ActiveRouter.update(). Subclasses that are interested of the event may want to override this.

Overrides:

transferDone in class ActiveRouter

Parameters:

con - The connection whose transfer was finalized

getRoutingInfo

public RoutingInfo getRoutingInfo()

Description copied from class: MessageRouter

Returns routing information about this router.

Overrides:

getRoutingInfo in class ActiveRouter

Returns:

The routing information.

replicate

public WaveRouter replicate()

Description copied from class: MessageRouter

Creates a replicate of this router. The replicate has the same settings as this router but empty buffers and routing tables.

Specified by:

replicate in class MessageRouter

Returns:

The replicate