NTCPTransport (I2P Anonymous Network - Java Documentation

java.lang.Object
- net.i2p.router.transport.TransportImpl
- - net.i2p.router.transport.ntcp.NTCPTransport

すべての実装されたインタフェース:

Transport
```
public class NTCPTransport
extends TransportImpl
```
The NIO TCP transport

ネストされたクラスの概要
- インタフェースから継承されたネストされたクラス/インタフェース net.i2p.router.transport.Transport
  Transport.AddressSource

フィールドの概要

フィールド
修飾子とタイプ	フィールド	説明
`static int`	`DEFAULT_COST`
`static int`	`ESTABLISH_TIMEOUT`	how long from initial connection attempt (accept() or connect()) until the con must be established to avoid premature close()ing
`static java.lang.String`	`MIN_SIGTYPE_VERSION`	RI sigtypes supported in 0.9.16
`static java.lang.String`	`PROP_BIND_INTERFACE`	this is rarely if ever used, default is to bind to wildcard address
`static java.lang.String`	`PROP_I2NP_NTCP_AUTO_IP`
`static java.lang.String`	`PROP_I2NP_NTCP_AUTO_PORT`
`static java.lang.String`	`PROP_I2NP_NTCP_HOSTNAME`
`static java.lang.String`	`PROP_I2NP_NTCP_PORT`
`static java.lang.String`	`STYLE`

クラスから継承されたフィールド net.i2p.router.transport.TransportImpl
_context, _currentAddresses, ADJUST_COST, CONGESTION_COST_ADJUSTMENT

コンストラクタの概要

コンストラクタ
コンストラクタ説明

NTCPTransport(RouterContext ctx, DHSessionKeyBuilder.Factory dh)

コンストラクタ
コンストラクタ	説明
`NTCPTransport(RouterContext ctx, DHSessionKeyBuilder.Factory dh)`

メソッドの概要

すべてのメソッドインスタンス・メソッド concreteメソッド推奨されていないメソッド
修飾子とタイプ	メソッド	説明
`void`	`afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend)`	The transport is done sending this message.
`boolean`	`allowConnection()`
`TransportBid`	`bid(RouterInfo toAddress, long dataSize)`
`int`	`countActivePeers()`	How many peers have we talked to in the last 5 minutes? As of 0.9.20, actually returns active peer count, not total.
`int`	`countActiveSendPeers()`	How many peers are we actively sending messages to (this minute)
`int`	`countPeers()`	How many peers are we connected to?
`(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
`void`	`externalAddressReceived(Transport.AddressSource source, byte[] ip, int port)`	UDP changed addresses, tell NTCP and (possibly) restart
`void`	`externalAddressRemoved(Transport.AddressSource source, boolean ipv6)`	Notify a transport of an external address change.
`void`	`forwardPortStatus(byte[] ip, int port, int externalPort, boolean success, java.lang.String reason)`	If we didn't used to be forwarded, and we have an address, and we are configured to use UPnP, update our RouterAddress Don't do anything now.
`java.util.Vector<java.lang.Long>`	`getClockSkews()`	Return our peer clock skews on this transport.
`(package private) DHSessionKeyBuilder`	`getDHBuilder()`
`java.util.Set<Hash>`	`getEstablished()`	Connected peers.
`java.util.Collection<NTCPConnection>`	`getPeers()`	For /peers UI only.
`(package private) EventPumper`	`getPumper()`	Hook for NTCPConnection
`CommSystemFacade.Status`	`getReachabilityStatus()`	Maybe we should trust UPnP here and report OK if it opened the port, but for now we don't.
`(package private) Reader`	`getReader()`	Hook for NTCPConnection
`int`	`getRequestedPort()`	What INTERNAL port would the transport like to have forwarded by UPnP.
`java.lang.String`	`getStyle()`	The unique identity of this Transport
`(package private) Writer`	`getWriter()`	Hook for NTCPConnection
`(package private) NTCPConnection`	`inboundEstablished(NTCPConnection con)`
`boolean`	`isAlive()`
`boolean`	`isBacklogged(Hash dest)`
`boolean`	`isEstablished(Hash dest)`
`(package private) boolean`	`isHXHIValid(byte[] hxhi)`	Incoming connection replay detection.
`void`	`mayDisconnect(Hash peer)`	Tell the transport that we may disconnect from this peer.
`protected void`	`outboundMessageReady()`	This message is called whenever a new message is added to the send pool, and it should not block Only used by NTCP.
`(package private) NTCPConnection`	`removeCon(NTCPConnection con)`
`void`	`renderStatusHTML(java.io.Writer out, int sortFlags)`
`void`	`renderStatusHTML(java.io.Writer out, java.lang.String urlBase, int sortFlags)`	推奨されていません。 as of 0.9.31
`(package private) void`	`returnUnused(DHSessionKeyBuilder builder)`	Return an unused DH key builder to be put back onto the queue for reuse.
`(package private) void`	`sendComplete(OutNetMessage msg)`	queue up afterSend call, which can take some time w/ jobs, etc
`(package private) void`	`setLastBadSkew(long skew)`	A positive number means our clock is ahead of theirs.
`void`	`startListening()`	Called by TransportManager.
`void`	`stopListening()`	This doesn't (completely) block, caller should check isAlive() before calling startListening() or restartListening()

クラスから継承されたメソッド java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

クラスから継承されたメソッド net.i2p.router.transport.TransportImpl
_t, _t, afterSend, afterSend, afterSend, allowLocal, getCurrentAddress, getCurrentAddresses, getIP, getIPv6Config, getMaxConnections, getMostRecentErrorMessages, getNextMessage, getSavedLocalAddresses, getTargetAddresses, hasCurrentAddress, haveCapacity, haveCapacity, isIPv4Firewalled, isIPv6Firewalled, isPubliclyRoutable, isUnreachable, markReachable, markUnreachable, messageReceived, ngettext, recheckReachability, removeAddress, removeAddress, renderStatusHTML, replaceAddress, saveLocalAddress, send, setIP, setListener, updateAddress, wasUnreachable

- フィールドの詳細
  - PROP_I2NP_NTCP_HOSTNAME
```
public static final java.lang.String PROP_I2NP_NTCP_HOSTNAME
```
    関連項目:
    
    定数フィールド値
  - PROP_I2NP_NTCP_PORT
```
public static final java.lang.String PROP_I2NP_NTCP_PORT
```
    関連項目:
    
    定数フィールド値
  - PROP_I2NP_NTCP_AUTO_PORT
```
public static final java.lang.String PROP_I2NP_NTCP_AUTO_PORT
```
    関連項目:
    
    定数フィールド値
  - PROP_I2NP_NTCP_AUTO_IP
```
public static final java.lang.String PROP_I2NP_NTCP_AUTO_IP
```
    関連項目:
    
    定数フィールド値
  - DEFAULT_COST
```
public static final int DEFAULT_COST
```
    関連項目:
    
    定数フィールド値
  - PROP_BIND_INTERFACE
```
public static final java.lang.String PROP_BIND_INTERFACE
```
    this is rarely if ever used, default is to bind to wildcard address
    
    関連項目:
    
    定数フィールド値
  - MIN_SIGTYPE_VERSION
```
public static final java.lang.String MIN_SIGTYPE_VERSION
```
    RI sigtypes supported in 0.9.16
    
    関連項目:
    
    定数フィールド値
  - ESTABLISH_TIMEOUT
```
public static final int ESTABLISH_TIMEOUT
```
    how long from initial connection attempt (accept() or connect()) until the con must be established to avoid premature close()ing
    
    関連項目:
    
    定数フィールド値
  - STYLE
```
public static final java.lang.String STYLE
```
    関連項目:
    
    定数フィールド値
- コンストラクタの詳細
  - NTCPTransport
```
public NTCPTransport(RouterContext ctx,
                     DHSessionKeyBuilder.Factory dh)
```
- メソッドの詳細
  - inboundEstablished
```
NTCPConnection inboundEstablished(NTCPConnection con)
```
    パラメータ:
    
    con - that is established
    
    戻り値:
    
    the previous connection to the same peer, must be closed by caller, null if no such.
  - outboundMessageReady
```
protected void outboundMessageReady()
```
    クラスからコピーされた説明: TransportImpl
    
    This message is called whenever a new message is added to the send pool, and it should not block Only used by NTCP. SSU throws UOE.
    
    定義:
    
    outboundMessageReady クラス内 TransportImpl
  - afterSend
```
public void afterSend(OutNetMessage msg,
                      boolean sendSuccessful,
                      boolean allowRequeue,
                      long msToSend)
```
    クラスからコピーされた説明: TransportImpl
    
    The transport is done sending this message. This is the method that actually does all of the cleanup - firing off jobs, requeueing, updating stats, etc.
    
    オーバーライド:
    
    afterSend クラス内 TransportImpl
    
    パラメータ:
    
    msg - message in question
    
    sendSuccessful - true if the peer received it
    
    allowRequeue - true if we should try other transports if available
    
    msToSend - how long it took to transfer the data to the peer
  - bid
```
public TransportBid bid(RouterInfo toAddress,
                        long dataSize)
```
  - allowConnection
```
public boolean allowConnection()
```
  - sendComplete
```
void sendComplete(OutNetMessage msg)
```
    queue up afterSend call, which can take some time w/ jobs, etc
  - isEstablished
```
public boolean isEstablished(Hash dest)
```
    定義:
    
    isEstablished インタフェース内 Transport
    
    オーバーライド:
    
    isEstablished クラス内 TransportImpl
  - isBacklogged
```
public boolean isBacklogged(Hash dest)
```
    定義:
    
    isBacklogged インタフェース内 Transport
    
    オーバーライド:
    
    isBacklogged クラス内 TransportImpl
  - mayDisconnect
```
public void mayDisconnect(Hash peer)
```
    Tell the transport that we may disconnect from this peer. This is advisory only.
    
    定義:
    
    mayDisconnect インタフェース内 Transport
    
    オーバーライド:
    
    mayDisconnect クラス内 TransportImpl
    
    導入されたバージョン:
    
    0.9.24
  - removeCon
```
NTCPConnection removeCon(NTCPConnection con)
```
    戻り値:
    
    usually the con passed in, but possibly a second connection with the same peer...
  - countPeers
```
public int countPeers()
```
    クラスからコピーされた説明: TransportImpl
    
    How many peers are we connected to?
    
    定義:
    
    countPeers インタフェース内 Transport
    
    定義:
    
    countPeers クラス内 TransportImpl
  - getPeers
```
public java.util.Collection<NTCPConnection> getPeers()
```
    For /peers UI only. Not a public API, not for external use.
    
    戻り値:
    
    not a copy, do not modify
    
    導入されたバージョン:
    
    0.9.31
  - getEstablished
```
public java.util.Set<Hash> getEstablished()
```
    Connected peers.
    
    戻り値:
    
    a copy, modifiable
    
    導入されたバージョン:
    
    0.9.34
  - countActivePeers
```
public int countActivePeers()
```
    How many peers have we talked to in the last 5 minutes? As of 0.9.20, actually returns active peer count, not total.
    
    定義:
    
    countActivePeers インタフェース内 Transport
    
    定義:
    
    countActivePeers クラス内 TransportImpl
  - countActiveSendPeers
```
public int countActiveSendPeers()
```
    How many peers are we actively sending messages to (this minute)
    
    定義:
    
    countActiveSendPeers インタフェース内 Transport
    
    定義:
    
    countActiveSendPeers クラス内 TransportImpl
  - setLastBadSkew
```
void setLastBadSkew(long skew)
```
    A positive number means our clock is ahead of theirs.
    
    パラメータ:
    
    skew - in seconds
  - getClockSkews
```
public java.util.Vector<java.lang.Long> getClockSkews()
```
    Return our peer clock skews on this transport. Vector composed of Long, each element representing a peer skew in seconds. A positive number means our clock is ahead of theirs.
    
    定義:
    
    getClockSkews インタフェース内 Transport
    
    オーバーライド:
    
    getClockSkews クラス内 TransportImpl
  - isHXHIValid
```
boolean isHXHIValid(byte[] hxhi)
```
    Incoming connection replay detection. As there is no timestamp in the first message, we can't detect something long-delayed. To be fixed in next version of NTCP.
    
    パラメータ:
    
    hxhi - 32 bytes
    
    戻り値:
    
    valid
    
    導入されたバージョン:
    
    0.9.12
  - startListening
```
public void startListening()
```
    Called by TransportManager. Caller should stop the transport first, then verify stopped with isAlive() Unfortunately TransportManager doesn't do that, so we check here to prevent two pumpers.
  - isAlive
```
public boolean isAlive()
```
  - getReader
```
Reader getReader()
```
    Hook for NTCPConnection
  - getWriter
```
Writer getWriter()
```
    Hook for NTCPConnection
  - getStyle
```
public java.lang.String getStyle()
```
    インタフェースからコピーされた説明: Transport
    
    The unique identity of this Transport
  - getPumper
```
EventPumper getPumper()
```
    Hook for NTCPConnection
  - getDHBuilder
```
DHSessionKeyBuilder getDHBuilder()
```
    導入されたバージョン:
    
    0.9
  - returnUnused
```
void returnUnused(DHSessionKeyBuilder builder)
```
    Return an unused DH key builder to be put back onto the queue for reuse.
    
    パラメータ:
    
    builder - must not have a peerPublicValue set
    
    導入されたバージョン:
    
    0.9.16
  - establishing
```
void establishing(NTCPConnection con)
```
    add us to the establishment timeout process
  - expireTimedOut
```
void expireTimedOut()
```
    called in the EventPumper no more than once a second or so, closing any unconnected/unestablished connections
  - externalAddressReceived
```
public void externalAddressReceived(Transport.AddressSource source,
                                    byte[] ip,
                                    int port)
```
    UDP changed addresses, tell NTCP and (possibly) restart
    
    定義:
    
    externalAddressReceived インタフェース内 Transport
    
    定義:
    
    externalAddressReceived クラス内 TransportImpl
    
    パラメータ:
    
    ip - typ. IPv4 or IPv6 non-local; may be null to indicate IPv4 failure or port info only
    
    source - defined in Transport.java
    
    port - 0 for unknown or unchanged
    
    導入されたバージョン:
    
    IPv6 moved from CSFI.notifyReplaceAddress()
  - externalAddressRemoved
```
public void externalAddressRemoved(Transport.AddressSource source,
                                   boolean ipv6)
```
    Notify a transport of an external address change. This may be from a local interface, UPnP, a config change, etc. This should not be called if the ip didn't change (from that source's point of view), or is a local address. May be called multiple times for IPv4 or IPv6. The transport should also do its own checking on whether to accept notifications from this source. This can be called after the transport is running. TODO externalAddressRemoved(source, ip, port)
    
    定義:
    
    externalAddressRemoved インタフェース内 Transport
    
    オーバーライド:
    
    externalAddressRemoved クラス内 TransportImpl
    
    パラメータ:
    
    source - defined in Transport.java
    
    導入されたバージョン:
    
    0.9.20
  - forwardPortStatus
```
public void forwardPortStatus(byte[] ip,
                              int port,
                              int externalPort,
                              boolean success,
                              java.lang.String reason)
```
    If we didn't used to be forwarded, and we have an address, and we are configured to use UPnP, update our RouterAddress Don't do anything now. If it fails, we don't know if it's because there is no firewall, or if the firewall rejected the request. So we just use the SSU reachability status to decide whether to enable inbound NTCP. SSU will have CSFI build a new NTCP address when it transitions to OK.
    
    定義:
    
    forwardPortStatus インタフェース内 Transport
    
    オーバーライド:
    
    forwardPortStatus クラス内 TransportImpl
    
    パラメータ:
    
    ip - may be null
    
    port - the internal port
    
    externalPort - the external port, which for now should always be the same as the internal port if the forwarding was successful.
  - getRequestedPort
```
public int getRequestedPort()
```
    クラスからコピーされた説明: TransportImpl
    
    What INTERNAL port would the transport like to have forwarded by UPnP. This can't be passed via getCurrentAddress(), as we have to open the port before we can publish the address, and that's the external port anyway.
    
    定義:
    
    getRequestedPort インタフェース内 Transport
    
    オーバーライド:
    
    getRequestedPort クラス内 TransportImpl
    
    戻り値:
    
    current IPv4 port, else NTCP configured port, else -1 (but not UDP port if auto)
  - getReachabilityStatus
```
public CommSystemFacade.Status getReachabilityStatus()
```
    Maybe we should trust UPnP here and report OK if it opened the port, but for now we don't. Just go through and if we have one inbound connection, we must be good. As we drop idle connections pretty quickly, this will be fairly accurate. We have to be careful here because much of the router console code assumes that the reachability status is really just the UDP status. This only returns OK, DISABLED, or UNKNOWN for IPv4 and IPv6. We leave the FIREWALLED status for UDP. Previously returned short, now enum as of 0.9.20
    
    定義:
    
    getReachabilityStatus インタフェース内 Transport
    
    定義:
    
    getReachabilityStatus クラス内 TransportImpl
  - stopListening
```
public void stopListening()
```
    This doesn't (completely) block, caller should check isAlive() before calling startListening() or restartListening()
  - renderStatusHTML
```
public void renderStatusHTML(java.io.Writer out,
                             int sortFlags)
                      throws java.io.IOException
```
    例外:
    
    java.io.IOException
  - renderStatusHTML
```
@Deprecated
public void renderStatusHTML(java.io.Writer out,
                             java.lang.String urlBase,
                             int sortFlags)
                      throws java.io.IOException
```
    推奨されていません。 as of 0.9.31
    
    Does nothing
    
    定義:
    
    renderStatusHTML インタフェース内 Transport
    
    オーバーライド:
    
    renderStatusHTML クラス内 TransportImpl
    
    例外:
    
    java.io.IOException

クラス NTCPTransport

ネストされたクラスの概要

インタフェースから継承されたネストされたクラス/インタフェース net.i2p.router.transport.Transport

フィールドの概要

クラスから継承されたフィールド net.i2p.router.transport.TransportImpl

コンストラクタの概要

メソッドの概要

クラスから継承されたメソッド java.lang.Object

クラスから継承されたメソッド net.i2p.router.transport.TransportImpl

フィールドの詳細

PROP_I2NP_NTCP_HOSTNAME

PROP_I2NP_NTCP_PORT

PROP_I2NP_NTCP_AUTO_PORT

PROP_I2NP_NTCP_AUTO_IP

DEFAULT_COST

PROP_BIND_INTERFACE

MIN_SIGTYPE_VERSION

ESTABLISH_TIMEOUT

STYLE

コンストラクタの詳細

NTCPTransport

メソッドの詳細

inboundEstablished

outboundMessageReady

afterSend

bid

allowConnection

sendComplete

isEstablished

isBacklogged

mayDisconnect

removeCon

countPeers

getPeers

getEstablished

countActivePeers

countActiveSendPeers

setLastBadSkew

getClockSkews

isHXHIValid

startListening

isAlive

getReader

getWriter

getStyle

getPumper

getDHBuilder

returnUnused

establishing

expireTimedOut

externalAddressReceived

externalAddressRemoved

forwardPortStatus

getRequestedPort

getReachabilityStatus

stopListening

renderStatusHTML

renderStatusHTML