Package | Description |
---|---|
net.i2p.BOB |
BOB, the Basic Open Bridge, allows TCP applications to talk over I2P.
|
net.i2p.client.streaming |
API, interfaces, and factory for a TCP-like (reliable, authenticated, in order) set of sockets for
communicating over the IP-like (unreliable, unauthenticated, unordered) I2P
messages.
|
net.i2p.client.streaming.impl |
Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for
communicating over the IP-like (unreliable, unauthenticated, unordered) I2P
messages.
|
net.i2p.i2ptunnel |
Implementation of preconfigured tunnels, both for clients and servers,
and a UI for adding more and editing the configuration.
|
net.i2p.i2ptunnel.irc |
Filters for the IRC client tunnel, and DCC handlers.
|
net.i2p.i2ptunnel.socks |
SOCKS 4, 4a, and 5 client tunnels.
|
net.i2p.sam |
The SAM client API.
|
org.klomp.snark |
I2P version of the snark bittorrent client, imported in 2005 and heavily enhanced
to add a web UI, DHT support, and other features.
|
Constructor | Description |
---|---|
I2PtoTCP(I2PSocket I2Psock,
NamedDB info,
NamedDB database,
AtomicBoolean lives) |
Constructor
|
Modifier and Type | Method | Description |
---|---|---|
protected abstract I2PSocket |
AcceptingChannel.accept() |
|
I2PSocket |
I2PServerSocket.accept() |
Waits for the next socket connecting.
|
I2PSocket |
I2PSocketManager.connect(Destination peer) |
Create a new connected socket (block until the socket is created)
|
I2PSocket |
I2PSocketManager.connect(Destination peer,
I2PSocketOptions options) |
Create a new connected socket (block until the socket is created)
|
Modifier and Type | Method | Description |
---|---|---|
Set<I2PSocket> |
I2PSocketManager.listSockets() |
Retrieve a set of currently connected I2PSockets, either initiated locally or remotely.
|
Modifier and Type | Class | Description |
---|---|---|
(package private) class |
I2PSocketFull |
Bridge between the full streaming lib and the I2PSocket API
|
Modifier and Type | Method | Description |
---|---|---|
I2PSocket |
I2PServerSocketFull.accept() |
Waits for the next socket connecting.
|
I2PSocket |
I2PSocketManagerFull.connect(Destination peer) |
Create a new connected socket.
|
I2PSocket |
I2PSocketManagerFull.connect(Destination peer,
I2PSocketOptions options) |
Create a new connected socket.
|
I2PSocket |
I2PSocketManagerFull.receiveSocket() |
The accept() call.
|
Modifier and Type | Method | Description |
---|---|---|
Set<I2PSocket> |
I2PSocketManagerFull.listSockets() |
Retrieve a set of currently connected I2PSockets, either initiated locally or remotely.
|
Constructor | Description |
---|---|
StandardSocket(I2PSocket socket) |
Modifier and Type | Field | Description |
---|---|---|
protected List<I2PSocket> |
I2PTunnelClientBase.mySockets |
Modifier and Type | Method | Description |
---|---|---|
I2PSocket |
I2PTunnelClientBase.createI2PSocket(Destination dest) |
Create a new I2PSocket towards to the specified destination,
adding it to the list of connections actually managed by this
tunnel.
|
I2PSocket |
I2PTunnelClientBase.createI2PSocket(Destination dest,
int port) |
Create a new I2PSocket towards to the specified destination,
adding it to the list of connections actually managed by this
tunnel.
|
I2PSocket |
I2PTunnelClientBase.createI2PSocket(Destination dest,
I2PSocketOptions opt) |
Create a new I2PSocket towards to the specified destination,
adding it to the list of connections actually managed by this
tunnel.
|
Modifier and Type | Method | Description |
---|---|---|
protected void |
I2PTunnelHTTPServer.blockingHandle(I2PSocket socket) |
Called by the thread pool of I2PSocket handlers
|
protected void |
I2PTunnelIRCServer.blockingHandle(I2PSocket socket) |
|
protected void |
I2PTunnelServer.blockingHandle(I2PSocket socket) |
This is run in a thread from a limited-size thread pool via Handler.run(),
except for a standard server (this class, no extension, as determined in getUsePool()),
it is run directly in the acceptor thread (see run()).
|
protected void |
I2PTunnelHTTPClientRunner.close(OutputStream out,
InputStream in,
OutputStream i2pout,
InputStream i2pin,
Socket s,
I2PSocket i2ps,
Thread t1,
Thread t2) |
Why is this overridden?
Why flush in super but not here?
Why do things in different order than in super?
|
protected void |
I2PTunnelRunner.close(OutputStream out,
InputStream in,
OutputStream i2pout,
InputStream i2pin,
Socket s,
I2PSocket i2ps,
Thread t1,
Thread t2) |
|
(package private) static Map<String,List<String>> |
I2PTunnelHTTPServer.readHeaders(I2PSocket socket,
InputStream in,
StringBuilder command,
String[] skipHeaders,
I2PAppContext ctx) |
From I2P to server: socket non-null, in null.
|
Constructor | Description |
---|---|
I2PTunnelHTTPClientRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList,
I2PTunnelRunner.FailCallback onFail) |
Does NOT start itself.
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList,
Runnable onTimeout) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList,
I2PTunnelRunner.FailCallback onFail) |
Recommended new constructor.
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList,
Runnable onTimeout) |
Deprecated.
use FailCallback constructor
|
Constructor | Description |
---|---|
I2PTunnelHTTPClientRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList,
I2PTunnelRunner.FailCallback onFail) |
Does NOT start itself.
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList,
Runnable onTimeout) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
byte[] initialSocketData,
List<I2PSocket> sockList,
I2PTunnelRunner.FailCallback onFail) |
Recommended new constructor.
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList) |
Deprecated.
use FailCallback constructor
|
I2PTunnelRunner(Socket s,
I2PSocket i2ps,
Object slock,
byte[] initialI2PData,
List<I2PSocket> sockList,
Runnable onTimeout) |
Deprecated.
use FailCallback constructor
|
Modifier and Type | Method | Description |
---|---|---|
protected void |
I2PTunnelDCCServer.blockingHandle(I2PSocket socket) |
An incoming DCC connection, only accept for a known port.
|
Constructor | Description |
---|---|
IrcInboundFilter(Socket lcl,
I2PSocket rem,
StringBuffer pong,
Log log) |
|
IrcInboundFilter(Socket lcl,
I2PSocket rem,
StringBuffer pong,
Log log,
DCCHelper helper) |
|
IrcOutboundFilter(Socket lcl,
I2PSocket rem,
StringBuffer pong,
Log log) |
|
IrcOutboundFilter(Socket lcl,
I2PSocket rem,
StringBuffer pong,
Log log,
DCCHelper helper) |
Modifier and Type | Class | Description |
---|---|---|
(package private) class |
SocketWrapper |
Wrapper around the Socket obtained from the Outproxy, which is a
wrapper around the Orchid Stream.
|
Modifier and Type | Method | Description |
---|---|---|
I2PSocket |
SOCKS4aServer.getDestinationI2PSocket(I2PSOCKSTunnel t) |
Get an I2PSocket that can be used to send/receive 8-bit clean data
to/from the destination of the SOCKS connection.
|
I2PSocket |
SOCKS5Server.getDestinationI2PSocket(I2PSOCKSTunnel t) |
Get an I2PSocket that can be used to send/receive 8-bit clean data
to/from the destination of the SOCKS connection.
|
abstract I2PSocket |
SOCKSServer.getDestinationI2PSocket(I2PSOCKSTunnel t) |
Get an I2PSocket that can be used to send/receive 8-bit clean data
to/from the destination of the SOCKS connection.
|
Modifier and Type | Field | Description |
---|---|---|
protected I2PSocket |
SAMStreamSession.SAMStreamSessionSocketReader.i2pSocket |
|
protected I2PSocket |
SAMStreamSession.StreamSender.i2pSocket |
Modifier and Type | Method | Description |
---|---|---|
protected int |
SAMStreamSession.createSocketHandler(I2PSocket s,
int id) |
Create a new SAM STREAM session socket handler, detaching its thread.
|
protected SAMStreamSession.SAMStreamSessionSocketReader |
SAMStreamSession.newSAMStreamSessionSocketReader(I2PSocket s,
int id) |
|
protected SAMStreamSession.SAMStreamSessionSocketReader |
SAMv2StreamSession.newSAMStreamSessionSocketReader(I2PSocket s,
int id) |
|
protected SAMStreamSession.StreamSender |
SAMStreamSession.newStreamSender(I2PSocket s,
int id) |
|
protected SAMStreamSession.StreamSender |
SAMv2StreamSession.newStreamSender(I2PSocket s,
int id) |
Lets us push data through the stream without blocking, (even after exceeding
the I2PSocket's buffer)
|
boolean |
SAMv3StreamSession.queueSocket(I2PSocket sock) |
Put a socket on the accept queue.
|
Constructor | Description |
---|---|
SAMStreamSessionSocketReader(I2PSocket s,
int id) |
Create a new SAM STREAM session socket reader
|
SAMv1StreamSessionSocketReader(I2PSocket s,
int id) |
Create a new SAM STREAM session socket reader
|
SAMv2StreamSessionSocketReader(I2PSocket s,
int id) |
Create a new SAM STREAM session socket reader
|
StreamSender(I2PSocket s,
int id) |
Modifier and Type | Method | Description |
---|---|---|
(package private) I2PSocket |
I2PSnarkUtil.connect(PeerID peer) |
connect to the given destination
|
Modifier and Type | Method | Description |
---|---|---|
void |
PeerAcceptor.connection(I2PSocket socket,
InputStream in,
OutputStream out) |
Constructor | Description |
---|---|
Peer(I2PSocket sock,
InputStream in,
OutputStream out,
byte[] my_id,
byte[] infohash,
MetaInfo metainfo) |
Incoming connection.
|