freenet.node

Class FNPPacketMangler

java.lang.Object

freenet.node.FNPPacketMangler

All Implemented Interfaces:

OutgoingPacketMangler

public class FNPPacketMangler
extends java.lang.Object
implements OutgoingPacketMangler

See Also:

IncomingPacketFilter, NewPacketFormat

Field Summary

Fields

Modifier and Type	Field and Description
static int	AMOUNT_OF_BYTES_ALLOWED_BEFORE_WE_REKEY The amount of data sent before we ask for a rekey
static int	DH_CONTEXT_BUFFER_SIZE
static int	DH_GENERATION_INTERVAL
static long	MAX_SESSION_KEY_REKEYING_DELAY The max amount of time we will accept to use the current tracker when it should have been replaced
static long	SESSION_KEY_REKEYING_INTERVAL The rekeying interval for the session key (keytrackers)
static long	TRANSIENT_KEY_REKEYING_MIN_INTERVAL

Constructor Summary

Constructors

Constructor and Description
FNPPacketMangler(Node node, NodeCrypto crypt, PacketSocketHandler sock)

Method Summary

Modifier and Type	Method and Description
boolean	allowConnection(PeerNode pn, FreenetInetAddress addr) Is there any reason not to allow this connection? E.g.
boolean	alwaysAllowLocalAddresses() Always allow local addresses?
byte[]	getCompressedNoderef() Get our compressed noderef
AddressTracker.Status	getConnectivityStatus() Port forwarding status.
Peer[]	getPrimaryIPAddress() Get our addresses, as peers.
SocketHandler	getSocketHandler() The SocketHandler we are connected to.
boolean	isDisconnected(PeerContext context) Is a peer disconnected?
IncomingPacketFilter.DECODED	process(byte[] buf, int offset, int length, Peer peer, PeerNode opn, long now) Decrypt and authenticate packet.
void	sendHandshake(PeerNode pn, boolean notRegistered) Send a handshake, if possible, to the node.
void	setPortForwardingBroken() If the lower level code detects the port forwarding is broken, it will call this method.
void	start() Start up the FNPPacketMangler.
int[]	supportedNegTypes(boolean forPublic) List of supported negotiation types in preference order (best last)

Methods inherited from class java.lang.Object

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

Field Detail

DH_GENERATION_INTERVAL

public static final int DH_GENERATION_INTERVAL

See Also:

Constant Field Values

DH_CONTEXT_BUFFER_SIZE

public static final int DH_CONTEXT_BUFFER_SIZE

See Also:

Constant Field Values

TRANSIENT_KEY_REKEYING_MIN_INTERVAL

public static final long TRANSIENT_KEY_REKEYING_MIN_INTERVAL

SESSION_KEY_REKEYING_INTERVAL

public static final long SESSION_KEY_REKEYING_INTERVAL

The rekeying interval for the session key (keytrackers)

MAX_SESSION_KEY_REKEYING_DELAY

public static final long MAX_SESSION_KEY_REKEYING_DELAY

The max amount of time we will accept to use the current tracker when it should have been replaced

AMOUNT_OF_BYTES_ALLOWED_BEFORE_WE_REKEY

public static final int AMOUNT_OF_BYTES_ALLOWED_BEFORE_WE_REKEY

The amount of data sent before we ask for a rekey

See Also:

Constant Field Values

Constructor Detail

FNPPacketMangler

public FNPPacketMangler(Node node,
                        NodeCrypto crypt,
                        PacketSocketHandler sock)

Method Detail

start

public void start()

Start up the FNPPacketMangler. By the time this is called, all objects will have been constructed, but not all will have been started yet.

process

public IncomingPacketFilter.DECODED process(byte[] buf,
                                            int offset,
                                            int length,
                                            Peer peer,
                                            PeerNode opn,
                                            long now)

Decrypt and authenticate packet. Then feed it to USM.checkFilters. Packets generated should have a PeerNode on them. Note that the buffer can be modified by this method.

sendHandshake

public void sendHandshake(PeerNode pn,
                          boolean notRegistered)

Description copied from interface: OutgoingPacketMangler

Send a handshake, if possible, to the node.

Specified by:

sendHandshake in interface OutgoingPacketMangler

isDisconnected

public boolean isDisconnected(PeerContext context)

Description copied from interface: OutgoingPacketMangler

Is a peer disconnected?

Specified by:

isDisconnected in interface OutgoingPacketMangler

supportedNegTypes

public int[] supportedNegTypes(boolean forPublic)

Description copied from interface: OutgoingPacketMangler

List of supported negotiation types in preference order (best last)

Specified by:

supportedNegTypes in interface OutgoingPacketMangler

getSocketHandler

public SocketHandler getSocketHandler()

Description copied from interface: OutgoingPacketMangler

The SocketHandler we are connected to.

Specified by:

getSocketHandler in interface OutgoingPacketMangler

getPrimaryIPAddress

public Peer[] getPrimaryIPAddress()

Description copied from interface: OutgoingPacketMangler

Get our addresses, as peers.

Specified by:

getPrimaryIPAddress in interface OutgoingPacketMangler

getCompressedNoderef

public byte[] getCompressedNoderef()

Description copied from interface: OutgoingPacketMangler

Get our compressed noderef

Specified by:

getCompressedNoderef in interface OutgoingPacketMangler

alwaysAllowLocalAddresses

public boolean alwaysAllowLocalAddresses()

Description copied from interface: OutgoingPacketMangler

Always allow local addresses?

Specified by:

alwaysAllowLocalAddresses in interface OutgoingPacketMangler

getConnectivityStatus

public AddressTracker.Status getConnectivityStatus()

Description copied from interface: OutgoingPacketMangler

Port forwarding status.

Specified by:

getConnectivityStatus in interface OutgoingPacketMangler

Returns:

A status code from AddressTracker. FIXME make this more generic when we need to.

allowConnection

public boolean allowConnection(PeerNode pn,
                               FreenetInetAddress addr)

Description copied from interface: OutgoingPacketMangler

Is there any reason not to allow this connection? E.g. limits on the number of nodes on a specific IP address?

Specified by:

allowConnection in interface OutgoingPacketMangler

setPortForwardingBroken

public void setPortForwardingBroken()

Description copied from interface: OutgoingPacketMangler

If the lower level code detects the port forwarding is broken, it will call this method.

Specified by:

setPortForwardingBroken in interface OutgoingPacketMangler