Package net.i2p.i2ptunnel.udp

Class UDPSource

java.lang.Object

net.i2p.i2ptunnel.udp.UDPSource

All Implemented Interfaces:

Runnable, Source

public class UDPSource
extends Object
implements Source, Runnable

Author:

welterde

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_SIZE
protected Sink	sink
protected final DatagramSocket	sock
protected final Thread	thread

Constructor Summary

Constructors

Constructor	Description
UDPSource(int port)
UDPSource(DatagramSocket sock)	use socket from UDPSink

Method Summary

Modifier and Type	Method	Description
int	getPort()
void	run()
void	setSink(Sink sink)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

sock

protected final DatagramSocket sock

sink

protected Sink sink

thread

protected final Thread thread

MAX_SIZE

public static final int MAX_SIZE

See Also:

• Constant Field Values

Constructor Details

UDPSource

public UDPSource(int port)

Throws:

RuntimeException - on DatagramSocket IOException

UDPSource

public UDPSource(DatagramSocket sock)

use socket from UDPSink

Method Details

setSink

public void setSink(Sink sink)

Specified by:

setSink in interface Source

start

public void start()

Specified by:

start in interface Source

run

public void run()

Specified by:

run in interface Runnable

getPort

public int getPort()

Returns:

the local port of the DatagramSocket we are receiving on

Since:

0.9.53

stop

public void stop()