Jetty 12.0.6 · org.eclipse.jetty.client.transport.internal.HttpReceiverOverHTTP

Modifier and Type	Field and Description
private Runnable	action
private final ByteBufferPool	byteBufferPool
private Content.Chunk	chunk
private boolean	complete
private final LongAdder	inMessages
private static final Logger	LOG Hides org.eclipse.jetty.client.transport.HttpReceiver.LOG.
private String	method
private RetainableByteBuffer	networkBuffer
private final HttpParser	parser
private boolean	shutdown
private int	status
private boolean	unsolicited

Access	Constructor and Description
public	HttpReceiverOverHTTP(HttpChannelOverHTTP channel)

Method Summary

Modifier and Type	Method and Description
private void	acquireNetworkBuffer()
public void	badMessage(HttpException the failure with the bad message information failure) Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.badMessage. Called to signal that a bad HTTP message has been received.
private Content.Chunk	consumeChunk()
public boolean	content(ByteBuffer buffer) Implements org.eclipse.jetty.http.HttpParser.HttpHandler.content.
public boolean	contentComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.contentComplete.
protected void	dispose() Overrides org.eclipse.jetty.client.transport.HttpReceiver.dispose. Disposes the state of this HttpReceiver.
public void	earlyEOF() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.earlyEOF. Called to signal that an EOF was received unexpectedly during the parsing of an HTTP message
public void	failAndClose(Throwable the failure. failure) Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.failAndClose. Fails the receiver and closes the underlying stream.
protected void	fillInterested()
private Runnable	getAndSetAction(Runnable action)
public HttpChannelOverHTTP	getHttpChannel() Overrides org.eclipse.jetty.client.transport.HttpReceiver.getHttpChannel.
private HttpConnectionOverHTTP	getHttpConnection()
pack-priv long	getMessagesIn()
protected ByteBuffer	getResponseBuffer()
public boolean	headerComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.headerComplete.
protected boolean	isShutdown()
public boolean	messageComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.messageComplete.
private RetainableByteBuffer	newNetworkBuffer()
protected void	onInterim() Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.onInterim. Prepare for the next step after an interim response was read.
protected ByteBuffer	onUpgradeFrom()
private boolean	Returns: true to indicate that parsing should be interrupted (and will be resumed by another thread). parse() Parses an HTTP response in the receivers buffer.
private boolean	Returns: true if no bytes were filled. parseAndFill() Parses the networkBuffer until the next content is generated or until the buffer is depleted.
public void	parsedHeader(HttpField The field parsed field) Implements org.eclipse.jetty.http.HttpParser.HttpHandler.parsedHeader. This is the method called by parser when an HTTP Header name and value is found
public void	parsedTrailer(HttpField The field parsed trailer) Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.parsedTrailer. This is the method called by parser when an HTTP Trailer name and value is found
private void	reacquireNetworkBuffer()
public Content.Chunk	read(boolean true to register for fill interest when no data was read. fillInterestIfNeeded) Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.read. Reads a chunk of data.
pack-priv void	receive()
private void	receiveNext()
private void	releaseNetworkBuffer()
protected void	reset() Overrides org.eclipse.jetty.client.transport.HttpReceiver.reset. Resets the state of this HttpReceiver.
private void	shutdown()
public void	startResponse(HttpVersion the http version in use version, int the response status status, String the response reason phrase reason) Implements org.eclipse.jetty.http.HttpParser.ResponseHandler.startResponse. This is the method called by parser when the HTTP request line is parsed
public String	toString() Overrides org.eclipse.jetty.client.transport.HttpReceiver.toString. Returns a string representation of the object.

Inherited from org.eclipse.jetty.client.transport.HttpReceiver:: abort getHttpDestination getHttpExchange hasContent isFailed responseBegin responseContentAvailable responseFailure responseHeader responseHeaders responseSuccess storeCookie

action	back to summary
private Runnable action

byteBufferPool	back to summary
private final ByteBufferPool byteBufferPool

chunk	back to summary
private Content.Chunk chunk

complete	back to summary
private boolean complete

inMessages	back to summary
private final LongAdder inMessages

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.client.transport.HttpReceiver.LOG.

method	back to summary
private String method

networkBuffer	back to summary
private RetainableByteBuffer networkBuffer

parser	back to summary
private final HttpParser parser

shutdown	back to summary
private boolean shutdown

status	back to summary
private int status

unsolicited	back to summary
private boolean unsolicited

HttpReceiverOverHTTP	back to summary
public HttpReceiverOverHTTP(HttpChannelOverHTTP channel)

Method Detail

acquireNetworkBuffer	back to summary
private void acquireNetworkBuffer()

badMessage	back to summary
public void badMessage(HttpException failure) Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.badMessage. Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.badMessage. Called to signal that a bad HTTP message has been received. Parameters failure:HttpException the failure with the bad message information Annotations @Override

badMessage

back to summary

public void badMessage(HttpException failure)

Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.badMessage.

Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.badMessage.

Called to signal that a bad HTTP message has been received.

Parameters

failure:HttpException: the failure with the bad message information

Annotations

@Override

consumeChunk	back to summary
private Content.Chunk consumeChunk()

content	back to summary
public boolean content(ByteBuffer buffer) Implements org.eclipse.jetty.http.HttpParser.HttpHandler.content. Annotations @Override

content

back to summary

public boolean content(ByteBuffer buffer)

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.content.

Annotations

@Override

contentComplete	back to summary
public boolean contentComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.contentComplete. Annotations @Override

contentComplete

back to summary

public boolean contentComplete()

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.contentComplete.

Annotations

@Override

dispose back to summary

dispose	back to summary
protected void dispose() Overrides org.eclipse.jetty.client.transport.HttpReceiver.dispose. Doc from org.eclipse.jetty.client.transport.HttpReceiver.dispose. Disposes the state of this HttpReceiver. Subclasses should override (but remember to call `super`) to dispose their own state. Either this method or `reset()` is called. Annotations @Override

protected void dispose()

Overrides org.eclipse.jetty.client.transport.HttpReceiver.dispose.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.dispose.

Disposes the state of this HttpReceiver.

Subclasses should override (but remember to call super) to dispose their own state.

Either this method or reset() is called.

Annotations

@Override

earlyEOF	back to summary
public void earlyEOF() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.earlyEOF. Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.earlyEOF. Called to signal that an EOF was received unexpectedly during the parsing of an HTTP message Annotations @Override

earlyEOF

back to summary

public void earlyEOF()

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.earlyEOF.

Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.earlyEOF.

Called to signal that an EOF was received unexpectedly during the parsing of an HTTP message

Annotations

@Override

failAndClose	back to summary
public void failAndClose(Throwable failure) Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.failAndClose. Doc from org.eclipse.jetty.client.transport.HttpReceiver.failAndClose. Fails the receiver and closes the underlying stream. Parameters failure:Throwable the failure. Annotations @Override

failAndClose

back to summary

public void failAndClose(Throwable failure)

Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.failAndClose.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.failAndClose.

Fails the receiver and closes the underlying stream.

Parameters

failure:Throwable: the failure.

Annotations

@Override

fillInterested	back to summary
protected void fillInterested()

getAndSetAction	back to summary
private Runnable getAndSetAction(Runnable action)

getHttpChannel	back to summary
public HttpChannelOverHTTP getHttpChannel() Overrides org.eclipse.jetty.client.transport.HttpReceiver.getHttpChannel. Annotations @Override

getHttpChannel

back to summary

public HttpChannelOverHTTP getHttpChannel()

Overrides org.eclipse.jetty.client.transport.HttpReceiver.getHttpChannel.

Annotations

@Override

getHttpConnection	back to summary
private HttpConnectionOverHTTP getHttpConnection()

getMessagesIn	back to summary
pack-priv long getMessagesIn()

getResponseBuffer	back to summary
protected ByteBuffer getResponseBuffer()

headerComplete	back to summary
public boolean headerComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.headerComplete. Annotations @Override

headerComplete

back to summary

public boolean headerComplete()

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.headerComplete.

Annotations

@Override

isShutdown	back to summary
protected boolean isShutdown()

messageComplete	back to summary
public boolean messageComplete() Implements org.eclipse.jetty.http.HttpParser.HttpHandler.messageComplete. Annotations @Override

messageComplete

back to summary

public boolean messageComplete()

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.messageComplete.

Annotations

@Override

newNetworkBuffer	back to summary
private RetainableByteBuffer newNetworkBuffer()

onInterim	back to summary
protected void onInterim() Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.onInterim. Doc from org.eclipse.jetty.client.transport.HttpReceiver.onInterim. Prepare for the next step after an interim response was read. Annotations @Override

onInterim

back to summary

protected void onInterim()

Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.onInterim.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.onInterim.

Prepare for the next step after an interim response was read.

Annotations

@Override

onUpgradeFrom	back to summary
protected ByteBuffer onUpgradeFrom()

parse	back to summary
private boolean parse() Parses an HTTP response in the receivers buffer. Returns:boolean true to indicate that parsing should be interrupted (and will be resumed by another thread).

parse

back to summary

private boolean parse()

Parses an HTTP response in the receivers buffer.

Returns:boolean: true to indicate that parsing should be interrupted (and will be resumed by another thread).

parseAndFill	back to summary
private boolean parseAndFill() Parses the networkBuffer until the next content is generated or until the buffer is depleted. If this method depletes the buffer, it will always try to re-fill until fill generates 0 byte. Returns:boolean true if no bytes were filled.

parseAndFill

back to summary

private boolean parseAndFill()

Parses the networkBuffer until the next content is generated or until the buffer is depleted. If this method depletes the buffer, it will always try to re-fill until fill generates 0 byte.

Returns:boolean: true if no bytes were filled.

parsedHeader	back to summary
public void parsedHeader(HttpField field) Implements org.eclipse.jetty.http.HttpParser.HttpHandler.parsedHeader. Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.parsedHeader. This is the method called by parser when an HTTP Header name and value is found Parameters field:HttpField The field parsed Annotations @Override

parsedHeader

back to summary

public void parsedHeader(HttpField field)

Implements org.eclipse.jetty.http.HttpParser.HttpHandler.parsedHeader.

Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.parsedHeader.

This is the method called by parser when an HTTP Header name and value is found

Parameters

field:HttpField: The field parsed

Annotations

@Override

parsedTrailer	back to summary
public void parsedTrailer(HttpField trailer) Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.parsedTrailer. Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.parsedTrailer. This is the method called by parser when an HTTP Trailer name and value is found Parameters trailer:HttpField The field parsed Annotations @Override

parsedTrailer

back to summary

public void parsedTrailer(HttpField trailer)

Overrides default org.eclipse.jetty.http.HttpParser.HttpHandler.parsedTrailer.

Doc from org.eclipse.jetty.http.HttpParser.HttpHandler.parsedTrailer.

This is the method called by parser when an HTTP Trailer name and value is found

Parameters

trailer:HttpField: The field parsed

Annotations

@Override

reacquireNetworkBuffer	back to summary
private void reacquireNetworkBuffer()

read back to summary

read	back to summary
public Content.Chunk read(boolean fillInterestIfNeeded) Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.read. Doc from org.eclipse.jetty.client.transport.HttpReceiver.read. Reads a chunk of data. If no data was read, `null` is returned and if `fillInterestIfNeeded` is `true` then fill interest is registered. The returned chunk of data may be the last one or an error exactly like `Content.Source#read()` specifies. Parameters fillInterestIfNeeded:boolean true to register for fill interest when no data was read. Returns:Content.Chunk the chunk of data that was read, or `null` if nothing was read. Annotations @Override

public Content.Chunk read(boolean fillInterestIfNeeded)

Implements abstract org.eclipse.jetty.client.transport.HttpReceiver.read.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.read.

Reads a chunk of data.

If no data was read, null is returned and if fillInterestIfNeeded is true then fill interest is registered.

The returned chunk of data may be the last one or an error exactly like Content.Source#read() specifies.

Parameters

fillInterestIfNeeded:boolean: true to register for fill interest when no data was read.

Returns:Content.Chunk

the chunk of data that was read, or null if nothing was read.

Annotations

@Override

receive	back to summary
pack-priv void receive()

receiveNext	back to summary
private void receiveNext()

releaseNetworkBuffer	back to summary
private void releaseNetworkBuffer()

reset back to summary

reset	back to summary
protected void reset() Overrides org.eclipse.jetty.client.transport.HttpReceiver.reset. Doc from org.eclipse.jetty.client.transport.HttpReceiver.reset. Resets the state of this HttpReceiver. Subclasses should override (but remember to call `super`) to reset their own state. Either this method or `dispose()` is called. Annotations @Override

protected void reset()

Overrides org.eclipse.jetty.client.transport.HttpReceiver.reset.

Doc from org.eclipse.jetty.client.transport.HttpReceiver.reset.

Resets the state of this HttpReceiver.

Subclasses should override (but remember to call super) to reset their own state.

Either this method or dispose() is called.

Annotations

@Override

shutdown	back to summary
private void shutdown()

startResponse	back to summary
public void startResponse(HttpVersion version, int status, String reason) Implements org.eclipse.jetty.http.HttpParser.ResponseHandler.startResponse. Doc from org.eclipse.jetty.http.HttpParser.ResponseHandler.startResponse. This is the method called by parser when the HTTP request line is parsed Parameters version:HttpVersion the http version in use status:int the response status reason:String the response reason phrase Annotations @Override

startResponse

back to summary

public void startResponse(HttpVersion version, int status, String reason)

Implements org.eclipse.jetty.http.HttpParser.ResponseHandler.startResponse.

Doc from org.eclipse.jetty.http.HttpParser.ResponseHandler.startResponse.

This is the method called by parser when the HTTP request line is parsed

Parameters

version:HttpVersion: the http version in use
status:int: the response status
reason:String: the response reason phrase

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides org.eclipse.jetty.client.transport.HttpReceiver.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides org.eclipse.jetty.client.transport.HttpReceiver.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

public Class HttpReceiverOverHTTP

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail