org.eclipse.jetty.client

Class HttpSender

java.lang.Object

org.eclipse.jetty.client.HttpSender

All Implemented Interfaces:

EventListener, AsyncContentProvider.Listener

Direct Known Subclasses:

HttpSenderOverFCGI, HttpSenderOverHTTP, HttpSenderOverSPDY

public abstract class HttpSender
extends Object
implements AsyncContentProvider.Listener

HttpSender abstracts the algorithm to send HTTP requests, so that subclasses only implement the transport-specific code to send requests over the wire, implementing sendHeaders(HttpExchange, HttpContent, Callback) and sendContent(HttpExchange, HttpContent, Callback).

HttpSender governs two state machines.

The request state machine is updated by HttpSender as the various steps of sending a request are executed, see RequestState. At any point in time, a user thread may abort the request, which may (if the request has not been completely sent yet) move the request state machine to RequestState#FAILURE. The request state machine guarantees that the request steps are executed (by I/O threads) only if the request has not been failed already.

The sender state machine is updated by HttpSender from three sources: deferred content notifications (via onContent()), 100-continue notifications (via proceed(HttpExchange, Throwable)) and normal request send (via sendContent(HttpExchange, HttpContent, Callback)). This state machine must guarantee that the request sending is never executed concurrently: only one of those sources may trigger the call to sendContent(HttpExchange, HttpContent, Callback).

See Also:

HttpReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HttpSender(HttpChannel channel)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	abort(Throwable failure)
protected boolean	anyToFailure(Throwable failure)
protected boolean	beginToHeaders(Request request)
protected void	dispose()
protected boolean	expects100Continue(Request request)
protected HttpChannel	getHttpChannel()
protected HttpExchange	getHttpExchange()
protected boolean	headersToCommit(Request request)
void	onContent() Callback method invoked when content is available
void	proceed(HttpExchange exchange, Throwable failure)
protected boolean	queuedToBegin(Request request)
protected void	reset()
void	send(HttpExchange exchange)
protected abstract void	sendContent(HttpExchange exchange, HttpContent content, Callback callback) Implementations should send the content at the HttpContent cursor position over the wire.
protected abstract void	sendHeaders(HttpExchange exchange, HttpContent content, Callback callback) Implementations should send the HTTP headers over the wire, possibly with some content, in a single write, and notify the given callback of the result of this operation.
protected boolean	someToContent(Request request, ByteBuffer content)
protected boolean	someToSuccess(HttpExchange exchange)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

Constructor Detail

HttpSender

protected HttpSender(HttpChannel channel)

Method Detail

getHttpChannel

protected HttpChannel getHttpChannel()

getHttpExchange

protected HttpExchange getHttpExchange()

onContent

public void onContent()

Description copied from interface: AsyncContentProvider.Listener

Callback method invoked when content is available

Specified by:

onContent in interface AsyncContentProvider.Listener

send

public void send(HttpExchange exchange)

expects100Continue

protected boolean expects100Continue(Request request)

queuedToBegin

protected boolean queuedToBegin(Request request)

beginToHeaders

protected boolean beginToHeaders(Request request)

headersToCommit

protected boolean headersToCommit(Request request)

someToContent

protected boolean someToContent(Request request,
                    ByteBuffer content)

someToSuccess

protected boolean someToSuccess(HttpExchange exchange)

anyToFailure

protected boolean anyToFailure(Throwable failure)

sendHeaders

protected abstract void sendHeaders(HttpExchange exchange,
               HttpContent content,
               Callback callback)

Implementations should send the HTTP headers over the wire, possibly with some content, in a single write, and notify the given callback of the result of this operation.

If there is more content to send, then sendContent(HttpExchange, HttpContent, Callback) will be invoked.

Parameters:

exchange - the exchange to send

content - the content to send

callback - the callback to notify

sendContent

protected abstract void sendContent(HttpExchange exchange,
               HttpContent content,
               Callback callback)

Implementations should send the content at the HttpContent cursor position over the wire.

The HttpContent cursor is advanced by HttpSender at the right time, and if more content needs to be sent, this method is invoked again; subclasses need only to send the content at the HttpContent cursor position.

This method is invoked one last time when HttpContent.isConsumed() is true and therefore there is no actual content to send. This is done to allow subclasses to write "terminal" bytes (such as the terminal chunk when the transfer encoding is chunked) if their protocol needs to.

Parameters:

exchange - the exchange to send

content - the content to send

callback - the callback to notify

reset

protected void reset()

dispose

protected void dispose()

proceed

public void proceed(HttpExchange exchange,
           Throwable failure)

abort

public boolean abort(Throwable failure)