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 CPoolEntry
poolEntry
-
Constructor Summary
Constructors Constructor Description CPoolProxy(CPoolEntry entry)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bind(java.net.Socket socket)
Binds this connection to the given socket.void
close()
(package private) CPoolEntry
detach()
static CPoolEntry
detach(org.apache.http.HttpClientConnection conn)
void
flush()
java.lang.Object
getAttribute(java.lang.String id)
(package private) ManagedHttpClientConnection
getConnection()
java.lang.String
getId()
Returns connection ID which is expected to be unique for the life span of the connection manager.java.net.InetAddress
getLocalAddress()
int
getLocalPort()
org.apache.http.HttpConnectionMetrics
getMetrics()
(package private) CPoolEntry
getPoolEntry()
static CPoolEntry
getPoolEntry(org.apache.http.HttpClientConnection proxy)
private static CPoolProxy
getProxy(org.apache.http.HttpClientConnection conn)
java.net.InetAddress
getRemoteAddress()
int
getRemotePort()
java.net.Socket
getSocket()
Returns the underlying socket.int
getSocketTimeout()
javax.net.ssl.SSLSession
getSSLSession()
Obtains the SSL session of the underlying connection, if any.(package private) ManagedHttpClientConnection
getValidConnection()
boolean
isOpen()
boolean
isResponseAvailable(int timeout)
boolean
isStale()
static org.apache.http.HttpClientConnection
newProxy(CPoolEntry poolEntry)
void
receiveResponseEntity(org.apache.http.HttpResponse response)
org.apache.http.HttpResponse
receiveResponseHeader()
java.lang.Object
removeAttribute(java.lang.String id)
void
sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest request)
void
sendRequestHeader(org.apache.http.HttpRequest request)
void
setAttribute(java.lang.String id, java.lang.Object obj)
void
setSocketTimeout(int timeout)
void
shutdown()
java.lang.String
toString()
-
-
-
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:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceorg.apache.http.HttpConnection
- Throws:
java.io.IOException
-
shutdown
public void shutdown() throws java.io.IOException
- Specified by:
shutdown
in interfaceorg.apache.http.HttpConnection
- Throws:
java.io.IOException
-
isOpen
public boolean isOpen()
- Specified by:
isOpen
in interfaceorg.apache.http.HttpConnection
-
isStale
public boolean isStale()
- Specified by:
isStale
in interfaceorg.apache.http.HttpConnection
-
setSocketTimeout
public void setSocketTimeout(int timeout)
- Specified by:
setSocketTimeout
in interfaceorg.apache.http.HttpConnection
-
getSocketTimeout
public int getSocketTimeout()
- Specified by:
getSocketTimeout
in interfaceorg.apache.http.HttpConnection
-
getId
public java.lang.String getId()
Description copied from interface:ManagedHttpClientConnection
Returns connection ID which is expected to be unique for the life span of the connection manager.- Specified by:
getId
in interfaceManagedHttpClientConnection
-
bind
public void bind(java.net.Socket socket) throws java.io.IOException
Description copied from interface:ManagedHttpClientConnection
Binds 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:
bind
in interfaceManagedHttpClientConnection
- Parameters:
socket
- the socket to bind the connection to.- Throws:
java.io.IOException
-
getSocket
public java.net.Socket getSocket()
Description copied from interface:ManagedHttpClientConnection
Returns the underlying socket.- Specified by:
getSocket
in interfaceManagedHttpClientConnection
-
getSSLSession
public javax.net.ssl.SSLSession getSSLSession()
Description copied from interface:ManagedHttpClientConnection
Obtains 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:
getSSLSession
in interfaceManagedHttpClientConnection
- Returns:
- the underlying SSL session if available,
null
otherwise
-
isResponseAvailable
public boolean isResponseAvailable(int timeout) throws java.io.IOException
- Specified by:
isResponseAvailable
in 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:
sendRequestHeader
in interfaceorg.apache.http.HttpClientConnection
- Throws:
org.apache.http.HttpException
java.io.IOException
-
sendRequestEntity
public void sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest request) throws org.apache.http.HttpException, java.io.IOException
- Specified by:
sendRequestEntity
in interfaceorg.apache.http.HttpClientConnection
- Throws:
org.apache.http.HttpException
java.io.IOException
-
receiveResponseHeader
public org.apache.http.HttpResponse receiveResponseHeader() throws org.apache.http.HttpException, java.io.IOException
- Specified by:
receiveResponseHeader
in interfaceorg.apache.http.HttpClientConnection
- Throws:
org.apache.http.HttpException
java.io.IOException
-
receiveResponseEntity
public void receiveResponseEntity(org.apache.http.HttpResponse response) throws org.apache.http.HttpException, java.io.IOException
- Specified by:
receiveResponseEntity
in interfaceorg.apache.http.HttpClientConnection
- Throws:
org.apache.http.HttpException
java.io.IOException
-
flush
public void flush() throws java.io.IOException
- Specified by:
flush
in interfaceorg.apache.http.HttpClientConnection
- Throws:
java.io.IOException
-
getMetrics
public org.apache.http.HttpConnectionMetrics getMetrics()
- Specified by:
getMetrics
in interfaceorg.apache.http.HttpConnection
-
getLocalAddress
public java.net.InetAddress getLocalAddress()
- Specified by:
getLocalAddress
in interfaceorg.apache.http.HttpInetConnection
-
getLocalPort
public int getLocalPort()
- Specified by:
getLocalPort
in interfaceorg.apache.http.HttpInetConnection
-
getRemoteAddress
public java.net.InetAddress getRemoteAddress()
- Specified by:
getRemoteAddress
in interfaceorg.apache.http.HttpInetConnection
-
getRemotePort
public int getRemotePort()
- Specified by:
getRemotePort
in interfaceorg.apache.http.HttpInetConnection
-
getAttribute
public java.lang.Object getAttribute(java.lang.String id)
- Specified by:
getAttribute
in interfaceorg.apache.http.protocol.HttpContext
-
setAttribute
public void setAttribute(java.lang.String id, java.lang.Object obj)
- Specified by:
setAttribute
in interfaceorg.apache.http.protocol.HttpContext
-
removeAttribute
public java.lang.Object removeAttribute(java.lang.String id)
- Specified by:
removeAttribute
in interfaceorg.apache.http.protocol.HttpContext
-
toString
public java.lang.String toString()
- Overrides:
toString
in 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)
-
-