|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.client.ClientConnectionRunner
net.i2p.router.client.QueuedClientConnectionRunner
class QueuedClientConnectionRunner
Zero-copy in-JVM. While super() starts both a reader and a writer thread, we only need a reader thread here.
Field Summary |
---|
Fields inherited from class net.i2p.router.client.ClientConnectionRunner |
---|
_context, _log, _reader |
Constructor Summary | |
---|---|
QueuedClientConnectionRunner(RouterContext context,
ClientManager manager,
I2CPMessageQueue queue)
Create a new runner with the given queues |
Method Summary | |
---|---|
(package private) void |
doSend(I2CPMessage msg)
Actually send the I2CPMessage to the client. |
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. |
Methods inherited from class net.i2p.router.client.ClientConnectionRunner |
---|
ackSendMessage, disconnectClient, disconnectClient, disconnected, distributeMessage, failLeaseRequest, getConfig, getDestHash, getIsDead, getLeaseRequest, getLeaseSet, getNextMessageId, getPayload, getSessionId, getSessionKeyManager, isDead, leaseSetCreated, receiveMessage, removePayload, reportAbuse, requestLeaseSet, sessionEstablished, setLeaseSet, setPayload, setSessionId, updateMessageDeliveryStatus |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueuedClientConnectionRunner(RouterContext context, ClientManager manager, I2CPMessageQueue queue)
Method Detail |
---|
public void startRunning()
startRunning
in class ClientConnectionRunner
public void stopRunning()
stopRunning
in class ClientConnectionRunner
void writeMessage(I2CPMessage msg)
writeMessage
in class ClientConnectionRunner
void doSend(I2CPMessage msg) throws I2CPMessageException
doSend
in class ClientConnectionRunner
I2CPMessageException
- if queue full or on other errors
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |