InputBuffer.
| Modifier and Type | Field and Description |
|---|---|
| private volatile Request | |
| private volatile long |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| protected HttpContent | blockingRead()
Overrides org. Read next chunk of data in this thread, block if needed. |
| private boolean | |
| protected Executor | |
| public void | |
| private boolean | |
| public void | initiateAsyncronousDataReceiving()
Overrides org. Initiates asynchronous data receiving. |
| public void | recycle()
Overrides org.
Recycle this |
| protected void | updateInputContentBuffer(final Buffer buffer)
Overrides org.
|
| serverRequest | back to summary |
|---|---|
| private volatile Request serverRequest | |
| totalReadContentInBytes | back to summary |
|---|---|
| private volatile long totalReadContentInBytes | |
| ServerInputBuffer | back to summary |
|---|---|
| public ServerInputBuffer() | |
| blockingRead | back to summary |
|---|---|
| protected HttpContent blockingRead() throws IOException Overrides org. Doc from org. Read next chunk of data in this thread, block if needed.
| |
| checkChunkedMaxPostSize | back to summary |
|---|---|
| private boolean checkChunkedMaxPostSize() | |
| getThreadPool | back to summary |
|---|---|
| protected Executor getThreadPool() Overrides org.
| |
| initialize | back to summary |
|---|---|
| public void initialize(final Request serverRequest, final FilterChainContext ctx) | |
| initialized | back to summary |
|---|---|
| private boolean initialized() | |
| initiateAsyncronousDataReceiving | back to summary |
|---|---|
| public void initiateAsyncronousDataReceiving() Overrides org. Initiates asynchronous data receiving. This is service method, usually users don't have to call it explicitly.
| |
| recycle | back to summary |
|---|---|
| public void recycle() Overrides org. Doc from org.
Recycle this
| |
| updateInputContentBuffer | back to summary |
|---|---|
| protected void updateInputContentBuffer(final Buffer buffer) throws IOException Overrides org.
| |