static class ThrottlingHttpClientHandler.ClientConnState
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
EXPECT_CONTINUE |
private SharedInputBuffer |
inbuffer |
private int |
inputState |
private SharedOutputBuffer |
outbuffer |
private int |
outputState |
static int |
READY |
private HttpRequest |
request |
static int |
REQUEST_BODY_DONE |
static int |
REQUEST_BODY_STREAM |
static int |
REQUEST_SENT |
private HttpResponse |
response |
static int |
RESPONSE_BODY_DONE |
static int |
RESPONSE_BODY_STREAM |
static int |
RESPONSE_DONE |
static int |
RESPONSE_RECEIVED |
static int |
SHUTDOWN |
private int |
timeout |
private boolean |
workerRunning |
Constructor and Description |
---|
ClientConnState(int bufsize,
IOControl ioControl,
ByteBufferAllocator allocator) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ContentInputBuffer |
getInbuffer() |
int |
getInputState() |
ContentOutputBuffer |
getOutbuffer() |
int |
getOutputState() |
HttpRequest |
getRequest() |
HttpResponse |
getResponse() |
int |
getTimeout() |
boolean |
isWorkerRunning() |
void |
resetInput() |
void |
resetOutput() |
void |
setInputState(int inputState) |
void |
setOutputState(int outputState) |
void |
setRequest(HttpRequest request) |
void |
setResponse(HttpResponse response) |
void |
setTimeout(int timeout) |
void |
setWorkerRunning(boolean b) |
void |
shutdown() |
public static final int SHUTDOWN
public static final int READY
public static final int REQUEST_SENT
public static final int EXPECT_CONTINUE
public static final int REQUEST_BODY_STREAM
public static final int REQUEST_BODY_DONE
public static final int RESPONSE_RECEIVED
public static final int RESPONSE_BODY_STREAM
public static final int RESPONSE_BODY_DONE
public static final int RESPONSE_DONE
private final SharedInputBuffer inbuffer
private final SharedOutputBuffer outbuffer
private volatile int inputState
private volatile int outputState
private volatile HttpRequest request
private volatile HttpResponse response
private volatile int timeout
private volatile boolean workerRunning
public ClientConnState(int bufsize, IOControl ioControl, ByteBufferAllocator allocator)
public ContentInputBuffer getInbuffer()
public ContentOutputBuffer getOutbuffer()
public int getInputState()
public void setInputState(int inputState)
public int getOutputState()
public void setOutputState(int outputState)
public HttpRequest getRequest()
public void setRequest(HttpRequest request)
public HttpResponse getResponse()
public void setResponse(HttpResponse response)
public int getTimeout()
public void setTimeout(int timeout)
public boolean isWorkerRunning()
public void setWorkerRunning(boolean b)
public void close()
public void shutdown()
public void resetInput()
public void resetOutput()