Package org.apache.hc.core5.http.impl.nio

Class ClientHttp1StreamHandler

java.lang.Object

org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler

All Implemented Interfaces:

ResourceHolder

class ClientHttp1StreamHandler
extends java.lang.Object
implements ResourceHolder

Field Summary

Fields

Modifier and Type	Field	Description
private HttpRequest	committedRequest
private ConnectionReuseStrategy	connectionReuseStrategy
private HttpCoreContext	context
static Timeout	DEFAULT_WAIT_FOR_CONTINUE
private java.util.concurrent.atomic.AtomicBoolean	done
private AsyncClientExchangeHandler	exchangeHandler
private Http1Config	http1Config
private HttpProcessor	httpProcessor
private DataStreamChannel	internalDataChannel
private boolean	keepAlive
private Http1StreamChannel<HttpRequest>	outputChannel
private java.util.concurrent.atomic.AtomicBoolean	requestCommitted
private java.util.concurrent.atomic.AtomicReference<MessageState>	requestState
private java.util.concurrent.atomic.AtomicReference<MessageState>	responseState
private Timeout	timeout

Constructor Summary

Constructors

Constructor	Description
ClientHttp1StreamHandler(Http1StreamChannel<HttpRequest> outputChannel, HttpProcessor httpProcessor, Http1Config http1Config, ConnectionReuseStrategy connectionReuseStrategy, AsyncClientExchangeHandler exchangeHandler, HttpCoreContext context)

Method Summary

Modifier and Type	Method	Description
(package private) void	appendState(java.lang.StringBuilder buf)
private void	commitRequest(HttpRequest request, EntityDetails entityDetails)
(package private) void	consumeData(java.nio.ByteBuffer src)
(package private) void	consumeHeader(HttpResponse response, EntityDetails entityDetails)
(package private) void	dataEnd(java.util.List<? extends Header> trailers)
(package private) void	failed(java.lang.Exception cause)
(package private) java.lang.String	getRequestMethod()
(package private) boolean	handleTimeout()
(package private) boolean	isCompleted()
(package private) boolean	isOutputReady()
(package private) boolean	isRequestFinal()
(package private) boolean	isResponseFinal()
(package private) void	produceOutput()
void	releaseResources()
java.lang.String	toString()
(package private) void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_WAIT_FOR_CONTINUE

public static final Timeout DEFAULT_WAIT_FOR_CONTINUE

outputChannel

private final Http1StreamChannel<HttpRequest> outputChannel

internalDataChannel

private final DataStreamChannel internalDataChannel

httpProcessor

private final HttpProcessor httpProcessor

http1Config

private final Http1Config http1Config

connectionReuseStrategy

private final ConnectionReuseStrategy connectionReuseStrategy

exchangeHandler

private final AsyncClientExchangeHandler exchangeHandler

context

private final HttpCoreContext context

requestState

private final java.util.concurrent.atomic.AtomicReference<MessageState> requestState

responseState

private final java.util.concurrent.atomic.AtomicReference<MessageState> responseState

requestCommitted

private final java.util.concurrent.atomic.AtomicBoolean requestCommitted

done

private final java.util.concurrent.atomic.AtomicBoolean done

keepAlive

private volatile boolean keepAlive

timeout

private volatile Timeout timeout

committedRequest

private volatile HttpRequest committedRequest

Constructor Detail

ClientHttp1StreamHandler

ClientHttp1StreamHandler(Http1StreamChannel<HttpRequest> outputChannel,
                         HttpProcessor httpProcessor,
                         Http1Config http1Config,
                         ConnectionReuseStrategy connectionReuseStrategy,
                         AsyncClientExchangeHandler exchangeHandler,
                         HttpCoreContext context)

Method Detail

isRequestFinal

boolean isRequestFinal()

isResponseFinal

boolean isResponseFinal()

isCompleted

boolean isCompleted()

getRequestMethod

java.lang.String getRequestMethod()

isOutputReady

boolean isOutputReady()

commitRequest

private void commitRequest(HttpRequest request,
                           EntityDetails entityDetails)
                    throws java.io.IOException,
                           HttpException

Throws:

java.io.IOException

HttpException

produceOutput

void produceOutput()
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

consumeHeader

void consumeHeader(HttpResponse response,
                   EntityDetails entityDetails)
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

consumeData

void consumeData(java.nio.ByteBuffer src)
          throws HttpException,
                 java.io.IOException

Throws:

HttpException

java.io.IOException

updateCapacity

void updateCapacity(CapacityChannel capacityChannel)
             throws java.io.IOException

Throws:

java.io.IOException

dataEnd

void dataEnd(java.util.List<? extends Header> trailers)
      throws HttpException,
             java.io.IOException

Throws:

HttpException

java.io.IOException

handleTimeout

boolean handleTimeout()

failed

void failed(java.lang.Exception cause)

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder

appendState

void appendState(java.lang.StringBuilder buf)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object