Package net.i2p.router.client
Class ClientListenerRunner
java.lang.Object
net.i2p.router.client.ClientListenerRunner
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
SSLClientListenerRunner
Listen for connections on the specified port, and toss them onto the client manager's
set of connections once they are established.
This is not used for internal (in-JVM) connections - see ClientManager and QueuedClientConnectionRunner.
Note that this is extended by SSLClientListenerRunner for SSL,
and by DomainClientListenerRunner in Android for domain sockets.
- Author:
- jrandom
-
Field Summary
Modifier and TypeFieldDescriptionprotected final boolean
protected final RouterContext
protected boolean
protected final Log
protected final ClientManager
protected final int
protected boolean
protected ServerSocket
static final String
protected static final int
give the i2cp client 5 seconds to show that they're really i2cp clients -
Constructor Summary
ConstructorDescriptionClientListenerRunner
(RouterContext context, ClientManager manager, int port) -
Method Summary
Modifier and TypeMethodDescriptionprotected ServerSocket
Get a ServerSocket.boolean
void
run()
protected void
runConnection
(Socket socket) Handle the connection by passing it off to aClientConnectionRunner
protected void
Start up the socket listener, listens for connections, and fires those connections off viarunConnection
.void
protected boolean
Verify the first byte.
-
Field Details
-
_log
-
_context
-
_manager
-
_socket
-
_port
protected final int _port -
_bindAllInterfaces
protected final boolean _bindAllInterfaces -
_running
protected volatile boolean _running -
_listening
protected volatile boolean _listening -
BIND_ALL_INTERFACES
- See Also:
-
CONNECT_TIMEOUT
protected static final int CONNECT_TIMEOUTgive the i2cp client 5 seconds to show that they're really i2cp clients- See Also:
-
-
Constructor Details
-
ClientListenerRunner
-
-
Method Details
-
isListening
public boolean isListening() -
getServerSocket
Get a ServerSocket. Split out so it can be overridden for SSL.- Throws:
IOException
- Since:
- 0.8.3
-
run
public void run() -
runServer
protected void runServer()Start up the socket listener, listens for connections, and fires those connections off viarunConnection
. This only returns if the socket cannot be opened or there is a catastrophic failure. -
validate
Verify the first byte. -
runConnection
Handle the connection by passing it off to aClientConnectionRunner
-
stopListening
public void stopListening()
-