public class BHttpConnectionBase extends Object implements HttpInetConnection
HttpConnection implementations
and provides functionality common to both client and server HTTP connections.| Modifier | Constructor and Description |
|---|---|
protected |
BHttpConnectionBase(int bufferSize,
int fragmentSizeHint,
CharsetDecoder charDecoder,
CharsetEncoder charEncoder,
MessageConstraints messageConstraints,
ContentLengthStrategy incomingContentStrategy,
ContentLengthStrategy outgoingContentStrategy)
Creates new instance of BHttpConnectionBase.
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
awaitInput(int timeout) |
protected void |
bind(Socket socket)
Binds this connection to the given
Socket. |
void |
close()
Closes this connection gracefully.
|
protected InputStream |
createInputStream(long len,
SessionInputBuffer inBuffer) |
protected OutputStream |
createOutputStream(long len,
SessionOutputBuffer outbuffer) |
protected void |
doFlush() |
protected void |
ensureOpen() |
InetAddress |
getLocalAddress() |
int |
getLocalPort() |
HttpConnectionMetrics |
getMetrics()
Returns a collection of connection metrics.
|
InetAddress |
getRemoteAddress() |
int |
getRemotePort() |
protected SessionInputBuffer |
getSessionInputBuffer() |
protected SessionOutputBuffer |
getSessionOutputBuffer() |
protected Socket |
getSocket() |
protected InputStream |
getSocketInputStream(Socket socket) |
protected OutputStream |
getSocketOutputStream(Socket socket) |
int |
getSocketTimeout()
Returns the socket timeout value.
|
protected void |
incrementRequestCount() |
protected void |
incrementResponseCount() |
boolean |
isOpen()
Checks if this connection is open.
|
boolean |
isStale()
Checks whether this connection has gone down.
|
protected HttpEntity |
prepareInput(HttpMessage message) |
protected OutputStream |
prepareOutput(HttpMessage message) |
void |
setSocketTimeout(int timeout)
Sets the socket timeout value.
|
void |
shutdown()
Force-closes this connection.
|
String |
toString() |
protected BHttpConnectionBase(int bufferSize,
int fragmentSizeHint,
CharsetDecoder charDecoder,
CharsetEncoder charEncoder,
MessageConstraints messageConstraints,
ContentLengthStrategy incomingContentStrategy,
ContentLengthStrategy outgoingContentStrategy)
bufferSize - buffer size. Must be a positive number.fragmentSizeHint - fragment size hint.charDecoder - decoder to be used for decoding HTTP protocol elements.
If null simple type cast will be used for byte to char conversion.charEncoder - encoder to be used for encoding HTTP protocol elements.
If null simple type cast will be used for char to byte conversion.messageConstraints - Message constraints. If null
MessageConstraints.DEFAULT will be used.incomingContentStrategy - incoming content length strategy. If null
LaxContentLengthStrategy.INSTANCE will be used.outgoingContentStrategy - outgoing content length strategy. If null
StrictContentLengthStrategy.INSTANCE will be used.protected void ensureOpen()
throws IOException
IOExceptionprotected InputStream getSocketInputStream(Socket socket) throws IOException
IOExceptionprotected OutputStream getSocketOutputStream(Socket socket) throws IOException
IOExceptionprotected void bind(Socket socket) throws IOException
Socket. This socket will be
used by the connection to send and receive data.
After this method's execution the connection status will be reported
as open and the isOpen() will return true.
socket - the socket.IOException - in case of an I/O error.protected SessionInputBuffer getSessionInputBuffer()
protected SessionOutputBuffer getSessionOutputBuffer()
protected void doFlush()
throws IOException
IOExceptionpublic boolean isOpen()
HttpConnectionisOpen in interface HttpConnectionprotected Socket getSocket()
protected OutputStream createOutputStream(long len, SessionOutputBuffer outbuffer)
protected OutputStream prepareOutput(HttpMessage message) throws HttpException
HttpExceptionprotected InputStream createInputStream(long len, SessionInputBuffer inBuffer)
protected HttpEntity prepareInput(HttpMessage message) throws HttpException
HttpExceptionpublic InetAddress getLocalAddress()
getLocalAddress in interface HttpInetConnectionpublic int getLocalPort()
getLocalPort in interface HttpInetConnectionpublic InetAddress getRemoteAddress()
getRemoteAddress in interface HttpInetConnectionpublic int getRemotePort()
getRemotePort in interface HttpInetConnectionpublic void setSocketTimeout(int timeout)
HttpConnectionsetSocketTimeout in interface HttpConnectiontimeout - timeout value in millisecondspublic int getSocketTimeout()
HttpConnectiongetSocketTimeout in interface HttpConnection0 if timeout is disabled or -1 if
timeout is undefined.public void shutdown()
throws IOException
HttpConnectionshutdown in interface HttpConnectionIOExceptionpublic void close()
throws IOException
HttpConnectionshutdown instead.close in interface Closeableclose in interface AutoCloseableclose in interface HttpConnectionIOExceptionprotected boolean awaitInput(int timeout)
throws IOException
IOExceptionpublic boolean isStale()
HttpConnectionisStale in interface HttpConnectiontrue if attempts to use this connection are
likely to succeed, or false if they are likely
to fail and this connection should be closedprotected void incrementRequestCount()
protected void incrementResponseCount()
public HttpConnectionMetrics getMetrics()
HttpConnectiongetMetrics in interface HttpConnectionCopyright © 2005–2022 The Apache Software Foundation. All rights reserved.