Package net.i2p.router.client
Class ClientWriterRunner
java.lang.Object
net.i2p.router.client.ClientWriterRunner
- All Implemented Interfaces:
Runnable
class ClientWriterRunner extends Object implements Runnable
Async writer class so that if a client app hangs, they wont take down the
whole router with them (since otherwise the JobQueue would block until
the client reads from their i2cp socket, causing all sorts of bad things to
happen)
For external I2CP connections only.
-
Constructor Summary
Constructors Constructor Description ClientWriterRunner(RouterContext context, ClientConnectionRunner runner) -
Method Summary
Modifier and Type Method Description voidaddMessage(I2CPMessage msg)Add this message to the writer's queue Nonblocking, throws exception if queue is fullvoidrun()voidstopWriting()No more messages - dont even try to send what we have
-
Constructor Details
-
Method Details
-
addMessage
Add this message to the writer's queue Nonblocking, throws exception if queue is full- Throws:
I2CPMessageException
-
stopWriting
public void stopWriting()No more messages - dont even try to send what we have -
run
public void run()
-