Modifier and Type	Class and Description
private class	HttpStreamOverHTTP2.SendTrailers
private class	HttpStreamOverHTTP2.TunnelSupportOverHTTP2

Modifier and Type	Field and Description
private Content.Chunk	_chunk
private final HTTP2ServerConnection	_connection
private boolean	_demand
private final HttpChannel	_httpChannel
private MetaData.Request	_requestMetaData
private MetaData.Response	_responseMetaData
private final HTTP2Stream	_stream
private Content.Chunk	_trailer
private boolean	committed
private final AutoLock	lock
private static final Logger	LOG
private TunnelSupport	tunnelSupport

Access	Constructor and Description
public	HttpStreamOverHTTP2(HTTP2ServerConnection connection, HttpChannel httpChannel, HTTP2Stream stream)

Method Summary

Modifier and Type	Method and Description
public Throwable	consumeAvailable() Implements org.eclipse.jetty.server.HttpStream.consumeAvailable.
private Content.Chunk	createChunk(Stream.Data data)
public void	demand() Implements org.eclipse.jetty.server.HttpStream.demand. Demands more content chunks to the underlying implementation.
public void	failed(Throwable the reason for the operation failure x) Overrides default org.eclipse.jetty.util.Callback.failed. Callback invoked when the operation fails.
public String	getId() Implements org.eclipse.jetty.server.HttpStream.getId.
public long	getIdleTimeout() Implements org.eclipse.jetty.server.HttpStream.getIdleTimeout.
public TunnelSupport	getTunnelSupport() Overrides default org.eclipse.jetty.server.HttpStream.getTunnelSupport.
public boolean	isCommitted() Implements org.eclipse.jetty.server.HttpStream.isCommitted.
public boolean	isIdle() Implements org.eclipse.jetty.http2.HTTP2Channel.Server.isIdle.
private boolean	isTunnel(MetaData.Request request, MetaData.Response response)
private void	onBadMessage(HttpException x)
public Runnable	onDataAvailable() Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onDataAvailable.
public Runnable	onFailure(Throwable failure, Callback callback) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onFailure.
public Runnable	onPushRequest(MetaData.Request request)
public Runnable	onRequest(HeadersFrame frame)
public void	onTimeout(TimeoutException timeout, BiConsumer<Runnable, Boolean> consumer) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTimeout.
public Runnable	onTrailer(HeadersFrame frame) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTrailer.
public void	prepareResponse(HttpFields.Mutable The headers to prepare. headers) Implements org.eclipse.jetty.server.HttpStream.prepareResponse. Prepare the response headers with respect to the stream.
public void	push(MetaData.Request the resource to push resource) Overrides default org.eclipse.jetty.server.HttpStream.push. Pushes the given `resource` to the client.
public Content.Chunk	read() Implements org.eclipse.jetty.server.HttpStream.read. Reads a chunk of content, with the same semantic as `Content.Source#read()`.
private HttpFields	retrieveTrailers()
public void	send(MetaData.Request The request metadata for which the response should be sent. request, MetaData.Response The response metadata to be sent or null if the response is already committed by a previous call to send. response, boolean True if this will be the last call to send and the response can be completed. last, ByteBuffer A buffer of content to send or null if no content. byteBuffer, Callback The callback to invoke when the send is completed successfully or in failure. callback) Implements org.eclipse.jetty.server.HttpStream.send. Send response meta-data and/or data.
private void	sendContent(MetaData.Request request, ByteBuffer content, boolean last, Callback callback)
private void	sendDataFrame(ByteBuffer content, boolean lastContent, boolean endStream, Callback callback)
private void	sendHeaders(MetaData.Request request, MetaData.Response response, ByteBuffer content, boolean last, Callback callback)
private void	sendTrailersFrame(MetaData metaData, Callback callback)
public void	setIdleTimeout(long idleTimeoutMs) Implements org.eclipse.jetty.server.HttpStream.setIdleTimeout.
public void	succeeded() Overrides default org.eclipse.jetty.util.Callback.succeeded. Callback invoked when the operation completes.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

_chunk	back to summary
private Content.Chunk _chunk

_connection	back to summary
private final HTTP2ServerConnection _connection

_demand	back to summary
private boolean _demand

_httpChannel	back to summary
private final HttpChannel _httpChannel

_requestMetaData	back to summary
private MetaData.Request _requestMetaData

_responseMetaData	back to summary
private MetaData.Response _responseMetaData

_stream	back to summary
private final HTTP2Stream _stream

_trailer	back to summary
private Content.Chunk _trailer

committed	back to summary
private boolean committed

lock	back to summary
private final AutoLock lock

LOG	back to summary
private static final Logger LOG

tunnelSupport	back to summary
private TunnelSupport tunnelSupport

Constructor Detail

HttpStreamOverHTTP2	back to summary
public HttpStreamOverHTTP2(HTTP2ServerConnection connection, HttpChannel httpChannel, HTTP2Stream stream)

Method Detail

consumeAvailable	back to summary
public Throwable consumeAvailable() Implements org.eclipse.jetty.server.HttpStream.consumeAvailable. Annotations @Override

consumeAvailable

back to summary

public Throwable consumeAvailable()

Implements org.eclipse.jetty.server.HttpStream.consumeAvailable.

Annotations

@Override

createChunk	back to summary
private Content.Chunk createChunk(Stream.Data data)

demand back to summary

demand	back to summary
public void demand() Implements org.eclipse.jetty.server.HttpStream.demand. Doc from org.eclipse.jetty.server.HttpStream.demand. Demands more content chunks to the underlying implementation. This method is called from the implementation of `Request#demand(Runnable)` and when the demand can be satisfied the implementation must call `HttpChannel#onContentAvailable()`. If there is a problem meeting demand, then the implementation must call `HttpChannel#onFailure(Throwable)`. Annotations @Override

public void demand()

Implements org.eclipse.jetty.server.HttpStream.demand.

Doc from org.eclipse.jetty.server.HttpStream.demand.

Demands more content chunks to the underlying implementation.

This method is called from the implementation of Request#demand(Runnable) and when the demand can be satisfied the implementation must call HttpChannel#onContentAvailable(). If there is a problem meeting demand, then the implementation must call HttpChannel#onFailure(Throwable).

Annotations

@Override

failed	back to summary
public void failed(Throwable x) Overrides default org.eclipse.jetty.util.Callback.failed. Doc from org.eclipse.jetty.util.Callback.failed. Callback invoked when the operation fails. Parameters x:Throwable the reason for the operation failure Annotations @Override

failed

back to summary

public void failed(Throwable x)

Overrides default org.eclipse.jetty.util.Callback.failed.

Doc from org.eclipse.jetty.util.Callback.failed.

Callback invoked when the operation fails.

Parameters

x:Throwable: the reason for the operation failure

Annotations

@Override

getId	back to summary
public String getId() Implements org.eclipse.jetty.server.HttpStream.getId. Returns:String Doc from org.eclipse.jetty.server.HttpStream.getId. an ID unique within the lifetime scope of the associated protocol connection. This may be a protocol ID (e.g. HTTP/2 stream ID) or it may be unrelated to the protocol. Annotations @Override

getId

back to summary

public String getId()

Implements org.eclipse.jetty.server.HttpStream.getId.

Returns:String

Doc from org.eclipse.jetty.server.HttpStream.getId.

an ID unique within the lifetime scope of the associated protocol connection. This may be a protocol ID (e.g. HTTP/2 stream ID) or it may be unrelated to the protocol.

Annotations

@Override

getIdleTimeout	back to summary
public long getIdleTimeout() Implements org.eclipse.jetty.server.HttpStream.getIdleTimeout. Annotations @Override

getIdleTimeout

back to summary

public long getIdleTimeout()

Implements org.eclipse.jetty.server.HttpStream.getIdleTimeout.

Annotations

@Override

getTunnelSupport	back to summary
public TunnelSupport getTunnelSupport() Overrides default org.eclipse.jetty.server.HttpStream.getTunnelSupport. Annotations @Override

getTunnelSupport

back to summary

public TunnelSupport getTunnelSupport()

Overrides default org.eclipse.jetty.server.HttpStream.getTunnelSupport.

Annotations

@Override

isCommitted	back to summary
public boolean isCommitted() Implements org.eclipse.jetty.server.HttpStream.isCommitted. Annotations @Override

isCommitted

back to summary

public boolean isCommitted()

Implements org.eclipse.jetty.server.HttpStream.isCommitted.

Annotations

@Override

isIdle	back to summary
public boolean isIdle() Implements org.eclipse.jetty.http2.HTTP2Channel.Server.isIdle. Annotations @Override

isIdle

back to summary

public boolean isIdle()

Implements org.eclipse.jetty.http2.HTTP2Channel.Server.isIdle.

Annotations

@Override

isTunnel	back to summary
private boolean isTunnel(MetaData.Request request, MetaData.Response response)

onBadMessage	back to summary
private void onBadMessage(HttpException x)

onDataAvailable	back to summary
public Runnable onDataAvailable() Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onDataAvailable. Annotations @Override

onDataAvailable

back to summary

public Runnable onDataAvailable()

Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onDataAvailable.

Annotations

@Override

onFailure	back to summary
public Runnable onFailure(Throwable failure, Callback callback) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onFailure. Annotations @Override

onFailure

back to summary

public Runnable onFailure(Throwable failure, Callback callback)

Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onFailure.

Annotations

@Override

onPushRequest	back to summary
public Runnable onPushRequest(MetaData.Request request)

onRequest	back to summary
public Runnable onRequest(HeadersFrame frame)

onTimeout	back to summary
public void onTimeout(TimeoutException timeout, BiConsumer<Runnable, Boolean> consumer) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTimeout. Annotations @Override

onTimeout

back to summary

public void onTimeout(TimeoutException timeout, BiConsumer<Runnable, Boolean> consumer)

Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTimeout.

Annotations

@Override

onTrailer	back to summary
public Runnable onTrailer(HeadersFrame frame) Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTrailer. Annotations @Override

onTrailer

back to summary

public Runnable onTrailer(HeadersFrame frame)

Implements org.eclipse.jetty.http2.HTTP2Channel.Server.onTrailer.

Annotations

@Override

prepareResponse back to summary

prepareResponse	back to summary
public void prepareResponse(HttpFields.Mutable headers) Implements org.eclipse.jetty.server.HttpStream.prepareResponse. Doc from org.eclipse.jetty.server.HttpStream.prepareResponse. Prepare the response headers with respect to the stream. Typically this may set headers related to protocol specific behaviour (e.g. `Keep-Alive` for HTTP/1.0 connections). Parameters headers:HttpFields.Mutable The headers to prepare. Annotations @Override

public void prepareResponse(HttpFields.Mutable headers)

Implements org.eclipse.jetty.server.HttpStream.prepareResponse.

Doc from org.eclipse.jetty.server.HttpStream.prepareResponse.

Prepare the response headers with respect to the stream. Typically this may set headers related to protocol specific behaviour (e.g. Keep-Alive for HTTP/1.0 connections).

Parameters

headers:HttpFields.Mutable: The headers to prepare.

Annotations

@Override

push back to summary

public void push(MetaData.Request resource)

Overrides default org.eclipse.jetty.server.HttpStream.push.

Doc from org.eclipse.jetty.server.HttpStream.push.

Pushes the given resource to the client.

Parameters

resource:MetaData.Request: the resource to push

Annotations

@Override

read back to summary

read	back to summary
public Content.Chunk read() Implements org.eclipse.jetty.server.HttpStream.read. Doc from org.eclipse.jetty.server.HttpStream.read. Reads a chunk of content, with the same semantic as `Content.Source#read()`. This method is called from the implementation of `Request#read()`. Returns:Content.Chunk a chunk of content, possibly with non-null `Chunk#getFailure()` or `null`. Annotations @Override

public Content.Chunk read()

Implements org.eclipse.jetty.server.HttpStream.read.

Doc from org.eclipse.jetty.server.HttpStream.read.

Reads a chunk of content, with the same semantic as Content.Source#read().

This method is called from the implementation of Request#read().

Returns:Content.Chunk

a chunk of content, possibly with non-null Chunk#getFailure() or null.

Annotations

@Override

retrieveTrailers	back to summary
private HttpFields retrieveTrailers()

send

back to summary

public void send(MetaData.Request request, MetaData.Response response, boolean last, ByteBuffer byteBuffer, Callback callback)

Implements org.eclipse.jetty.server.HttpStream.send.

Doc from org.eclipse.jetty.server.HttpStream.send.

Send response meta-data and/or data.

Parameters

request:MetaData.Request: The request metadata for which the response should be sent.
response:MetaData.Response: The response metadata to be sent or null if the response is already committed by a previous call to send.
last:boolean: True if this will be the last call to send and the response can be completed.
byteBuffer:ByteBuffer: A buffer of content to send or null if no content.
callback:Callback: The callback to invoke when the send is completed successfully or in failure.

Annotations

@Override

sendContent	back to summary
private void sendContent(MetaData.Request request, ByteBuffer content, boolean last, Callback callback)

sendDataFrame	back to summary
private void sendDataFrame(ByteBuffer content, boolean lastContent, boolean endStream, Callback callback)

sendHeaders	back to summary
private void sendHeaders(MetaData.Request request, MetaData.Response response, ByteBuffer content, boolean last, Callback callback)

sendTrailersFrame	back to summary
private void sendTrailersFrame(MetaData metaData, Callback callback)

setIdleTimeout	back to summary
public void setIdleTimeout(long idleTimeoutMs) Implements org.eclipse.jetty.server.HttpStream.setIdleTimeout. Annotations @Override

setIdleTimeout

back to summary

public void setIdleTimeout(long idleTimeoutMs)

Implements org.eclipse.jetty.server.HttpStream.setIdleTimeout.

Annotations

@Override

succeeded	back to summary
public void succeeded() Overrides default org.eclipse.jetty.util.Callback.succeeded. Doc from org.eclipse.jetty.util.Callback.succeeded. Callback invoked when the operation completes. Annotations @Override

succeeded

back to summary

public void succeeded()

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Doc from org.eclipse.jetty.util.Callback.succeeded.

Callback invoked when the operation completes.

Annotations

@Override

org.eclipse.jetty.http2.server.internal back to summary

private Class HttpStreamOverHTTP2.SendTrailers

Class Inheritance

extends Nested

java.lang.Object
org.eclipse.jetty.util.Callback.Nested
org.eclipse.jetty.http2.server.internal.HttpStreamOverHTTP2.SendTrailers

Field Summary

Modifier and Type	Field and Description
private final HttpFields	trailers

Constructor Summary

Access	Constructor and Description
private	SendTrailers(Callback callback, HttpFields trailers)

Method Summary

Modifier and Type	Method and Description
public void	succeeded() Overrides org.eclipse.jetty.util.Callback.Nested.succeeded. Overrides default org.eclipse.jetty.util.Callback.Completing.succeeded. Callback invoked when the operation completes.

Inherited from org.eclipse.jetty.util.Callback.Nested:: completed failed getCallback getInvocationType toString

Field Detail

trailers	back to summary
private final HttpFields trailers

Constructor Detail

SendTrailers	back to summary
private SendTrailers(Callback callback, HttpFields trailers)

Method Detail

succeeded

back to summary

public void succeeded()

Overrides org.eclipse.jetty.util.Callback.Nested.succeeded.

Overrides default org.eclipse.jetty.util.Callback.Completing.succeeded.

Doc from org.eclipse.jetty.util.Callback.succeeded.

Callback invoked when the operation completes.

Annotations

@Override

org.eclipse.jetty.http2.server.internal back to summary

private Class HttpStreamOverHTTP2.TunnelSupportOverHTTP2

Class Inheritance

extends Object
implements TunnelSupport

java.lang.Object
org.eclipse.jetty.http2.server.internal.HttpStreamOverHTTP2.TunnelSupportOverHTTP2

All Implemented Interfaces

org.eclipse.jetty.server.TunnelSupport

Field Summary

Modifier and Type	Field and Description
private final EndPoint	endPoint
private final String	protocol

Constructor Summary

Access	Constructor and Description
private	TunnelSupportOverHTTP2(String protocol)

Method Summary

Modifier and Type	Method and Description
public EndPoint	getEndPoint() Implements org.eclipse.jetty.server.TunnelSupport.getEndPoint. Returns the `EndPoint` that should be used to carry the tunneled protocol.
public String	getProtocol() Implements org.eclipse.jetty.server.TunnelSupport.getProtocol. Returns the protocol of the `CONNECT` tunnel, or `null` if the tunnel transports HTTP or opaque bytes.