class QueuedClientConnectionRunner extends ClientConnectionRunner
_context, _log, _manager, _reader| Constructor and Description |
|---|
QueuedClientConnectionRunner(RouterContext context,
ClientManager manager,
I2CPMessageQueue queue)Create a new runner with the given queues |
| Modifier and Type | Method and Description |
|---|---|
(package private) void | doSend(I2CPMessage msg)Actually send the I2CPMessage to the client. |
String | getClientVersion()The client version. |
void | setClientVersion(String version)Does nothing. |
void | startRunning()Starts the reader thread. |
void | stopRunning()Calls super() to stop the reader, and sends a poison message to the client. |
(package private) void | writeMessage(I2CPMessage msg)In super(), doSend queues it to the writer thread and
the writer thread calls writeMessage() to write to the output stream. |
ackSendMessage, createListener, disconnectClient, disconnectClient, disconnected, distributeMessage, failLeaseRequest, getAddress, getConfig, getConfig, getDestHash, getDestHash, getDestination, getDestinations, getFloodfillNetworkDatabaseFacade, getIsDead, getLeaseRequest, getLeaseSet, getNextMessageId, getPayload, getPrimaryConfig, getSessionId, getSessionIds, getSessionKeyManager, isDead, leaseSetCreated, receiveMessage, receiveMessage, registerEncryptedLS, removePayload, removeSession, reportAbuse, requestLeaseSet, sessionEstablished, setPayload, setSessionId, updateMessageDeliveryStatuspublic QueuedClientConnectionRunner(RouterContext context, ClientManager manager, I2CPMessageQueue queue)
context - the router contextmanager - the client managerqueue - the I2CP message queuevoid doSend(I2CPMessage msg) throws I2CPMessageException
doSend in class ClientConnectionRunnermsg - the message to sendI2CPMessageException - if queue full or on other errorspublic String getClientVersion()
getClientVersion in class ClientConnectionRunnerpublic void setClientVersion(String version)
setClientVersion in class ClientConnectionRunnerversion - the client version stringpublic void startRunning()
startRunning in class ClientConnectionRunnerpublic void stopRunning()
stopRunning in class ClientConnectionRunnervoid writeMessage(I2CPMessage msg)
writeMessage in class ClientConnectionRunnermsg - the message to write