Package org.eclipse.jetty.client

Class HttpChannel

java.lang.Object

org.eclipse.jetty.client.HttpChannel

All Implemented Interfaces:

CyclicTimeouts.Expirable

Direct Known Subclasses:

HttpChannelOverFCGI, HttpChannelOverHTTP, HttpChannelOverHTTP2

public abstract class HttpChannel
extends Object
implements CyclicTimeouts.Expirable

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	HttpChannel(HttpDestination destination)

Method Summary

Modifier and Type	Method	Description
boolean	abort(HttpExchange exchange, Throwable requestFailure, Throwable responseFailure)
boolean	abortResponse(HttpExchange exchange, Throwable failure)
boolean	associate(HttpExchange exchange)	Associates the given exchange to this channel in order to be sent over the network.
void	destroy()
boolean	disassociate(HttpExchange exchange)
void	exchangeTerminated(HttpExchange exchange, Result result)
Result	exchangeTerminating(HttpExchange exchange, Result result)
protected abstract Connection	getConnection()
long	getExpireNanoTime()	Returns the expiration time in nanoseconds.
HttpDestination	getHttpDestination()
HttpExchange	getHttpExchange()
protected abstract HttpReceiver	getHttpReceiver()
protected abstract HttpSender	getHttpSender()
void	proceed(HttpExchange exchange, Throwable failure)
abstract void	release()
void	send()
abstract void	send(HttpExchange exchange)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

HttpChannel

protected HttpChannel(HttpDestination destination)

Method Details

destroy

public void destroy()

getHttpDestination

public HttpDestination getHttpDestination()

associate

public boolean associate(HttpExchange exchange)

Associates the given exchange to this channel in order to be sent over the network.

If the association is successful, the exchange can be sent. Otherwise, the channel must be disposed because whoever terminated the exchange did not do it - it did not have the channel yet.

Parameters:

exchange - the exchange to associate

Returns:

true if the association was successful, false otherwise

disassociate

public boolean disassociate(HttpExchange exchange)

getHttpExchange

public HttpExchange getHttpExchange()

getConnection

protected abstract Connection getConnection()

getExpireNanoTime

public long getExpireNanoTime()

Description copied from interface: CyclicTimeouts.Expirable

Returns the expiration time in nanoseconds.

The value to return must be calculated taking into account the current nanoTime, for example:

expireNanoTime = NanoTime.now() + timeoutNanos

Returning Long.MAX_VALUE indicates that this entity does not expire.

Specified by:

getExpireNanoTime in interface CyclicTimeouts.Expirable

Returns:

the expiration time in nanoseconds, or Long.MAX_VALUE if this entity does not expire

getHttpSender

protected abstract HttpSender getHttpSender()

getHttpReceiver

protected abstract HttpReceiver getHttpReceiver()

send

public void send()

send

public abstract void send(HttpExchange exchange)

release

public abstract void release()

proceed

public void proceed(HttpExchange exchange,
 Throwable failure)

abort

public boolean abort(HttpExchange exchange,
 Throwable requestFailure,
 Throwable responseFailure)

abortResponse

public boolean abortResponse(HttpExchange exchange,
 Throwable failure)

exchangeTerminating

public Result exchangeTerminating(HttpExchange exchange,
 Result result)

exchangeTerminated

public void exchangeTerminated(HttpExchange exchange,
 Result result)

toString

public String toString()

Overrides:

toString in class Object