Package org.apache.http.impl.conn
Class CPoolProxy
- java.lang.Object
-
- org.apache.http.impl.conn.CPoolProxy
-
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable,ManagedHttpClientConnection,org.apache.http.HttpClientConnection,org.apache.http.HttpConnection,org.apache.http.HttpInetConnection,org.apache.http.protocol.HttpContext
class CPoolProxy extends java.lang.Object implements ManagedHttpClientConnection, org.apache.http.protocol.HttpContext
- Since:
- 4.3
-
-
Field Summary
Fields Modifier and Type Field Description private CPoolEntrypoolEntry
-
Constructor Summary
Constructors Constructor Description CPoolProxy(CPoolEntry entry)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbind(java.net.Socket socket)Binds this connection to the given socket.voidclose()(package private) CPoolEntrydetach()static CPoolEntrydetach(org.apache.http.HttpClientConnection conn)voidflush()java.lang.ObjectgetAttribute(java.lang.String id)(package private) ManagedHttpClientConnectiongetConnection()java.lang.StringgetId()Returns connection ID which is expected to be unique for the life span of the connection manager.java.net.InetAddressgetLocalAddress()intgetLocalPort()org.apache.http.HttpConnectionMetricsgetMetrics()(package private) CPoolEntrygetPoolEntry()static CPoolEntrygetPoolEntry(org.apache.http.HttpClientConnection proxy)private static CPoolProxygetProxy(org.apache.http.HttpClientConnection conn)java.net.InetAddressgetRemoteAddress()intgetRemotePort()java.net.SocketgetSocket()Returns the underlying socket.intgetSocketTimeout()javax.net.ssl.SSLSessiongetSSLSession()Obtains the SSL session of the underlying connection, if any.(package private) ManagedHttpClientConnectiongetValidConnection()booleanisOpen()booleanisResponseAvailable(int timeout)booleanisStale()static org.apache.http.HttpClientConnectionnewProxy(CPoolEntry poolEntry)voidreceiveResponseEntity(org.apache.http.HttpResponse response)org.apache.http.HttpResponsereceiveResponseHeader()java.lang.ObjectremoveAttribute(java.lang.String id)voidsendRequestEntity(org.apache.http.HttpEntityEnclosingRequest request)voidsendRequestHeader(org.apache.http.HttpRequest request)voidsetAttribute(java.lang.String id, java.lang.Object obj)voidsetSocketTimeout(int timeout)voidshutdown()java.lang.StringtoString()
-
-
-
Field Detail
-
poolEntry
private volatile CPoolEntry poolEntry
-
-
Constructor Detail
-
CPoolProxy
CPoolProxy(CPoolEntry entry)
-
-
Method Detail
-
getPoolEntry
CPoolEntry getPoolEntry()
-
detach
CPoolEntry detach()
-
getConnection
ManagedHttpClientConnection getConnection()
-
getValidConnection
ManagedHttpClientConnection getValidConnection()
-
close
public void close() throws java.io.IOException- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfacejava.io.Closeable- Specified by:
closein interfaceorg.apache.http.HttpConnection- Throws:
java.io.IOException
-
shutdown
public void shutdown() throws java.io.IOException- Specified by:
shutdownin interfaceorg.apache.http.HttpConnection- Throws:
java.io.IOException
-
isOpen
public boolean isOpen()
- Specified by:
isOpenin interfaceorg.apache.http.HttpConnection
-
isStale
public boolean isStale()
- Specified by:
isStalein interfaceorg.apache.http.HttpConnection
-
setSocketTimeout
public void setSocketTimeout(int timeout)
- Specified by:
setSocketTimeoutin interfaceorg.apache.http.HttpConnection
-
getSocketTimeout
public int getSocketTimeout()
- Specified by:
getSocketTimeoutin interfaceorg.apache.http.HttpConnection
-
getId
public java.lang.String getId()
Description copied from interface:ManagedHttpClientConnectionReturns connection ID which is expected to be unique for the life span of the connection manager.- Specified by:
getIdin interfaceManagedHttpClientConnection
-
bind
public void bind(java.net.Socket socket) throws java.io.IOExceptionDescription copied from interface:ManagedHttpClientConnectionBinds this connection to the given socket. The connection is considered open if it is bound and the underlying socket is connection to a remote host.- Specified by:
bindin interfaceManagedHttpClientConnection- Parameters:
socket- the socket to bind the connection to.- Throws:
java.io.IOException
-
getSocket
public java.net.Socket getSocket()
Description copied from interface:ManagedHttpClientConnectionReturns the underlying socket.- Specified by:
getSocketin interfaceManagedHttpClientConnection
-
getSSLSession
public javax.net.ssl.SSLSession getSSLSession()
Description copied from interface:ManagedHttpClientConnectionObtains the SSL session of the underlying connection, if any. If this connection is open, and the underlying socket is anSSLSocket, the SSL session of that socket is obtained. This is a potentially blocking operation.- Specified by:
getSSLSessionin interfaceManagedHttpClientConnection- Returns:
- the underlying SSL session if available,
nullotherwise
-
isResponseAvailable
public boolean isResponseAvailable(int timeout) throws java.io.IOException- Specified by:
isResponseAvailablein interfaceorg.apache.http.HttpClientConnection- Throws:
java.io.IOException
-
sendRequestHeader
public void sendRequestHeader(org.apache.http.HttpRequest request) throws org.apache.http.HttpException, java.io.IOException- Specified by:
sendRequestHeaderin interfaceorg.apache.http.HttpClientConnection- Throws:
org.apache.http.HttpExceptionjava.io.IOException
-
sendRequestEntity
public void sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest request) throws org.apache.http.HttpException, java.io.IOException- Specified by:
sendRequestEntityin interfaceorg.apache.http.HttpClientConnection- Throws:
org.apache.http.HttpExceptionjava.io.IOException
-
receiveResponseHeader
public org.apache.http.HttpResponse receiveResponseHeader() throws org.apache.http.HttpException, java.io.IOException- Specified by:
receiveResponseHeaderin interfaceorg.apache.http.HttpClientConnection- Throws:
org.apache.http.HttpExceptionjava.io.IOException
-
receiveResponseEntity
public void receiveResponseEntity(org.apache.http.HttpResponse response) throws org.apache.http.HttpException, java.io.IOException- Specified by:
receiveResponseEntityin interfaceorg.apache.http.HttpClientConnection- Throws:
org.apache.http.HttpExceptionjava.io.IOException
-
flush
public void flush() throws java.io.IOException- Specified by:
flushin interfaceorg.apache.http.HttpClientConnection- Throws:
java.io.IOException
-
getMetrics
public org.apache.http.HttpConnectionMetrics getMetrics()
- Specified by:
getMetricsin interfaceorg.apache.http.HttpConnection
-
getLocalAddress
public java.net.InetAddress getLocalAddress()
- Specified by:
getLocalAddressin interfaceorg.apache.http.HttpInetConnection
-
getLocalPort
public int getLocalPort()
- Specified by:
getLocalPortin interfaceorg.apache.http.HttpInetConnection
-
getRemoteAddress
public java.net.InetAddress getRemoteAddress()
- Specified by:
getRemoteAddressin interfaceorg.apache.http.HttpInetConnection
-
getRemotePort
public int getRemotePort()
- Specified by:
getRemotePortin interfaceorg.apache.http.HttpInetConnection
-
getAttribute
public java.lang.Object getAttribute(java.lang.String id)
- Specified by:
getAttributein interfaceorg.apache.http.protocol.HttpContext
-
setAttribute
public void setAttribute(java.lang.String id, java.lang.Object obj)- Specified by:
setAttributein interfaceorg.apache.http.protocol.HttpContext
-
removeAttribute
public java.lang.Object removeAttribute(java.lang.String id)
- Specified by:
removeAttributein interfaceorg.apache.http.protocol.HttpContext
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
newProxy
public static org.apache.http.HttpClientConnection newProxy(CPoolEntry poolEntry)
-
getProxy
private static CPoolProxy getProxy(org.apache.http.HttpClientConnection conn)
-
getPoolEntry
public static CPoolEntry getPoolEntry(org.apache.http.HttpClientConnection proxy)
-
detach
public static CPoolEntry detach(org.apache.http.HttpClientConnection conn)
-
-