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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addMessage(I2CPMessage msg)
Add this message to the writer's queue Nonblocking, throws exception if queue is fullvoid
run()
void
stopWriting()
No more messages - dont even try to send what we have
-
-
-
Constructor Detail
-
ClientWriterRunner
public ClientWriterRunner(RouterContext context, ClientConnectionRunner runner)
-
-
Method Detail
-
addMessage
public void addMessage(I2CPMessage msg) throws I2CPMessageException
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
-
-