TransportImpl (I2P Anonymous Network - Java Documentation

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

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

Transport

直系の既知のサブクラス:

NTCPTransport, UDPTransport
```
public abstract class TransportImpl
extends java.lang.Object
implements Transport
```
Defines a way to send a message to another peer and start listening for messages

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

フィールドの概要

フィールド
修飾子とタイプ	フィールド	説明
`protected RouterContext`	`_context`
`protected java.util.List<RouterAddress>`	`_currentAddresses`
`protected static boolean`	`ADJUST_COST`	Do we increase the advertised cost when approaching conn limits?
`protected static int`	`CONGESTION_COST_ADJUSTMENT`	TODO change to 2

コンストラクタの概要

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

TransportImpl(RouterContext context)
Initialize the new transport

コンストラクタ
コンストラクタ	説明
`TransportImpl(RouterContext context)`	Initialize the new transport

メソッドの概要

すべてのメソッド staticメソッドインスタンス・メソッド abstractメソッド concreteメソッド推奨されていないメソッド
修飾子とタイプ	メソッド	説明
`protected java.lang.String`	`_t(java.lang.String s)`	Translate
`protected java.lang.String`	`_t(java.lang.String s, java.lang.Object o)`	Translate
`protected void`	`afterSend(OutNetMessage msg, boolean sendSuccessful)`	The transport is done sending this message
`protected void`	`afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue)`	The transport is done sending this message
`protected void`	`afterSend(OutNetMessage msg, boolean sendSuccessful, boolean allowRequeue, long msToSend)`	The transport is done sending this message.
`protected void`	`afterSend(OutNetMessage msg, boolean sendSuccessful, long msToSend)`	The transport is done sending this message
`boolean`	`allowLocal()`	Are we allowed to connect to local addresses?
`(package private) static void`	`clearCaches()`
`abstract int`	`countActivePeers()`	How many peers are we currently connected to, that we have sent a message to or received a message from in the last five minutes.
`abstract int`	`countActiveSendPeers()`	How many peers are we currently connected to, that we have sent a message to in the last minute.
`abstract int`	`countPeers()`	How many peers are we connected to?
`abstract void`	`externalAddressReceived(Transport.AddressSource source, byte[] ip, int port)`	Notify a transport of an external address change.
`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)`	Notify a transport of the results of trying to forward a port.
`java.util.Vector<java.lang.Long>`	`getClockSkews()`	Return our peer clock skews on a transport.
`RouterAddress`	`getCurrentAddress(boolean ipv6)`	What address are we currently listening to? Replaces getCurrentAddress()
`java.util.List<RouterAddress>`	`getCurrentAddresses()`	What addresses are we currently listening to? Replaces getCurrentAddress()
`static byte[]`	`getIP(Hash peer)`	IP of the peer from the last connection (in or out, any transport).
`TransportUtil.IPv6Config`	`getIPv6Config()`
`int`	`getMaxConnections()`	Per-transport connection limit
`java.util.List<java.lang.String>`	`getMostRecentErrorMessages()`
`protected OutNetMessage`	`getNextMessage()`	Nonblocking call to pull the next outbound message off the queue.
`abstract CommSystemFacade.Status`	`getReachabilityStatus()`	Previously returned short, now enum as of 0.9.20
`int`	`getRequestedPort()`	What INTERNAL port would the transport like to have forwarded by UPnP.
`protected java.util.Collection<java.net.InetAddress>`	`getSavedLocalAddresses()`	Return and then clear all saved local addresses.
`protected java.util.List<RouterAddress>`	`getTargetAddresses(RouterInfo target)`	Get all available address we can use, shuffled and then sorted by cost/preference.
`boolean`	`hasCurrentAddress()`	Do we have any current address?
`boolean`	`haveCapacity()`	Can we initiate or accept a connection to another peer, saving some margin
`boolean`	`haveCapacity(int pct)`
`boolean`	`isBacklogged(Hash peer)`
`boolean`	`isEstablished(Hash peer)`
`boolean`	`isIPv4Firewalled()`	This returns true if the force-firewalled setting is configured, false otherwise.
`boolean`	`isIPv6Firewalled()`	This returns true if the force-firewalled setting is configured, false otherwise.
`protected boolean`	`isPubliclyRoutable(byte[] addr)`	Allows IPv6 only if the transport is configured for it.
`boolean`	`isUnreachable(Hash peer)`
`void`	`markReachable(Hash peer, boolean isInbound)`	called when we establish a peer connection (outbound or inbound)
`void`	`markUnreachable(Hash peer)`	called when we can't reach a peer
`void`	`mayDisconnect(Hash peer)`	Tell the transport that we may disconnect from this peer.
`void`	`messageReceived(I2NPMessage inMsg, RouterIdentity remoteIdent, Hash remoteIdentHash, long msToReceive, int bytesReceived)`	Message received from the I2NPMessageReader - send it to the listener
`protected java.lang.String`	`ngettext(java.lang.String s, java.lang.String p, int n)`	Translate
`protected abstract 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.
`void`	`recheckReachability()`	推奨されていません。 unused
`protected void`	`removeAddress(boolean ipv6)`	Remove all existing addresses with the specified IP length (4 or 16).
`protected void`	`removeAddress(RouterAddress address)`	Remove only this address.
`void`	`renderStatusHTML(java.io.Writer out)`	Make this stuff pretty (only used in the old console)
`void`	`renderStatusHTML(java.io.Writer out, java.lang.String urlBase, int sortFlags)`
`protected void`	`replaceAddress(RouterAddress address)`	Replace any existing addresses for the current transport with the same IP length (4 or 16) with the given one.
`protected void`	`saveLocalAddress(java.net.InetAddress address)`	Save a local address we were notified about before we started.
`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).
`void`	`setIP(Hash peer, byte[] ip)`	IP of the peer from the last connection (in or out, any transport).
`void`	`setListener(TransportEventListener listener)`	Who to notify on message availability
`java.util.List<RouterAddress>`	`updateAddress()`	Ask the transport to update its address based on current information and return it Transports should override.
`boolean`	`wasUnreachable(Hash peer)`	Was the peer UNreachable (outbound only) the last time we tried it? This is NOT reset if the peer contacts us.

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

インタフェースから継承されたメソッド net.i2p.router.transport.Transport
bid, getEstablished, getStyle, startListening, stopListening

- フィールドの詳細
  - _currentAddresses
```
protected final java.util.List<RouterAddress> _currentAddresses
```
  - _context
```
protected final RouterContext _context
```
  - ADJUST_COST
```
protected static final boolean ADJUST_COST
```
    Do we increase the advertised cost when approaching conn limits?
    
    関連項目:
    
    定数フィールド値
  - CONGESTION_COST_ADJUSTMENT
```
protected static final int CONGESTION_COST_ADJUSTMENT
```
    TODO change to 2
    
    関連項目:
    
    定数フィールド値
- コンストラクタの詳細
  - TransportImpl
```
public TransportImpl(RouterContext context)
```
    Initialize the new transport
- メソッドの詳細
  - countPeers
```
public abstract int countPeers()
```
    How many peers are we connected to?
    
    定義:
    
    countPeers インタフェース内 Transport
  - countActivePeers
```
public abstract int countActivePeers()
```
    How many peers are we currently connected to, that we have sent a message to or received a message from in the last five minutes.
    
    定義:
    
    countActivePeers インタフェース内 Transport
  - countActiveSendPeers
```
public abstract int countActiveSendPeers()
```
    How many peers are we currently connected to, that we have sent a message to in the last minute. Unused for anything, to be removed.
    
    定義:
    
    countActiveSendPeers インタフェース内 Transport
  - getMaxConnections
```
public int getMaxConnections()
```
    Per-transport connection limit
  - haveCapacity
```
public boolean haveCapacity()
```
    Can we initiate or accept a connection to another peer, saving some margin
    
    定義:
    
    haveCapacity インタフェース内 Transport
  - haveCapacity
```
public boolean haveCapacity(int pct)
```
    定義:
    
    haveCapacity インタフェース内 Transport
    
    パラメータ:
    
    pct - are we under x% 0-100
  - getClockSkews
```
public java.util.Vector<java.lang.Long> getClockSkews()
```
    Return our peer clock skews on a transport. Vector composed of Long, each element representing a peer skew in seconds. Dummy version. Transports override it.
    
    定義:
    
    getClockSkews インタフェース内 Transport
  - getMostRecentErrorMessages
```
public java.util.List<java.lang.String> getMostRecentErrorMessages()
```
    定義:
    
    getMostRecentErrorMessages インタフェース内 Transport
  - getNextMessage
```
protected OutNetMessage getNextMessage()
```
    Nonblocking call to pull the next outbound message off the queue. Only used by NTCP. SSU does not call.
    
    戻り値:
    
    the next message or null if none are available
  - afterSend
```
protected void afterSend(OutNetMessage msg,
                         boolean sendSuccessful)
```
    The transport is done sending this message
    
    パラメータ:
    
    msg - message in question
    
    sendSuccessful - true if the peer received it
  - afterSend
```
protected void afterSend(OutNetMessage msg,
                         boolean sendSuccessful,
                         boolean allowRequeue)
```
    The transport is done sending this message
    
    パラメータ:
    
    msg - message in question
    
    sendSuccessful - true if the peer received it
    
    allowRequeue - true if we should try other transports if available
  - afterSend
```
protected void afterSend(OutNetMessage msg,
                         boolean sendSuccessful,
                         long msToSend)
```
    The transport is done sending this message
    
    パラメータ:
    
    msg - message in question
    
    sendSuccessful - true if the peer received it
    
    msToSend - how long it took to transfer the data to the peer
  - afterSend
```
protected void afterSend(OutNetMessage msg,
                         boolean sendSuccessful,
                         boolean allowRequeue,
                         long msToSend)
```
    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.
    
    パラメータ:
    
    msg - message in question
    
    sendSuccessful - true if the peer received it
    
    msToSend - how long it took to transfer the data to the peer
    
    allowRequeue - true if we should try other transports if available
  - send
```
public 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). If the send fails, queue up any msg.getOnFailedSendJob Only used by NTCP. SSU overrides. Note that this adds to the queue and then takes it back off in the same thread, so it actually blocks, and we don't need a big queue. TODO: Override in NTCP also and get rid of queue?
    
    定義:
    
    send インタフェース内 Transport
  - outboundMessageReady
```
protected abstract 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. SSU throws UOE.
  - messageReceived
```
public void messageReceived(I2NPMessage inMsg,
                            RouterIdentity remoteIdent,
                            Hash remoteIdentHash,
                            long msToReceive,
                            int bytesReceived)
```
    Message received from the I2NPMessageReader - send it to the listener
    
    パラメータ:
    
    inMsg - non-null
    
    remoteIdent - may be null
    
    remoteIdentHash - may be null, calculated from remoteIdent if null
  - getCurrentAddresses
```
public java.util.List<RouterAddress> getCurrentAddresses()
```
    What addresses are we currently listening to? Replaces getCurrentAddress()
    
    定義:
    
    getCurrentAddresses インタフェース内 Transport
    
    戻り値:
    
    all addresses, non-null
    
    導入されたバージョン:
    
    IPv6
  - getCurrentAddress
```
public RouterAddress getCurrentAddress(boolean ipv6)
```
    What address are we currently listening to? Replaces getCurrentAddress()
    
    パラメータ:
    
    ipv6 - true for IPv6 only; false for IPv4 only
    
    戻り値:
    
    first matching address or null
    
    導入されたバージョン:
    
    IPv6
  - hasCurrentAddress
```
public boolean hasCurrentAddress()
```
    Do we have any current address?
    
    定義:
    
    hasCurrentAddress インタフェース内 Transport
    
    導入されたバージョン:
    
    IPv6
  - updateAddress
```
public java.util.List<RouterAddress> updateAddress()
```
    Ask the transport to update its address based on current information and return it Transports should override.
    
    定義:
    
    updateAddress インタフェース内 Transport
    
    戻り値:
    
    all addresses, non-null
    
    導入されたバージョン:
    
    0.7.12
  - replaceAddress
```
protected void replaceAddress(RouterAddress address)
```
    Replace any existing addresses for the current transport with the same IP length (4 or 16) with the given one. TODO: Allow multiple addresses of the same length. Calls listener.transportAddressChanged() To remove all IPv4 or IPv6 addresses, use removeAddress(boolean).
    
    パラメータ:
    
    address - null to remove all
  - removeAddress
```
protected void removeAddress(RouterAddress address)
```
    Remove only this address. Calls listener.transportAddressChanged(). To remove all IPv4 or IPv6 addresses, use removeAddress(boolean). To remove all IPv4 and IPv6 addresses, use replaceAddress(null).
    
    導入されたバージョン:
    
    0.9.20
  - removeAddress
```
protected void removeAddress(boolean ipv6)
```
    Remove all existing addresses with the specified IP length (4 or 16). Calls listener.transportAddressChanged(). To remove all IPv4 and IPv6 addresses, use replaceAddress(null).
    
    パラメータ:
    
    ipv6 - true to remove all IPv6 addresses, false to remove all IPv4 addresses
    
    導入されたバージョン:
    
    0.9.20
  - saveLocalAddress
```
protected void saveLocalAddress(java.net.InetAddress address)
```
    Save a local address we were notified about before we started.
    
    導入されたバージョン:
    
    IPv6
  - getSavedLocalAddresses
```
protected java.util.Collection<java.net.InetAddress> getSavedLocalAddresses()
```
    Return and then clear all saved local addresses.
    
    導入されたバージョン:
    
    IPv6
  - getTargetAddresses
```
protected java.util.List<RouterAddress> getTargetAddresses(RouterInfo target)
```
    Get all available address we can use, shuffled and then sorted by cost/preference. Lowest cost (most preferred) first.
    
    戻り値:
    
    non-null, possibly empty
    
    導入されたバージョン:
    
    IPv6
  - externalAddressReceived
```
public abstract void externalAddressReceived(Transport.AddressSource source,
                                             byte[] ip,
                                             int port)
```
    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 before startListening() to set an initial address, or after the transport is running.
    
    定義:
    
    externalAddressReceived インタフェース内 Transport
    
    パラメータ:
    
    source - defined in Transport.java
    
    ip - typ. IPv4 or IPv6 non-local; may be null to indicate IPv4 failure or port info only
    
    port - 0 for unknown or unchanged
  - 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) This implementation does nothing. Transports should override if they want notification.
    
    定義:
    
    externalAddressRemoved インタフェース内 Transport
    
    パラメータ:
    
    source - defined in Transport.java
    
    導入されたバージョン:
    
    0.9.20
  - forwardPortStatus
```
public void forwardPortStatus(byte[] ip,
                              int port,
                              int externalPort,
                              boolean success,
                              java.lang.String reason)
```
    Notify a transport of the results of trying to forward a port. This implementation does nothing. Transports should override if they want notification.
    
    定義:
    
    forwardPortStatus インタフェース内 Transport
    
    パラメータ:
    
    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()
```
    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
    
    戻り値:
    
    port or -1 for none or 0 for any
  - setListener
```
public void setListener(TransportEventListener listener)
```
    Who to notify on message availability
    
    定義:
    
    setListener インタフェース内 Transport
  - renderStatusHTML
```
public void renderStatusHTML(java.io.Writer out)
                      throws java.io.IOException
```
    Make this stuff pretty (only used in the old console)
    
    例外:
    
    java.io.IOException
  - renderStatusHTML
```
public void renderStatusHTML(java.io.Writer out,
                             java.lang.String urlBase,
                             int sortFlags)
                      throws java.io.IOException
```
    定義:
    
    renderStatusHTML インタフェース内 Transport
    
    例外:
    
    java.io.IOException
  - getReachabilityStatus
```
public abstract CommSystemFacade.Status getReachabilityStatus()
```
    Previously returned short, now enum as of 0.9.20
    
    定義:
    
    getReachabilityStatus インタフェース内 Transport
  - recheckReachability
```
@Deprecated
public void recheckReachability()
```
    推奨されていません。 unused
    
    定義:
    
    recheckReachability インタフェース内 Transport
  - isIPv4Firewalled
```
public boolean isIPv4Firewalled()
```
    This returns true if the force-firewalled setting is configured, false otherwise.
    
    導入されたバージョン:
    
    0.9.20, public since 0.9.30
  - isIPv6Firewalled
```
public boolean isIPv6Firewalled()
```
    This returns true if the force-firewalled setting is configured, false otherwise.
    
    導入されたバージョン:
    
    0.9.27, public since 0.9.30
  - isBacklogged
```
public boolean isBacklogged(Hash peer)
```
    定義:
    
    isBacklogged インタフェース内 Transport
  - isEstablished
```
public boolean isEstablished(Hash peer)
```
    定義:
    
    isEstablished インタフェース内 Transport
  - mayDisconnect
```
public void mayDisconnect(Hash peer)
```
    Tell the transport that we may disconnect from this peer. This is advisory only.
    
    定義:
    
    mayDisconnect インタフェース内 Transport
    
    導入されたバージョン:
    
    0.9.24
  - isUnreachable
```
public boolean isUnreachable(Hash peer)
```
    定義:
    
    isUnreachable インタフェース内 Transport
  - markUnreachable
```
public void markUnreachable(Hash peer)
```
    called when we can't reach a peer
  - markReachable
```
public void markReachable(Hash peer,
                          boolean isInbound)
```
    called when we establish a peer connection (outbound or inbound)
  - wasUnreachable
```
public boolean wasUnreachable(Hash peer)
```
    Was the peer UNreachable (outbound only) the last time we tried it? This is NOT reset if the peer contacts us.
    
    定義:
    
    wasUnreachable インタフェース内 Transport
  - allowLocal
```
public boolean allowLocal()
```
    Are we allowed to connect to local addresses?
    
    導入されたバージョン:
    
    0.9.28 moved from UDPTransport
  - setIP
```
public void setIP(Hash peer,
                  byte[] ip)
```
    IP of the peer from the last connection (in or out, any transport).
    
    パラメータ:
    
    ip - IPv4 or IPv6, non-null
  - getIP
```
public static byte[] getIP(Hash peer)
```
    IP of the peer from the last connection (in or out, any transport).
    
    戻り値:
    
    IPv4 or IPv6 or null
  - clearCaches
```
static void clearCaches()
```
    導入されたバージョン:
    
    0.9.3
  - getIPv6Config
```
public TransportUtil.IPv6Config getIPv6Config()
```
    導入されたバージョン:
    
    IPv6, public since 0.9.30
  - isPubliclyRoutable
```
protected boolean isPubliclyRoutable(byte[] addr)
```
    Allows IPv6 only if the transport is configured for it. Caller must check if we actually have a public IPv6 address.
    
    パラメータ:
    
    addr - non-null
  - _t
```
protected java.lang.String _t(java.lang.String s)
```
    Translate
    
    導入されたバージョン:
    
    0.9.8 moved from transports
  - _t
```
protected java.lang.String _t(java.lang.String s,
                              java.lang.Object o)
```
    Translate
    
    導入されたバージョン:
    
    0.9.8 moved from transports
  - ngettext
```
protected java.lang.String ngettext(java.lang.String s,
                                    java.lang.String p,
                                    int n)
```
    Translate
    
    導入されたバージョン:
    
    0.9.8

クラス TransportImpl

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

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

フィールドの概要

コンストラクタの概要

メソッドの概要

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

インタフェースから継承されたメソッド net.i2p.router.transport.Transport

フィールドの詳細

_currentAddresses

_context

ADJUST_COST

CONGESTION_COST_ADJUSTMENT

コンストラクタの詳細

TransportImpl

メソッドの詳細

countPeers

countActivePeers

countActiveSendPeers

getMaxConnections

haveCapacity

haveCapacity

getClockSkews

getMostRecentErrorMessages

getNextMessage

afterSend

afterSend

afterSend

afterSend

send

outboundMessageReady

messageReceived

getCurrentAddresses

getCurrentAddress

hasCurrentAddress

updateAddress

replaceAddress

removeAddress

removeAddress

saveLocalAddress

getSavedLocalAddresses

getTargetAddresses

externalAddressReceived

externalAddressRemoved

forwardPortStatus

getRequestedPort

setListener

renderStatusHTML

renderStatusHTML

getReachabilityStatus

recheckReachability

isIPv4Firewalled

isIPv6Firewalled

isBacklogged

isEstablished

mayDisconnect

isUnreachable

markUnreachable

markReachable

wasUnreachable

allowLocal

setIP

getIP

clearCaches

getIPv6Config

isPubliclyRoutable

_t

_t

ngettext