|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.transport.TransportImpl
net.i2p.router.transport.udp.UDPTransport
Field Summary | |
static java.lang.String |
PROP_EXTERNAL_HOST
define this to explicitly set an external IP address |
static java.lang.String |
PROP_EXTERNAL_PORT
define this to explicitly set an external port |
static java.lang.String |
PROP_INTERNAL_PORT
|
static int |
PUBLIC_RELAY_COUNT
how many relays offered to us will we use at a time? |
static java.lang.String |
STYLE
|
Constructor Summary | |
UDPTransport(RouterContext ctx)
|
Method Summary | |
(package private) void |
addRelayPeer(java.lang.String host,
int port,
byte[] tag,
SessionKey relayIntroKey)
|
(package private) boolean |
addRemotePeerState(PeerState peer)
add the peer info, returning true if it went in properly, false if it was rejected (causes include peer ident already connected, or no remote host info known |
TransportBid |
bid(RouterInfo toAddress,
long dataSize)
|
int |
countActivePeers()
How many peers can we talk to right now? |
(package private) void |
externalAddressReceived(byte[] ourIP,
int ourPort)
Someone we tried to contact gave us what they think our IP address is. |
void |
failed(OutNetMessage msg)
|
int |
getExternalPort()
|
SessionKey |
getIntroKey()
Introduction key that people should use to contact us |
java.net.InetAddress |
getLocalAddress()
|
int |
getLocalPort()
|
OutNetMessage |
getNextMessage()
Nonblocking call to pull the next outbound message off the queue. |
OutNetMessage |
getNextMessage(long blockUntil)
Get the next message, blocking until one is found or the expiration reached. |
PeerState |
getPeerState(Hash remotePeer)
get the state for the peer with the given ident, or null if no state exists |
PeerState |
getPeerState(java.net.InetAddress remoteHost,
int remotePort)
get the state for the peer at the given remote host/port, or null if no state exists |
PeerState |
getPeerState(java.lang.String relayTag)
get the state for the peer being introduced, or null if we aren't offering to introduce anyone with that tag. |
java.lang.String |
getStyle()
|
protected void |
outboundMessageReady()
This message is called whenever a new message is added to the send pool, and it should not block |
(package private) void |
rebuildExternalAddress()
|
void |
renderStatusHTML(java.io.Writer out)
Make this stuff pretty (only used in the old console) |
(package private) void |
send(I2NPMessage msg,
PeerState peer)
|
void |
send(OutNetMessage msg)
Asynchronously send the message as requested in the message and, if the send is successful, queue up any msg.getOnSendJob job, and register it with the OutboundMessageRegistry (if it has a reply selector). |
(package private) int |
send(UDPPacket packet)
|
(package private) void |
setExternalListenHost(byte[] addr)
|
(package private) void |
setExternalListenHost(java.net.InetAddress addr)
|
(package private) void |
setExternalListenPort(int port)
|
void |
shutdown()
|
RouterAddress |
startListening()
|
void |
startup()
|
void |
stopListening()
|
void |
succeeded(OutNetMessage msg)
|
Methods inherited from class net.i2p.router.transport.TransportImpl |
afterSend, afterSend, afterSend, afterSend, getContext, getCurrentAddresses, getMostRecentErrorMessages, messageReceived, replaceAddress, setListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final java.lang.String STYLE
public static final java.lang.String PROP_INTERNAL_PORT
public static final java.lang.String PROP_EXTERNAL_HOST
public static final java.lang.String PROP_EXTERNAL_PORT
public static final int PUBLIC_RELAY_COUNT
Constructor Detail |
public UDPTransport(RouterContext ctx)
Method Detail |
public void startup()
public void shutdown()
public SessionKey getIntroKey()
public int getLocalPort()
public java.net.InetAddress getLocalAddress()
public int getExternalPort()
void externalAddressReceived(byte[] ourIP, int ourPort)
public PeerState getPeerState(java.net.InetAddress remoteHost, int remotePort)
public PeerState getPeerState(Hash remotePeer)
public PeerState getPeerState(java.lang.String relayTag)
boolean addRemotePeerState(PeerState peer)
int send(UDPPacket packet)
public TransportBid bid(RouterInfo toAddress, long dataSize)
bid
in interface Transport
public java.lang.String getStyle()
getStyle
in interface Transport
public void send(OutNetMessage msg)
TransportImpl
send
in interface Transport
send
in class TransportImpl
void send(I2NPMessage msg, PeerState peer)
public OutNetMessage getNextMessage()
TransportImpl
getNextMessage
in class TransportImpl
public OutNetMessage getNextMessage(long blockUntil)
blockUntil
- expiration, or -1 if indefiniteprotected void outboundMessageReady()
TransportImpl
outboundMessageReady
in class TransportImpl
public RouterAddress startListening()
startListening
in interface Transport
public void stopListening()
stopListening
in interface Transport
void setExternalListenPort(int port)
void setExternalListenHost(java.net.InetAddress addr)
void setExternalListenHost(byte[] addr) throws java.net.UnknownHostException
java.net.UnknownHostException
void addRelayPeer(java.lang.String host, int port, byte[] tag, SessionKey relayIntroKey)
void rebuildExternalAddress()
public void failed(OutNetMessage msg)
failed
in interface TimedWeightedPriorityMessageQueue.FailedListener
public void succeeded(OutNetMessage msg)
public int countActivePeers()
TransportImpl
countActivePeers
in interface Transport
countActivePeers
in class TransportImpl
public void renderStatusHTML(java.io.Writer out) throws java.io.IOException
TransportImpl
renderStatusHTML
in interface Transport
renderStatusHTML
in class TransportImpl
java.io.IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |