freenet.io.comm

Class MessageCore

java.lang.Object

freenet.io.comm.MessageCore

public class MessageCore
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	VERSION

Constructor Summary

Constructors

Constructor and Description
MessageCore(Executor executor)

Method Summary

Modifier and Type	Method and Description
void	addAsyncFilter(MessageFilter filter, AsyncMessageFilterCallback callback, ByteCounter ctr)
void	checkFilters(Message m, PacketSocketHandler from) Dispatch a message to a waiting filter, or feed it to the Dispatcher if none are found.
Message	decodeSingleMessage(byte[] data, int offset, int length, PeerContext peer, int overhead) Decode a packet from data and a peer.
Executor	getExecutor()
long	getStartedTime()
java.util.Map<java.lang.String,java.lang.Integer>	getUnclaimedFIFOMessageCounts()
int	getUnclaimedFIFOSize()
void	onDisconnect(PeerContext ctx) IncomingPacketFilter should call this when a node is disconnected.
void	onRestart(PeerContext ctx) IncomingPacketFilter should call this when a node connects with a new boot ID
void	send(PeerContext destination, Message m, ByteCounter ctr) Send a Message to a PeerContext.
void	setDispatcher(Dispatcher d)
void	start(Ticker ticker)
Message	waitFor(MessageFilter filter, ByteCounter ctr) Wait for a filter to trigger, or timeout.

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final java.lang.String VERSION

See Also:

Constant Field Values

Constructor Detail

MessageCore

public MessageCore(Executor executor)

Method Detail

getStartedTime

public long getStartedTime()

decodeSingleMessage

public Message decodeSingleMessage(byte[] data,
                                   int offset,
                                   int length,
                                   PeerContext peer,
                                   int overhead)

Decode a packet from data and a peer. Can be called by IncomingPacketFilter's.

Parameters:

data -

offset -

length -

peer -

start

public void start(Ticker ticker)

checkFilters

public void checkFilters(Message m,
                         PacketSocketHandler from)

Dispatch a message to a waiting filter, or feed it to the Dispatcher if none are found.

Parameters:

m - The Message to dispatch.

onDisconnect

public void onDisconnect(PeerContext ctx)

IncomingPacketFilter should call this when a node is disconnected.

onRestart

public void onRestart(PeerContext ctx)

IncomingPacketFilter should call this when a node connects with a new boot ID

addAsyncFilter

public void addAsyncFilter(MessageFilter filter,
                           AsyncMessageFilterCallback callback,
                           ByteCounter ctr)
                    throws DisconnectedException

Throws:

DisconnectedException

waitFor

public Message waitFor(MessageFilter filter,
                       ByteCounter ctr)
                throws DisconnectedException

Wait for a filter to trigger, or timeout. Blocks until either the trigger is activated, or it times out, or the peer is disconnected.

Parameters:

filter - The filter to wait for. This filter must not have a callback.

ctr - Byte counter to add bytes from the message to.

Returns:

Either a message, or null if the filter timed out.

Throws:

DisconnectedException - If the single peer being waited for disconnects.

java.lang.IllegalArgumentException - If filter has a callback

send

public void send(PeerContext destination,
                 Message m,
                 ByteCounter ctr)
          throws NotConnectedException

Send a Message to a PeerContext.

Throws:

NotConnectedException - If we are not currently connected to the node.

setDispatcher

public void setDispatcher(Dispatcher d)

getUnclaimedFIFOSize

public int getUnclaimedFIFOSize()

Returns:

the number of received messages that are currently unclaimed

getUnclaimedFIFOMessageCounts

public java.util.Map<java.lang.String,java.lang.Integer> getUnclaimedFIFOMessageCounts()

getExecutor

public Executor getExecutor()