ClientWriterRunner (Javadocs [I2P+ 2.13.0+] - API Version 0.9.70+)

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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, it won't take down the whole router with it (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 and Description
ClientWriterRunner(RouterContext ctx, ClientConnectionRunner runner)
Creates a new client writer runner.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addMessage(I2CPMessage msg)` Add this message to the writer's queue Nonblocking, throws exception if queue is full
`static int`	`getQueueSize()` Get the queue size.
`void`	`run()`
`static void`	`setQueueSize(int val)` Set the queue size.
`void`	`stopWriting()` No more messages - don't even try to send what we have

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ClientWriterRunner
```
public ClientWriterRunner(RouterContext ctx,
                          ClientConnectionRunner runner)
```
    Creates a new client writer runner.
    Parameters:
    ctx - the router context
    runner - the client connection 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
    Parameters:
    msg - the message to add
    Throws:
    I2CPMessageException - if the queue is full
  - getQueueSize
```
public static int getQueueSize()
```
    Get the queue size.
    Returns:
    the queue size
  - run
```
public void run()
```
    Specified by:
    run in interface Runnable
  - setQueueSize
```
public static void setQueueSize(int val)
```
    Set the queue size.
    Parameters:
    val - the new queue size
  - stopWriting
```
public void stopWriting()
```
    No more messages - don't even try to send what we have

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method