Class EagerContentHandler.RetainedContentLoaderFactory.RetainedContentLoader

java.lang.Object

org.eclipse.jetty.server.handler.EagerContentHandler.ContentLoader

org.eclipse.jetty.server.handler.EagerContentHandler.RetainedContentLoaderFactory.RetainedContentLoader

All Implemented Interfaces:

Runnable, Invocable, Invocable.Task

Enclosing class:

EagerContentHandler.RetainedContentLoaderFactory

public static class EagerContentHandler.RetainedContentLoaderFactory.RetainedContentLoader
extends EagerContentHandler.ContentLoader
implements Invocable.Task

Delay dispatch until all content or an effective buffer size is reached

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable.Task

Invocable.Task.Abstract

Field Summary

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

Constructor	Description
RetainedContentLoader(Handler handler, Request request, Response response, Callback callback, long maxRetainedBytes, int framingOverhead, boolean rejectWhenExceeded)

Method Summary

Modifier and Type	Method	Description
Invocable.InvocationType	getInvocationType()
protected void	load()	Called to initiate eager loading of the content.
protected void	read(boolean execute)
void	run()	This is run when enough content has been received to dispatch to the next handler.

Methods inherited from class org.eclipse.jetty.server.handler.EagerContentHandler.ContentLoader

getCallback, getHandler, getRequest, getResponse, handle, handle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RetainedContentLoader

public RetainedContentLoader(Handler handler,
 Request request,
 Response response,
 Callback callback,
 long maxRetainedBytes,
 int framingOverhead,
 boolean rejectWhenExceeded)

Parameters:

handler - The next handler

request - The delayed request

response - The delayed response

callback - The delayed callback

maxRetainedBytes - The maximum size to buffer before dispatching to the next handler; or -1 for a heuristically determined default

framingOverhead - The bytes to account for per chunk when calculating the size; or -1 for a heuristic.

rejectWhenExceeded - If true then requests are rejected if the content is not complete before maxRetainedBytes.

Method Details

load

protected void load()

Description copied from class: EagerContentHandler.ContentLoader

Called to initiate eager loading of the content. The content may be loaded within the scope of this method, or within the scope of a callback as a result of a Request.demand(Runnable) call made by this methhod.

Specified by:

load in class EagerContentHandler.ContentLoader

read

protected void read(boolean execute)

getInvocationType

public Invocable.InvocationType getInvocationType()

Specified by:

getInvocationType in interface Invocable

Returns:

The InvocationType of this object

run

public void run()

This is run when enough content has been received to dispatch to the next handler.

Specified by:

run in interface Runnable