|
||||||||||
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.ntcp.NTCPTransport
public class NTCPTransport
Field Summary | |
---|---|
static java.lang.String |
STYLE
|
Fields inherited from class net.i2p.router.transport.TransportImpl |
---|
_context |
Constructor Summary | |
---|---|
NTCPTransport(RouterContext ctx)
|
Method Summary | |
---|---|
void |
afterSend(OutNetMessage msg,
boolean sendSuccessful,
boolean allowRequeue,
long msToSend)
The transport is done sending this message. |
TransportBid |
bid(RouterInfo toAddress,
long dataSize)
|
int |
countActivePeers()
How many peers can we talk to right now? |
int |
countActiveSendPeers()
How many peers are we actively sending messages to (this minute) |
(package private) void |
establishing(NTCPConnection con)
add us to the establishment timeout process |
(package private) void |
expireTimedOut()
called in the EventPumper no more than once a second or so, closing any unconnected/unestablished connections |
java.util.Vector |
getClockSkews()
Return our peer clock skews on this transport. |
(package private) EventPumper |
getPumper()
|
(package private) Reader |
getReader()
|
java.lang.String |
getStyle()
|
(package private) Writer |
getWriter()
|
(package private) void |
inboundEstablished(NTCPConnection con)
|
boolean |
isBacklogged(Hash dest)
|
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 |
removeCon(NTCPConnection con)
|
void |
renderStatusHTML(java.io.Writer out,
int sortFlags)
|
void |
renderStatusHTML(java.io.Writer out,
java.lang.String urlBase,
int sortFlags)
|
RouterAddress |
restartListening(RouterAddress addr)
|
(package private) void |
sendComplete(OutNetMessage msg)
|
RouterAddress |
startListening()
|
void |
stopListening()
|
Methods inherited from class net.i2p.router.transport.TransportImpl |
---|
afterSend, afterSend, afterSend, getContext, getCurrentAddress, getMostRecentErrorMessages, getNextMessage, getReachabilityStatus, isPubliclyRoutable, isUnreachable, markReachable, markUnreachable, messageReceived, recheckReachability, renderStatusHTML, replaceAddress, send, 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
Constructor Detail |
---|
public NTCPTransport(RouterContext ctx)
Method Detail |
---|
void inboundEstablished(NTCPConnection con)
protected void outboundMessageReady()
TransportImpl
outboundMessageReady
in class TransportImpl
public void afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend)
TransportImpl
afterSend
in class TransportImpl
msg
- message in questionsendSuccessful
- true if the peer received itallowRequeue
- true if we should try other transports if availablemsToSend
- how long it took to transfer the data to the peerpublic TransportBid bid(RouterInfo toAddress, long dataSize)
void sendComplete(OutNetMessage msg)
public boolean isBacklogged(Hash dest)
isBacklogged
in interface Transport
isBacklogged
in class TransportImpl
void removeCon(NTCPConnection con)
public int countActivePeers()
countActivePeers
in interface Transport
countActivePeers
in class TransportImpl
public int countActiveSendPeers()
countActiveSendPeers
in interface Transport
countActiveSendPeers
in class TransportImpl
public java.util.Vector getClockSkews()
getClockSkews
in interface Transport
getClockSkews
in class TransportImpl
public RouterAddress startListening()
public RouterAddress restartListening(RouterAddress addr)
Reader getReader()
Writer getWriter()
public java.lang.String getStyle()
EventPumper getPumper()
void establishing(NTCPConnection con)
void expireTimedOut()
public void stopListening()
public void renderStatusHTML(java.io.Writer out, int sortFlags) throws java.io.IOException
java.io.IOException
public void renderStatusHTML(java.io.Writer out, java.lang.String urlBase, int sortFlags) throws java.io.IOException
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 |